Logo ROOT  
Reference Guide
TMessage.h
Go to the documentation of this file.
1// @(#)root/net:$Id$
2// Author: Fons Rademakers 19/12/96
3
4/*************************************************************************
5 * Copyright (C) 1995-2000, Rene Brun and Fons Rademakers. *
6 * All rights reserved. *
7 * *
8 * For the licensing terms see $ROOTSYS/LICENSE. *
9 * For the list of contributors see $ROOTSYS/README/CREDITS. *
10 *************************************************************************/
11
12#ifndef ROOT_TMessage
13#define ROOT_TMessage
14
15
16//////////////////////////////////////////////////////////////////////////
17// //
18// TMessage //
19// //
20// Message buffer class used for serializing objects and sending them //
21// over the network. //
22// //
23//////////////////////////////////////////////////////////////////////////
24
25#include "Compression.h"
26#include "TBufferFile.h"
27#include "MessageTypes.h"
28#include "TBits.h"
29
30class TList;
32
33class TMessage : public TBufferFile {
34
35friend class TAuthenticate;
36friend class TSocket;
37friend class TUDPSocket;
38friend class TPSocket;
39friend class TXSocket;
40
41private:
42 TList *fInfos{nullptr}; // List of TStreamerInfo used in WriteObject
43 TBits fBitsPIDs; // Array of bits to mark the TProcessIDs uids written to the message
44 UInt_t fWhat{0}; // Message type
45 TClass *fClass{nullptr}; // If message is kMESS_OBJECT pointer to object's class
46 Int_t fCompress{0}; // Compression level and algorithm
47 char *fBufComp{nullptr}; // Compressed buffer
48 char *fBufCompCur{nullptr}; // Current position in compressed buffer
49 char *fCompPos{nullptr}; // Position of fBufCur when message was compressed
50 Bool_t fEvolution{kFALSE}; // True if support for schema evolution required
51
52 static Bool_t fgEvolution; //True if global support for schema evolution required
53
54 // TMessage objects cannot be copied or assigned
55 TMessage(const TMessage &); // not implemented
56 void operator=(const TMessage &); // not implemented
57
58 // used by friend TSocket
59 Bool_t TestBitNumber(UInt_t bitnumber) const { return fBitsPIDs.TestBitNumber(bitnumber); }
60
61protected:
62 TMessage(void *buf, Int_t bufsize); // only called by T(P)Socket::Recv()
63 void SetLength() const; // only called by T(P)Socket::Send()
64
65public:
67 virtual ~TMessage();
68
69 void ForceWriteInfo(TVirtualStreamerInfo *info, Bool_t force) override;
70 void Forward();
71 TClass *GetClass() const { return fClass;}
72 void TagStreamerInfo(TVirtualStreamerInfo* info) override;
73 void Reset() override;
74 void Reset(UInt_t what) { SetWhat(what); Reset(); }
75 UInt_t What() const { return fWhat; }
76 void SetWhat(UInt_t what);
77
78 void EnableSchemaEvolution(Bool_t enable = kTRUE) { fEvolution = enable; }
80 TList *GetStreamerInfos() const { return fInfos; }
89 char *CompBuffer() const { return fBufComp; }
90 Int_t CompLength() const { return (Int_t)(fBufCompCur - fBufComp); }
91 UShort_t WriteProcessID(TProcessID *pid) override;
92
93 static void EnableSchemaEvolutionForAll(Bool_t enable = kTRUE);
95
96 ClassDefOverride(TMessage,0) // Message buffer class
97};
98
99//______________________________________________________________________________
101{
102 return (fCompress < 0) ? -1 : fCompress / 100;
103}
104
105//______________________________________________________________________________
107{
108 return (fCompress < 0) ? -1 : fCompress % 100;
109}
110
111//______________________________________________________________________________
113{
114 return (fCompress < 0) ? -1 : fCompress;
115}
116
117#endif
@ kMESS_ANY
Definition: MessageTypes.h:31
unsigned short UShort_t
Definition: RtypesCore.h:36
int Int_t
Definition: RtypesCore.h:41
unsigned int UInt_t
Definition: RtypesCore.h:42
const Bool_t kFALSE
Definition: RtypesCore.h:88
bool Bool_t
Definition: RtypesCore.h:59
const Bool_t kTRUE
Definition: RtypesCore.h:87
#define ClassDefOverride(name, id)
Definition: Rtypes.h:330
Container of bits.
Definition: TBits.h:27
Bool_t TestBitNumber(UInt_t bitnumber) const
Definition: TBits.h:222
The concrete implementation of TBuffer for writing/reading to/from a ROOT file or socket.
Definition: TBufferFile.h:46
@ kInitialSize
Definition: TBuffer.h:77
TClass instances represent classes, structs and namespaces in the ROOT type system.
Definition: TClass.h:75
A doubly linked list.
Definition: TList.h:44
static void EnableSchemaEvolutionForAll(Bool_t enable=kTRUE)
Static function enabling or disabling the automatic schema evolution.
Definition: TMessage.cxx:116
void Reset(UInt_t what)
Definition: TMessage.h:74
void operator=(const TMessage &)
Bool_t UsesSchemaEvolution() const
Definition: TMessage.h:79
UInt_t fWhat
Definition: TMessage.h:44
void ForceWriteInfo(TVirtualStreamerInfo *info, Bool_t force) override
Force writing the TStreamerInfo to the message.
Definition: TMessage.cxx:132
UInt_t What() const
Definition: TMessage.h:75
char * fCompPos
Definition: TMessage.h:49
void Forward()
Change a buffer that was received into one that can be send, i.e.
Definition: TMessage.cxx:144
void SetLength() const
Set the message length at the beginning of the message buffer.
Definition: TMessage.cxx:202
Int_t GetCompressionAlgorithm() const
Definition: TMessage.h:100
TClass * fClass
Definition: TMessage.h:45
Bool_t TestBitNumber(UInt_t bitnumber) const
Definition: TMessage.h:59
char * CompBuffer() const
Definition: TMessage.h:89
void Reset() override
Reset the message buffer so we can use (i.e. fill) it again.
Definition: TMessage.cxx:179
char * fBufComp
Definition: TMessage.h:47
char * fBufCompCur
Definition: TMessage.h:48
Bool_t fEvolution
Definition: TMessage.h:50
void SetCompressionSettings(Int_t settings=ROOT::RCompressionSetting::EDefaults::kUseCompiledDefault)
Set compression settings.
Definition: TMessage.cxx:288
TList * GetStreamerInfos() const
Definition: TMessage.h:80
UShort_t WriteProcessID(TProcessID *pid) override
Check if the ProcessID pid is already in the message.
Definition: TMessage.cxx:440
Int_t Compress()
Compress the message.
Definition: TMessage.cxx:306
virtual ~TMessage()
Destructor.
Definition: TMessage.cxx:106
Int_t fCompress
Definition: TMessage.h:46
static Bool_t UsesSchemaEvolutionForAll()
Static function returning status of global schema evolution.
Definition: TMessage.cxx:124
TMessage(const TMessage &)
Int_t GetCompressionSettings() const
Definition: TMessage.h:112
void TagStreamerInfo(TVirtualStreamerInfo *info) override
Remember that the StreamerInfo is being used in writing.
Definition: TMessage.cxx:168
void SetCompressionLevel(Int_t level=ROOT::RCompressionSetting::ELevel::kUseMin)
Set compression level.
Definition: TMessage.cxx:264
Int_t Uncompress()
Uncompress the message.
Definition: TMessage.cxx:391
Int_t GetCompressionLevel() const
Definition: TMessage.h:106
TBits fBitsPIDs
Definition: TMessage.h:43
TList * fInfos
Definition: TMessage.h:42
Int_t CompLength() const
Definition: TMessage.h:90
static Bool_t fgEvolution
Definition: TMessage.h:52
void SetWhat(UInt_t what)
Using this method one can change the message type a-posteriori In case you OR "what" with kMESS_ACK,...
Definition: TMessage.cxx:222
void SetCompressionAlgorithm(Int_t algorithm=ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)
Set compression algorithm.
Definition: TMessage.cxx:242
TClass * GetClass() const
Definition: TMessage.h:71
void EnableSchemaEvolution(Bool_t enable=kTRUE)
Definition: TMessage.h:78
A TProcessID identifies a ROOT job in a unique way in time and space.
Definition: TProcessID.h:69
Abstract Interface class describing Streamer information for one class.
High level handler of connections to XProofD.
Definition: TXSocket.h:59
@ kUseGlobal
Use the global compression algorithm.
Definition: Compression.h:83
@ kUseCompiledDefault
Use the compile-time default setting.
Definition: Compression.h:50