xrootd
|
#include <XrdClientMessage.hh>
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 |
XrdClientMessage::XrdClientMessage | ( | ServerResponseHeader | header | ) |
References CreateData(), Error, fAllocated, fData, fHdr, fMarshalled, fStatusCode, and kXrdMSC_ok.
XrdClientMessage::XrdClientMessage | ( | ) |
References fAllocated, fData, fHdr, fMarshalled, fStatusCode, and kXrdMSC_ok.
XrdClientMessage::~XrdClientMessage | ( | ) |
References fData.
Referenced by HeaderSID().
bool XrdClientMessage::CreateData | ( | ) |
References _SC_PAGESIZE, ServerResponseHeader::dlen, Error, fAllocated, FALSE, fData, fHdr, posix_memalign(), sysconf(), 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::HandleUnsolicited(), ParseRedir(), XrdClientConn::ProcessAsynResp(), XrdClientAdmin::ProcessUnsolicitedMsg(), XrdClient::ProcessUnsolicitedMsg(), XrdClientConn::ReadPartialAnswer(), and XrdClientConn::SendGenCommand().
int XrdClientMessage::GetStatusCode | ( | ) | [inline] |
kXR_unt16 XrdClientMessage::HeaderSID | ( | ) | [inline] |
int XrdClientMessage::HeaderStatus | ( | ) | [inline] |
void XrdClientMessage::Int2CharStreamid | ( | kXR_char * | charstreamid, |
short | intstreamid | ||
) | [static] |
bool XrdClientMessage::IsAttn | ( | ) | [inline] |
bool XrdClientMessage::IsError | ( | ) | [inline] |
References fStatusCode, and kXrdMSC_ok.
Referenced by 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(), 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().
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().
bool XrdClientMessage::fAllocated [private] |
Referenced by CreateData(), DonateData(), and XrdClientMessage().
void* XrdClientMessage::fData [private] |
Referenced by CreateData(), DonateData(), GetData(), ReadRaw(), XrdClientMessage(), and ~XrdClientMessage().
Referenced by XrdClientConn::ClientServerCmd(), CreateData(), DataLen(), 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().
short XrdClientMessage::fStatusCode [private] |
Referenced by GetStatusCode(), IsError(), SetStatusCode(), and XrdClientMessage().