#ifndef TCtr16RawPROCESSOR_H
#define TCtr16RawPROCESSOR_H

/* VUPROM Ctr16 beam monitor
 * Version 0.9 on 3-Nov-2010 by J.Adamczewski-Musch, GSI
 * V 0.92 25-Jan-2010 with mean/sigma calculation of counts by J.Adamczewski-Musch, GSI
 * */

class TCtr16RawParam;
class TGo4Fitter;

#include "TGo4EventProcessor.h"
#include "TGo4WinCond.h"

#include <vector>

#include "TCtr16RawEvent.h"
#include "TCtr16Display.h"

class TCtr16RawProc: public TGo4EventProcessor
{

public:
  TCtr16RawProc();
  TCtr16RawProc(const char *name);
  virtual ~TCtr16RawProc();

  Bool_t BuildEvent(TGo4EventElement *target);    // event processing function

protected:

  /** handle subevent payload in case of VULOM readout */
   Bool_t ProcessVulomSubevent();

  /** handle subevent payload in case of GOSIP readout */
    Bool_t ProcessGosipSubevent();


  /** Additional histogram filling here*/
  Bool_t UpdateDisplays();

  /** access to histogram set for current board id*/
  TCtr16BoardDisplay* GetBoardDisplay(Int_t uniqueid);

  /** recreate histograms using the given number of time slice*/
  void InitDisplay(Int_t timeslices, Int_t numsnapshots, Bool_t replace = kFALSE);

  /** get next data word from subevent payload.
   * Optionally align it to word boundaries.
   * Return values: 1: message exceeded, 2: subevent exceeded, 0:OK
   * */
  Int_t NextDataWord();

  /** Change alignment of subevent payload words*/
  void SwitchDataAlignment();

  /** Unpacker for data type frames**/
  Int_t HandleDataFrame(TCtr16Board*, TCtr16BoardDisplay *disp);

  /** Unpacker for data continuation type frames**/
  Int_t HandleContinuationFrame(TCtr16Board*, TCtr16BoardDisplay *disp);

  /** Unpacker for error type frames**/
  Int_t HandleErrorFrame(TCtr16Board*, TCtr16BoardDisplay *disp);

  /** Unpacker for wishbone type frames**/
  Int_t HandleWishboneFrame(TCtr16Board *board, TCtr16BoardDisplay *disp);

  /** unpacker for transient data events which is used both in data frame and continuation frame*/
  Int_t UnpackTrace(TCtr16Board *board, TCtr16BoardDisplay *disp, UInt_t epoch);

  /* Get trace data from transient event message.*
   * Return values: 1: message exceeded, 2: subevent exceeded, 0:OK
   * */
  Int_t ExtractTrace(TCtr16Board *board, TCtr16BoardDisplay *disp);

  /* Scan through most recent trace data of board and build event message.
   * Also fill trace histograms and snapshots*/
  void FinalizeTrace(TCtr16Board *board, TCtr16BoardDisplay *disp);

  /** unpacker for feature extracted data*/
  Int_t UnpackFeature(TCtr16Board *board, TCtr16BoardDisplay *disp, UInt_t epoch);

  /** unpacker for threshold messages*/
  Int_t UnpackThresholdMessage(TCtr16Board *board, TCtr16BoardDisplay *disp);

  /** unpacker for slow control messages, except for threshold type*/
  Int_t UnpackSlowControlMessage(TCtr16Board *board, TCtr16BoardDisplay *disp, TCtr16MsgWishbone *theMsg);

  /** unpacker for plain wishbone messages, except for slow control or threshold type*/
  Int_t UnpackWishboneMessage(TCtr16Board *board, TCtr16BoardDisplay *disp, TCtr16MsgWishbone *theMsg);

  /** Evaluate time differences between current event ev and previous event of that channel*/
  void UpdateDeltaTimes(TCtr16Board *board, TCtr16BoardDisplay *disp, TCtr16MsgEvent *ev, UChar_t chan);

  /** calculate corrected adc value from raw entry, using correction vector histogram of display*/
  Double_t CorrectedADCVal(Short_t raw, TCtr16BoardDisplay *boardDisplay);

  /** subdisplays for each frotend board */
  std::vector<TCtr16BoardDisplay*> fBoards;

  /** parameter for runtime settings*/
  TCtr16RawParam *fPar;

  /* The current mbs input event*/
  TGo4MbsEvent *fMbsEvt;

  /** the current input subevent */
  TGo4MbsSubEvent *fPsubevt;

  /** reference to output data*/
  TCtr16RawEvent *Ctr16RawEvent;    //!

//  /** remember most recent message for delta T evaluation*/
  TCtr16MsgEvent fLastMessages[Ctr16_CHANNELS];

  /** unpacker working pointer*/
  Int_t *fPdata;    //!

  /** begin of payload working pointer*/
  Int_t *fPdatastart;    //!

  /** length of subevent in 32bit words*/
  Int_t fLwords;    //!

  /** begin of message working pointer*/
  Int_t *fPdatastartMsg;    //!

  /** message size in 32bit words*/
  Int_t fMsize;    //!

  /** Copy of current working data
   * For message alignment */
  Int_t fWorkData;    //!

  /** Required bitshift to align payload to 32bit*/
  Int_t fWorkShift;    //!


#ifdef Ctr16_DO_MEMORYSAMPLES
/* local event counter for writing out ADC memory decision (simple approach)*/
  Int_t fEventCounter; //!
  Bool_t fIgnoreTheRest; //!
#endif


ClassDef(TCtr16RawProc,1)
};

#endif //TUNPACKPROCESSOR_H