|
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().
1.7.3