xrootd
Public Types | Public Member Functions | Static Public Member Functions | Public Attributes | Private Attributes | List of all members
XrdClientMessage Class Reference

#include <XrdClientMessage.hh>

Collaboration diagram for XrdClientMessage:
Collaboration graph
[legend]

Public Types

enum  EXrdMSCStatus { kXrdMSC_ok = 0, kXrdMSC_readerr = 1, kXrdMSC_writeerr = 2, kXrdMSC_timeout = 3 }

Public Member Functions

 XrdClientMessage (ServerResponseHeader header)
 XrdClientMessage ()
 ~XrdClientMessage ()
bool CreateData ()
int DataLen ()
void * DonateData ()
void * GetData ()
int GetStatusCode ()
int HeaderStatus ()
kXR_unt16 HeaderSID ()
bool IsAttn ()
bool IsError ()
bool IsMarshalled ()
void Marshall ()
bool MatchStreamid (short sid)
int ReadRaw (XrdClientPhyConnection *phy)
void SetHeaderStatus (kXR_unt16 sts)
void SetMarshalled (bool m)
void SetStatusCode (kXR_unt16 status)
void Unmarshall ()

Static Public Member Functions

static kXR_unt16 CharStreamid2Int (kXR_char *charstreamid)
static void Int2CharStreamid (kXR_char *charstreamid, short intstreamid)

Public Attributes

ServerResponseHeader fHdr

Private Attributes

bool fAllocated
void * fData
bool fMarshalled
short fStatusCode
XrdSysRecMutex fMultireadMutex

Member Enumeration Documentation

enum XrdClientMessage::EXrdMSCStatus
Enumerator:
kXrdMSC_ok 
kXrdMSC_readerr 
kXrdMSC_writeerr 
kXrdMSC_timeout 

Constructor & Destructor Documentation

XrdClientMessage::XrdClientMessage ( ServerResponseHeader  header)

References CreateData(), ServerResponseHeader::dlen, Error, fAllocated, fData, fHdr, fMarshalled, fStatusCode, and kXrdMSC_ok.

XrdClientMessage::XrdClientMessage ( )

References fAllocated, fData, fHdr, fMarshalled, fStatusCode, and kXrdMSC_ok.

XrdClientMessage::~XrdClientMessage ( )

References fData.

Member Function Documentation

kXR_unt16 XrdClientMessage::CharStreamid2Int ( kXR_char *  charstreamid)
static

Referenced by HeaderSID().

bool XrdClientMessage::CreateData ( )

References ServerResponseHeader::dlen, Error, fAllocated, FALSE, fData, fHdr, and TRUE.

Referenced by ReadRaw(), and XrdClientMessage().

int XrdClientMessage::DataLen ( )
inline

References ServerResponseHeader::dlen, and fHdr.

Referenced by XrdClientConn::CheckErrorStatus(), XrdClientConn::ClientServerCmd(), XrdClient::ProcessUnsolicitedMsg(), and XrdClientConn::ReadPartialAnswer().

void * XrdClientMessage::DonateData ( )

References fAllocated, and fData.

Referenced by XrdClientConn::ProcessAsynResp(), XrdClient::ProcessUnsolicitedMsg(), ReadRaw(), and XrdClientReadCache::SubmitXMessage().

void* XrdClientMessage::GetData ( )
inline

References fData.

Referenced by XrdClientConn::CheckErrorStatus(), XrdClientPhyConnection::DoHandShake(), XrdClientPhyConnection::HandleUnsolicited(), ParseRedir(), XrdClientConn::ProcessAsynResp(), XrdClientAdmin::ProcessUnsolicitedMsg(), XrdClient::ProcessUnsolicitedMsg(), XrdClientConn::ReadPartialAnswer(), and XrdClientConn::SendGenCommand().

int XrdClientMessage::GetStatusCode ( )
inline

References fStatusCode.

Referenced by XrdClientPhyConnection::BuildMessage(), XrdClientConn::ProcessAsynResp(), XrdClientAdmin::ProcessUnsolicitedMsg(), and XrdClient::ProcessUnsolicitedMsg().

kXR_unt16 XrdClientMessage::HeaderSID ( )
inline

References CharStreamid2Int(), fHdr, and ServerResponseHeader::streamid.

Referenced by XrdClientPhyConnection::BuildMessage(), MatchStreamid(), XrdClientAdmin::ProcessUnsolicitedMsg(), XrdClient::ProcessUnsolicitedMsg(), XrdClientInputBuffer::PutMsg(), and ReadRaw().

int XrdClientMessage::HeaderStatus ( )
inline

References fHdr, and ServerResponseHeader::status.

Referenced by XrdClientPhyConnection::BuildMessage(), XrdClientConn::CheckErrorStatus(), XrdClientConn::ClientServerCmd(), XrdClientPhyConnection::DoHandShake(), IsAttn(), XrdClient::ProcessUnsolicitedMsg(), XrdClientConn::ReadPartialAnswer(), and XrdClientConn::SubmitDataToCache().

void XrdClientMessage::Int2CharStreamid ( kXR_char *  charstreamid,
short  intstreamid 
)
static
bool XrdClientMessage::IsAttn ( )
inline

References HeaderStatus(), and kXR_attn.

Referenced by XrdClientPhyConnection::BuildMessage(), XrdClientPhyConnection::HandleUnsolicited(), XrdClientAdmin::ProcessUnsolicitedMsg(), XrdClient::ProcessUnsolicitedMsg(), and ReadRaw().

bool XrdClientMessage::IsError ( )
inline

References fStatusCode, and kXrdMSC_ok.

Referenced by XrdClientPhyConnection::DoHandShake(), XrdClientConn::HandleServerError(), XrdClientConn::ReadPartialAnswer(), and XrdClientConn::SendGenCommand().

bool XrdClientMessage::IsMarshalled ( )
inline

References fMarshalled.

void XrdClientMessage::Marshall ( )

References fHdr, fMarshalled, ServerResponseHeader2NetFmt(), and TRUE.

bool XrdClientMessage::MatchStreamid ( short  sid)
inline

References HeaderSID().

Referenced by XrdClientInputBuffer::MsgForStreamidCnt(), and XrdClientInputBuffer::WipeStreamid().

int XrdClientMessage::ReadRaw ( XrdClientPhyConnection *  phy)

References CreateData(), ServerResponseHeader::dlen, DonateData(), fData, fHdr, HeaderSID(), Info, IsAttn(), XrdClientDebug::kDUMPDEBUG, XrdClientDebug::kNODEBUG, kXrdMSC_readerr, kXrdMSC_timeout, XrdClientPhyConnection::PauseSelectOnSubstream(), XrdClientPhyConnection::ReadLock(), XrdClientPhyConnection::ReadRaw(), XrdClientPhyConnection::ReadUnLock(), XrdClientPhyConnection::RestartSelectOnSubstream(), SetMarshalled(), SetStatusCode(), TRUE, TXSOCK_ERR_TIMEOUT, and Unmarshall().

Referenced by XrdClientPhyConnection::BuildMessage(), and XrdClientPhyConnection::DoHandShake().

void XrdClientMessage::SetHeaderStatus ( kXR_unt16  sts)
inline

References fHdr, and ServerResponseHeader::status.

void XrdClientMessage::SetMarshalled ( bool  m)
inline

References fMarshalled.

Referenced by ReadRaw().

void XrdClientMessage::SetStatusCode ( kXR_unt16  status)
inline

References fStatusCode.

Referenced by ReadRaw().

void XrdClientMessage::Unmarshall ( )

References clientUnmarshall(), FALSE, fHdr, and fMarshalled.

Referenced by XrdClientConn::ReadPartialAnswer(), and ReadRaw().

Member Data Documentation

bool XrdClientMessage::fAllocated
private

Referenced by CreateData(), DonateData(), and XrdClientMessage().

void* XrdClientMessage::fData
private

Referenced by CreateData(), DonateData(), GetData(), ReadRaw(), XrdClientMessage(), and ~XrdClientMessage().

ServerResponseHeader XrdClientMessage::fHdr

Referenced by XrdClientConn::ClientServerCmd(), CreateData(), DataLen(), XrdClientPhyConnection::DoHandShake(), XrdClientConn::HandleServerError(), HeaderSID(), HeaderStatus(), Marshall(), XrdClient::ProcessUnsolicitedMsg(), XrdClientConn::ReadPartialAnswer(), ReadRaw(), XrdClientConn::SendGenCommand(), SetHeaderStatus(), Unmarshall(), and XrdClientMessage().

bool XrdClientMessage::fMarshalled
private

Referenced by IsMarshalled(), Marshall(), SetMarshalled(), Unmarshall(), and XrdClientMessage().

XrdSysRecMutex XrdClientMessage::fMultireadMutex
private
short XrdClientMessage::fStatusCode
private

Referenced by GetStatusCode(), IsError(), SetStatusCode(), and XrdClientMessage().

The documentation for this class was generated from the following files:
Generated by   doxygen 1.8.1.2