 |
Belle II Software
release-05-02-19
|
12 #include <RtypesCore.h>
26 enum ERecordType { MSG_EVENT, MSG_BEGIN_RUN, MSG_END_RUN, MSG_TERMINATE, MSG_NORECORD, MSG_STREAMERINFO };
36 UInt_t
src{(UInt_t) - 1};
124 struct timeval
time() const;
int paddedSize() const
Same as size(), but as size of an integer array.
EvtMessage & operator=(const EvtMessage &obj)
Assignment (m_data is copied).
bool m_ownsBuffer
Wether to clean up m_data in destructor.
ERecordType type() const
Get record type.
const static unsigned int c_MaxEventSize
maximal EvtMessage size, in bytes (200MB).
struct timeval time() const
Get time stamp.
char * m_data
Pointer to the internal EvtMessage buffer.
unsigned int getMsgFlags() const
Get flags of the message.
void setMsgFlags(unsigned int flags)
Set flags for the message.
Class to manage streamed object.
int dest() const
Get destination IP of message.
bool hasMsgFlags(unsigned int flags) const
Check if the message has the given flags.
char * msg()
Get pointer to message body.
int size() const
Get size of message including headers.
unsigned int getVersion() const
get version of the header.
Abstract base class for different kinds of events.
int src() const
Get source IP of message.
ERecordType
What type of message is this?
EMessageFlags
Flags for the message.
EvtHeader * header()
Get pointer to EvtHeader.
const EvtHeader * getHeader() const
Get pointer to EvtHeader.
@ c_MsgCompressed
indicates that the message body is compressed and should be uncompressed using ROOT R__unzip_header a...
void setMsg(const char *msg, int size, ERecordType type)
Copy message into newly allocated buffer.
void setTime(const struct timeval &time)
Set time stamp.
char * buffer()
Get buffer address.
void addMsgFlags(unsigned int flags)
Add flags to the message.
int msg_size() const
Get size of message body.
EvtMessage(char *buf=nullptr)
build EvtMessage from existing buffer (no copy, but does not take ownership).