A++ » INCLUDE » TPSocket

class TPSocket: public TSocket


TPSocket

This class implements parallel client sockets. A parallel socket is
an endpoint for communication between two machines. It is parallel
because several TSockets are open at the same time to the same
destination. This especially speeds up communication over Big Fat
Pipes (i.e. high bandwidth, high latency WAN connections).

Function Members (Methods)

public:
virtual~TPSocket()
voidTObject::AbstractMethod(const char* method) const
virtual voidTObject::AppendPad(Option_t* option = "")
virtual voidTObject::Browse(TBrowser* b)
static TClass*Class()
virtual const char*TObject::ClassName() const
virtual voidTNamed::Clear(Option_t* option = "")
virtual TObject*TNamed::Clone(const char* newname = "") const
virtual voidClose(Option_t* opt = "")
virtual Int_tTNamed::Compare(const TObject* obj) const
virtual voidTNamed::Copy(TObject& named) const
static TSocket*TSocket::CreateAuthSocket(const char* url, Int_t size = 0, Int_t tcpwindowsize = -1, TSocket* s = 0, Int_t* err = 0)
static TSocket*TSocket::CreateAuthSocket(const char* user, const char* host, Int_t port, Int_t size = 0, Int_t tcpwindowsize = -1, TSocket* s = 0, Int_t* err = 0)
virtual voidTObject::Delete(Option_t* option = "")MENU
virtual Int_tTObject::DistancetoPrimitive(Int_t px, Int_t py)
virtual voidTObject::Draw(Option_t* option = "")
virtual voidTObject::DrawClass() constMENU
virtual TObject*TObject::DrawClone(Option_t* option = "") constMENU
virtual voidTObject::Dump() constMENU
virtual voidTObject::Error(const char* method, const char* msgfmt) const
virtual voidTObject::Execute(const char* method, const char* params, Int_t* error = 0)
virtual voidTObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0)
virtual voidTObject::ExecuteEvent(Int_t event, Int_t px, Int_t py)
virtual voidTObject::Fatal(const char* method, const char* msgfmt) const
virtual voidTNamed::FillBuffer(char*& buffer)
virtual TObject*TObject::FindObject(const char* name) const
virtual TObject*TObject::FindObject(const TObject* obj) const
UInt_tTSocket::GetBytesRecv() const
UInt_tTSocket::GetBytesSent() const
static Int_tTSocket::GetClientProtocol()
Int_tTSocket::GetCompressionAlgorithm() const
Int_tTSocket::GetCompressionLevel() const
Int_tTSocket::GetCompressionSettings() const
virtual Int_tGetDescriptor() const
virtual Option_t*TObject::GetDrawOption() const
static Long_tTObject::GetDtorOnly()
Int_tGetErrorCode() const
virtual const char*TObject::GetIconName() const
TInetAddressTSocket::GetInetAddress() const
TTimeStampTSocket::GetLastUsage()
virtual TInetAddressGetLocalInetAddress()
virtual Int_tTSocket::GetLocalPort()
virtual const char*TNamed::GetName() const
virtual char*TObject::GetObjectInfo(Int_t px, Int_t py) const
static Bool_tTObject::GetObjectStat()
virtual Int_tGetOption(ESockOptions opt, Int_t& val)
Int_tTSocket::GetPort() const
Int_tTSocket::GetRemoteProtocol() const
TSecContext*TSocket::GetSecContext() const
const char*TSocket::GetService() const
Int_tTSocket::GetServType() const
Int_tGetSize() const
static ULong64_tTSocket::GetSocketBytesRecv()
static ULong64_tTSocket::GetSocketBytesSent()
Int_tTSocket::GetTcpWindowSize() const
virtual const char*TNamed::GetTitle() const
virtual UInt_tTObject::GetUniqueID() const
const char*TSocket::GetUrl() const
virtual Bool_tTObject::HandleTimer(TTimer* timer)
virtual ULong_tTNamed::Hash() const
virtual voidTObject::Info(const char* method, const char* msgfmt) const
virtual Bool_tTObject::InheritsFrom(const char* classname) const
virtual Bool_tTObject::InheritsFrom(const TClass* cl) const
virtual voidTObject::Inspect() constMENU
voidTObject::InvertBit(UInt_t f)
virtual TClass*IsA() const
virtual Bool_tTSocket::IsAuthenticated() const
virtual Bool_tTObject::IsEqual(const TObject* obj) const
virtual Bool_tTObject::IsFolder() const
Bool_tTObject::IsOnHeap() const
virtual Bool_tTNamed::IsSortable() const
virtual Bool_tIsValid() const
Bool_tTObject::IsZombie() const
virtual voidTNamed::ls(Option_t* option = "") const
voidTObject::MayNotUse(const char* method) const
static voidTSocket::NetError(const char* where, Int_t error)
virtual Bool_tTObject::Notify()
voidTObject::Obsolete(const char* method, const char* asOfVers, const char* removedFromVers) const
voidTObject::operator delete(void* ptr)
voidTObject::operator delete(void* ptr, void* vp)
voidTObject::operator delete[](void* ptr)
voidTObject::operator delete[](void* ptr, void* vp)
void*TObject::operator new(size_t sz)
void*TObject::operator new(size_t sz, void* vp)
void*TObject::operator new[](size_t sz)
void*TObject::operator new[](size_t sz, void* vp)
virtual voidTObject::Paint(Option_t* option = "")
virtual voidTObject::Pop()
virtual voidTNamed::Print(Option_t* option = "") const
virtual Int_tTObject::Read(const char* name)
virtual Int_tTSocket::Reconnect()
virtual voidTObject::RecursiveRemove(TObject* obj)
virtual Int_tRecv(TMessage*& mess)
virtual Int_tRecv(Int_t& status, Int_t& kind)
virtual Int_tRecv(char* mess, Int_t max)
virtual Int_tRecv(char* mess, Int_t max, Int_t& kind)
virtual Int_tRecvRaw(void* buffer, Int_t length, ESendRecvOptions opt)
voidTObject::ResetBit(UInt_t f)
virtual voidTObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU
virtual voidTObject::SavePrimitive(ostream& out, Option_t* option = "")
virtual Int_tTSocket::Select(Int_t interest = kRead, Long_t timeout = -1)
virtual Int_tSend(const TMessage& mess)
virtual Int_tSend(Int_t kind)
virtual Int_tSend(Int_t status, Int_t kind)
virtual Int_tSend(const char* mess, Int_t kind = kMESS_STRING)
virtual Int_tTSocket::SendObject(const TObject* obj, Int_t kind = kMESS_OBJECT)
virtual Int_tSendRaw(const void* buffer, Int_t length, ESendRecvOptions opt)
voidTObject::SetBit(UInt_t f)
voidTObject::SetBit(UInt_t f, Bool_t set)
voidTSocket::SetCompressionAlgorithm(Int_t algorithm = 0)
voidTSocket::SetCompressionLevel(Int_t level = 1)
voidTSocket::SetCompressionSettings(Int_t settings = 1)
virtual voidTObject::SetDrawOption(Option_t* option = "")MENU
static voidTObject::SetDtorOnly(void* obj)
virtual voidTNamed::SetName(const char* name)MENU
virtual voidTNamed::SetNameTitle(const char* name, const char* title)
static voidTObject::SetObjectStat(Bool_t stat)
virtual Int_tSetOption(ESockOptions opt, Int_t val)
voidTSocket::SetRemoteProtocol(Int_t rproto)
voidTSocket::SetSecContext(TSecContext* ctx)
voidTSocket::SetService(const char* service)
voidTSocket::SetServType(Int_t st)
virtual voidTNamed::SetTitle(const char* title = "")MENU
virtual voidTObject::SetUniqueID(UInt_t uid)
voidTSocket::SetUrl(const char* url)
virtual voidShowMembers(TMemberInspector& insp) const
virtual Int_tTNamed::Sizeof() const
virtual voidStreamer(TBuffer&)
voidStreamerNVirtual(TBuffer& ClassDef_StreamerNVirtual_b)
virtual voidTObject::SysError(const char* method, const char* msgfmt) const
Bool_tTObject::TestBit(UInt_t f) const
Int_tTObject::TestBits(UInt_t f) const
voidTSocket::Touch()
TPSocket(TInetAddress address, const char* service, Int_t size, Int_t tcpwindowsize = -1)
TPSocket(TInetAddress address, Int_t port, Int_t size, Int_t tcpwindowsize = -1)
TPSocket(const char* host, const char* service, Int_t size, Int_t tcpwindowsize = -1)
TPSocket(const char* host, Int_t port, Int_t size, Int_t tcpwindowsize = -1)
TPSocket(const char* host, Int_t port, Int_t size, TSocket* sock)
virtual voidTObject::UseCurrentStyle()
virtual voidTObject::Warning(const char* method, const char* msgfmt) const
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0)
virtual Int_tTObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const
protected:
Bool_tTSocket::Authenticate(const char* user)
virtual voidTObject::DoError(int level, const char* location, const char* fmt, va_list va) const
voidTObject::MakeZombie()
Bool_tTSocket::RecvProcessIDs(TMessage* mess)
Bool_tTSocket::RecvStreamerInfos(TMessage* mess)
voidTSocket::SendProcessIDs(const TMessage& mess)
voidTSocket::SendStreamerInfos(const TMessage& mess)
voidTSocket::SetDescriptor(Int_t desc)
private:
virtual Option_t*GetOption() const
voidInit(Int_t tcpwindowsize, TSocket* sock = 0)
voidoperator=(const TPSocket&)
TPSocket(const TPSocket&)
TPSocket(TSocket*[] pSockets, Int_t size)

Data Members

public:
static TObject::(anonymous)TObject::kBitMask
static TSocket::EStatusBitsTSocket::kBrokenConn
static TObject::EStatusBitsTObject::kCanDelete
static TObject::EStatusBitsTObject::kCannotPick
static TObject::EStatusBitsTObject::kHasUUID
static TObject::EStatusBitsTObject::kInvalidObject
static TObject::(anonymous)TObject::kIsOnHeap
static TObject::EStatusBitsTObject::kIsReferenced
static TSocket::EStatusBitsTSocket::kIsUnix
static TObject::EStatusBitsTObject::kMustCleanup
static TObject::EStatusBitsTObject::kNoContextMenu
static TObject::(anonymous)TObject::kNotDeleted
static TObject::EStatusBitsTObject::kObjInCanvas
static TObject::(anonymous)TObject::kOverwrite
static TSocket::EServiceTypeTSocket::kPROOFD
static TSocket::EServiceTypeTSocket::kROOTD
static TSocket::EInterestTSocket::kRead
static TSocket::EServiceTypeTSocket::kSOCKD
static TObject::(anonymous)TObject::kSingleKey
static TSocket::EInterestTSocket::kWrite
static TObject::(anonymous)TObject::kWriteDelete
static TObject::(anonymous)TObject::kZombie
protected:
TInetAddressTSocket::fAddressremote internet address and port #
TBitsTSocket::fBitsInfobits array to mark TStreamerInfo classes already sent
UInt_tTSocket::fBytesRecvtotal bytes received over this socket
UInt_tTSocket::fBytesSenttotal bytes sent using this socket
Int_tTSocket::fCompressCompression level and algorithm
TTimeStampTSocket::fLastUsageTime stamp of last usage
TVirtualMutex*TSocket::fLastUsageMtxProtect last usage setting / reading
TInetAddressTSocket::fLocalAddresslocal internet address and port #
TStringTNamed::fNameobject identifier
Int_tTSocket::fRemoteProtocolprotocol of remote daemon
TSecContext*TSocket::fSecContextafter a successful Authenticate call
TSocket::EServiceTypeTSocket::fServTyperemote service type
TStringTSocket::fServicename of service (matches remote port #)
Int_tTSocket::fSocketsocket descriptor
Int_tTSocket::fTcpWindowSizeTCP window size (default 65535);
TStringTNamed::fTitleobject title
TList*TSocket::fUUIDslist of TProcessIDs already sent through the socket
TStringTSocket::fUrlneeds this for special authentication options
static ULong64_tTSocket::fgBytesRecvtotal bytes received by all socket objects
static ULong64_tTSocket::fgBytesSenttotal bytes sent by all socket objects
static Int_tTSocket::fgClientProtocolclient "protocol" version
private:
Int_t*fReadBytesLeftbytes left to read for specified socket
TMonitor*fReadMonitormonitor read from parallel sockets
char**fReadPtrpointer to read buffer for specified socket
Int_tfSizenumber of parallel sockets
TSocket**fSocketsarray of parallel sockets
Int_t*fWriteBytesLeftbytes left to write for specified socket
TMonitor*fWriteMonitormonitor write on parallel sockets
char**fWritePtrpointer to write buffer for specified socket

Class Charts

Inheritance Chart:
TObject
←
TNamed
←
TSocket
←
TPSocket

Function documentation

TPSocket(TSocket*[] pSockets, Int_t size)
TPSocket(const TPSocket& )
void operator=(const TPSocket& )
void Init(Int_t tcpwindowsize, TSocket* sock = 0)
Option_t * GetOption() const
{ return TObject::GetOption(); }
TPSocket(TInetAddress address, const char* service, Int_t size, Int_t tcpwindowsize = -1)
TPSocket(const char* host, const char* service, Int_t size, Int_t tcpwindowsize = -1)
TPSocket(const char* host, Int_t port, Int_t size, TSocket* sock)
virtual ~TPSocket()
void Close(Option_t* opt = "")
Int_t GetDescriptor() const
TInetAddress GetLocalInetAddress()
Int_t Send(const TMessage& mess)
Int_t Send(Int_t kind)
{ return TSocket::Send(kind); }
Int_t Send(Int_t status, Int_t kind)
{ return TSocket::Send(status, kind); }
Int_t Send(const char* mess, Int_t kind = kMESS_STRING)
{ return TSocket::Send(mess, kind); }
Int_t SendRaw(const void* buffer, Int_t length, ESendRecvOptions opt)
Int_t Recv(TMessage*& mess)
Int_t Recv(Int_t& status, Int_t& kind)
{ return TSocket::Recv(status, kind); }
Int_t Recv(char* mess, Int_t max)
{ return TSocket::Recv(mess, max); }
Int_t Recv(char* mess, Int_t max, Int_t& kind)
{ return TSocket::Recv(mess, max, kind); }
Int_t RecvRaw(void* buffer, Int_t length, ESendRecvOptions opt)
Bool_t IsValid() const
{ return fSockets ? kTRUE : kFALSE; }
Int_t GetErrorCode() const
Int_t SetOption(ESockOptions opt, Int_t val)
Int_t GetOption(ESockOptions opt, Int_t& val)
Int_t GetSize() const
{ return fSize; }