release-05-01-25/doxygen/StorageDeserializer_8h_source.html

//+

// File : StorageDeserializer.h

// Description : Module to receive data from outside and store it to DataStore

//

// Author : Tomoyuki Konno, Tokyo Metropolitan University

// Date : 16 - Oct - 2013

//-


#ifndef STORAGEDESERIALIZER_H

#define STORAGEDESERIALIZER_H


#include <framework/core/Module.h>

#include <framework/datastore/StoreArray.h>


#include <rawdata/dataobjects/RawCOPPER.h>


#include <daq/slc/readout/RunInfoBuffer.h>


#include <daq/storage/SharedEventBuffer.h>

#include "daq/storage/modules/DataStorePackage.h"


#include <string>

#include <vector>


namespace Belle2 {

  class StorageDeserializerModule : public Module {


    /*

    private:

    static StorageDeserializerModule* g_module;


    public:

    static StorageDeserializerModule* get() { return g_module; }

    static DataStorePackage& getPackage() { return *(g_module->m_package); }

    static RunInfoBuffer& getInfo() { return g_module->m_info; }

    static EvtMessage* streamDataStore();

    */


    // Public functions

  public:

    StorageDeserializerModule();

    virtual ~StorageDeserializerModule();


    virtual void initialize();


    virtual void beginRun();

    virtual void event();

    virtual void endRun();

    virtual void terminate();


  private:

    DataStorePackage* m_package;

    std::string m_ibuf_name;

    int m_ibuf_size;

    SharedEventBuffer m_ibuf;

    RunInfoBuffer m_info;

    int m_compressionLevel;

    int m_nodeid;

    std::string m_nodename;

    int m_shmflag;

    unsigned long long m_count;

    unsigned int m_expno;

    unsigned int m_runno;

    unsigned int m_evtno;

    unsigned long long m_datasize;

    MsgHandler* m_handler;

    DataStoreStreamer* m_streamer;

    int m_eb2;

    std::vector<std::string> m_saveObjs;


    StoreArray<RawCOPPER> rawcprarray;

    StoreArray<RawPXD> rawpxdarray;


  };


} // end namespace Belle2


#endif // MODULEHELLO_H