d7/dbd/ophBuffer_8h_source.html

#ifndef __OPHBUFFER_H

#define __OPHBUFFER_H


#include "event_io.h"


#include "phenixTypes.h"

#include "oBuffer.h"

#include "oEvent.h"

#include "Event.h"


class  ophBuffer : public oBuffer {


public:


  //** Constructors


  //  ophBuffer( FILE *fpp, PHDWORD * , const int length

  //   , const int iseq = 1, const int irun=1);


  ophBuffer() {};


  ophBuffer (int fd, PHDWORD * where, const int length,

    const int irun=1 , const int iseq=0 );


  ophBuffer (const char *filename, PHDWORD * where, const int length,

     int &status,

     const int irun=1 , const int iseq=0 );


  ~ophBuffer();


  //  this creates a new event on the next address

  int nextEvent( const unsigned int evtsize, const int etype =0, const int evtseq =0);


  // frame and packet adding


  int addRawEvent(unsigned int *);


  int addEvent(Event *);


  int addFrame(PHDWORD *);


  int  addPacket( const Packet *p);


  int addUnstructPacketData(PHDWORD * data,

        const int length,

        const int id,

        const int wordsize,

        const int hitformat);


  int writeout ();


  // now the re-sizing of buffer

  int setMaxSize( const int size);


  // and the query

  int getMaxSize() const;


  // and the query`

  unsigned long long getBytesWritten() const;


  int addEoB();


protected:


  int prepare_next();


  buffer_ptr bptr;

  buffer_ptr bptr_being_written;


  buffer_ptr bptr0;

  buffer_ptr bptr1;

  PHDWORD *data_ptr;

  int current_index;

  int max_length;

  int max_size;

  unsigned int left;

  int sequence;

  int runnumber;

  unsigned long long byteswritten;

  oEvent *current_event;

  int eventsequence;

  int current_etype;

  int has_end;

  int dirty;

  int fd;

  int our_fd;

  int good_object;


};


#endif