/** @file CbmDaq.h
 ** @author Volker Friese <v.friese@gsi.de>
 ** @date 20 July 2012
 **/


#ifndef CBMDAQ_H
#define CBMDAQ_H 1

#include "TStopwatch.h"
#include "FairTask.h"
#include "CbmMCEventList.h"


class CbmDaqBuffer;
class CbmDigi;
class CbmTimeSlice;


/** @class CbmDaq
 ** @author Volker Friese <v.friese@gsi.de>
 ** @date 20 July 2012
 ** @brief CBM task class for filling digis from the CbmDaqBuffer into
 ** timeslice containers
 **/
class CbmDaq : public FairTask
{
  public:

    /**   Constructor
     ** @param timeSliceSize  Duration of time slices [ns]
     **/
    CbmDaq(Double_t timeSliceSize = 1000.);


    /**   Destructor   **/
    ~CbmDaq();


    /**   Task execution   **/
    virtual void Exec(Option_t* opt);


    /**   Task initialisation   **/
    virtual InitStatus Init();


  private:

    /** Start time of current time slice [ns] **/
    Double_t fCurrentStartTime;

    /** Duration of time slice [ns] **/
    Double_t fDuration;

    /** Flag whether empty timeslices should be filled to the tree **/
    // TODO: Implement functionality
    Bool_t fStoreEmptySlices;

    /** Timer **/
    TStopwatch fTimer;

    /** Counters **/
    Int_t fNofSteps;             ///< Number of execute steps
    Int_t fNofDigis;             ///< Total number of processed digis
    Int_t fNofTimeSlices;        ///< Number of time slices
    Int_t fNofTimeSlicesEmpty;   ///< Number of empty time slices
    Double_t fTimeDigiFirst;     ///< Time of first digi
    Double_t fTimeDigiLast;      ///< Time of last digi
    Double_t fTimeSliceFirst;    ///< Start time of first time slice
    Double_t fTimeSliceLast;     ///< Stop time of last time slice


    /** Pointer to current time slice **/
    CbmTimeSlice* fTimeSlice;

    /** Pointer to CbmDaqBuffer instance  **/
    CbmDaqBuffer* fBuffer;
    
    /** MC event list (all events) **/
    CbmMCEventList fEventList;      //!  MC event list (all)
    CbmMCEventList* fEventsCurrent; //! MC events for current time slice

    /** First and last event in current time slice for each input **/
    map<Int_t, pair<Int_t, Int_t>> fEventRange; //!


    /** Close the current time slice
     ** The current slice is filled to the tree. It is then reset
     ** to the next time slice interval.
     */
    void CloseTimeSlice();


    /** Copy the MC events contributing to the current time slice
     ** to the output array.
     **
     ** @value  Number of MC events for this time slice
     **/
    Int_t CopyEventList();


    /** Fill data from the buffer into the current time slice
     ** @return Number if digis filled into the timeslice
     **/
    Int_t FillTimeSlice();


    /** Screen log of the range of MC events contributing to the
     ** current time slice
     **/
    void PrintCurrentEventRange() const;


    /** Register input and entry number of a MC event contributing data
     ** to the current time slice.
     **
     ** CbmDaq stores the first and last event for each input such that
     ** it can be copied from the event list after the time slice is
     ** closed and filled to the tree.
     **/
    void RegisterEvent(CbmDigi* digi);


    /** At end of run: Process the remaining data in the CbmDaqBuffer  **/
    virtual void Finish();

    CbmDaq(const CbmDaq&);
    CbmDaq& operator=(const CbmDaq&);
    
    ClassDef (CbmDaq,1);

};

#endif /* CBMDAQ_H */