In This Package:

MixRootIOCnvSvc.h

Go to the documentation of this file.

#ifndef MixRootIOCnvSvc_H
#define MixRootIOCnvSvc_H

#include <algorithm>

//#include "TRandom3.h"
#include "TRandom.h"

#include "RootIOSvc/RootIOCnvSvc.h"
#include "Mixing/MixHeader.h"
#include "Mixing/IMixingSvc.h"
#include "Context/TimeStamp.h"
#include "Conventions/Detectors.h"

#include "GaudiKernel/MsgStream.h"
//#include "GaudiKernel/RndmGenerators.h"

using namespace std;
using namespace DayaBay;

class  IRndmGenSvc;
class  PerReadoutHeader;

class MixRootIOCnvSvc : public RootIOCnvSvc, virtual public IMixingSvc
{
public:
  MixRootIOCnvSvc(const string& name, ISvcLocator* svc);
  virtual ~MixRootIOCnvSvc();

  virtual StatusCode         initialize();
  virtual StatusCode         queryInterface(const InterfaceID& riid, void** ppint);
  virtual void               setInputFiles( const vector<string>& inputs) 
                             { m_defaultInputFilenames = inputs;}

  virtual StatusCode         buildStream();
  virtual StatusCode         readin(deque<MixHeader>* value);
  virtual MixHeader          fetchMixHeader();
  virtual void               print();
  virtual long               entries();
 
private:
  StatusCode                                   updateBuffer();
  StatusCode                                   doInit();
  double                                       nextTime(double tau);
  double                                       flatdis(double maximum);  
  void                                         performMixing();

  map<string, vector<string> >                 m_inputSamples;
  map<string, RootInputStream*>                m_simROMap;
  map<string, map<string, RootInputStream*> >  m_sampleInputStreamMap;

  long                                         m_totalentries;
  double                                       m_days;
  double                                       m_maximum;
  double                                       m_maintau;
  double                                       m_lasttime;
  TimeStamp                                    m_lastTime;

  //The three ones for sampling
  map<string, int>                             m_fileNum;
  map<string, int>                             m_fileindex;
  map<string, int>                             m_fileEntryNum;

  map<string, int>                             m_fileentries;
  map<string, int>                             m_streamentries;
  map<string, double>                          m_nod;
  map<string, double>                          m_timeTau;

  deque<MixHeader>*                            m_firstBuffer; 
  deque<MixHeader>*                            m_secondBuffer; 
  deque<MixHeader>*                            m_tesBuffer;

  mutable                                      MsgStream m_log;
  //TRandom3                                   m_randomNum;
  //unsigned int                                       m_randomSeed;
  //IRndmGenSvc*                               m_ranSvc;  
  //Rndm::Numbers                              m_exp;
  //Rndm::Numbers                              m_uniSample;
  //Rndm::Numbers                              m_uniFile;
  MixHeader                                    m_earliestHeader;
};

#endif

---