/home/bes3soft/bes3soft/Boss/7.0.2/dist/7.0.2/DistBoss/NetDataReader/NetDataReader-00-00-06/NetDataReader/DimRpcReader.h

Go to the documentation of this file.

#ifndef DIM_RPC_READER_H
#define DIM_RPC_READER_H

#include <pthread.h>
#include <string>
#include <stdint.h>

class AutoEnlargeBuffer;
class DimRpcInfo;

class DimRpcReader
{
   public :

      typedef const std::string ReaderArgType;

      DimRpcReader(ReaderArgType& name);
      virtual ~DimRpcReader();

      const uint32_t*  nextEvent();
      const uint32_t*  currentEvent() const;
      uint32_t         runNo();
      std::string      currentFile();
      uint32_t         stat();


   private :

      DimRpcReader();  //stop default


   private :

      int                 m_inCode;
      int                 m_outCode;
      AutoEnlargeBuffer  *m_buffer;

      DimRpcInfo         *m_rpc;

      static pthread_mutex_t  m_rpcLock;
};

#endif

---