KVProtobufDataReader.h

 
#ifndef __KVProtobufDataReader_H
#define __KVProtobufDataReader_H
 
#include "KVRawDataReader.h"
class KVProtobufDataReader : public KVRawDataReader {
protected:
    Int_t fBufSize;
    char* fBuffer;
    std::unique_ptr<TFile> fFile;
    Long64_t fFileSize;
    UInt_t fEvSize;
    ptrdiff_t fEvOffset;
    bool fNeedToReadBuffer;
    bool fReachedEndOfFile;
 
   virtual bool read_buffer();
 
   UInt_t get_remaining_readable_buffer() const
   {
      return (UInt_t)(fBufSize - fEvOffset);
   }
 
   virtual bool parse_event_from_message() = 0;
 
   void open_file(const Char_t* filepath);
 
public:
   KVProtobufDataReader(Int_t bufSiz = 16 * 1024 * 1024);
   KVProtobufDataReader(const Char_t* filepath, Int_t bufSiz = 16 * 1024 * 1024);
   virtual ~KVProtobufDataReader();
 
   Bool_t GetNextEvent() override;
   TString GetDataFormat() const override
   {
      return "PROTOBUF";
   }
   Int_t GetRunNumberReadFromFile() const override;
 
   ClassDefOverride(KVProtobufDataReader, 1) //Read Google Protobuf DAQ files
};
 
#endif