DataStorePackage.h

#ifndef DATASTOREPACKAGE_H
#define DATASTOREPACKAGE_H
 
#include <framework/datastore/StoreArray.h>
#include <framework/pcore/DataStoreStreamer.h>
 
#include <daq/slc/system/Mutex.h>
#include <rawdata/dataobjects/RawPXD.h>
 
#include "daq/storage/BinData.h"
 
namespace Belle2 {
  class DataStorePackage {
 
  public:
    static const unsigned int MAX_BUFFER_WORDS = 10000000;
 
  private:
    static Mutex g_mutex;
    static bool g_init;
    enum ETObjectBits {
      c_IsTransient = BIT(19),
      c_IsNull = BIT(20)
    };
 
  public:
    DataStorePackage(DataStoreStreamer* streamer, int eb2, unsigned int serial = 0)
      : m_serial(serial)
    {
      m_streamer = streamer;
      m_buf = new int [MAX_BUFFER_WORDS];
      m_data.setBuffer(m_buf);
      m_data_hlt.setBuffer(NULL);
      m_data_pxd.setBuffer(NULL);
      m_eb2 = eb2;
    }
    ~DataStorePackage()
    {
      delete[] m_buf;
    }
 
  public:
    bool restore();
    unsigned int getSerial() const { return m_serial; }
    void setSerial(unsigned int serial) { m_serial = serial; }
    const BinData& getData() const { return m_data; }
    const BinData& getHLTData() const { return  m_data_hlt; }
    const BinData& getPXDData() const { return m_data_pxd; }
 
  private:
    unsigned int m_serial;
    BinData m_data;
    BinData m_data_hlt;
    BinData m_data_pxd;
    int* m_buf;
    int m_eb2;
    //DataStoreStreamer m_streamer;
    DataStoreStreamer* m_streamer;
    StoreArray<RawPXD> m_rawpxdary;
    //StoreArray<SndHdrTemp> m_sndhdrary;
 
  };
 
}
 
#endif