#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 |
Member Enumeration Documentation
Constructor & Destructor Documentation
| XrdClientMessage::XrdClientMessage | ( | ServerResponseHeader | header | ) |
References fStatusCode, kXrdMSC_ok, fHdr, fData, fMarshalled, CreateData(), Error, and fAllocated.
| XrdClientMessage::XrdClientMessage | ( | ) |
References fHdr, fStatusCode, kXrdMSC_ok, fData, fMarshalled, and fAllocated.
| XrdClientMessage::~XrdClientMessage | ( | ) |
References fData.
Member Function Documentation
Referenced by HeaderSID().
| bool XrdClientMessage::CreateData | ( | ) |
References fAllocated, fHdr, ServerResponseHeader::dlen, sysconf(), _SC_PAGESIZE, posix_memalign(), fData, Error, FALSE, and TRUE.
Referenced by XrdClientMessage(), and ReadRaw().
| int XrdClientMessage::DataLen | ( | ) | [inline] |
References fHdr, and ServerResponseHeader::dlen.
Referenced by XrdClient::ProcessUnsolicitedMsg(), XrdClientConn::ClientServerCmd(), XrdClientConn::CheckErrorStatus(), and XrdClientConn::ReadPartialAnswer().
| void * XrdClientMessage::DonateData | ( | ) |
References fData, and fAllocated.
Referenced by XrdClient::ProcessUnsolicitedMsg(), XrdClientConn::ProcessAsynResp(), ReadRaw(), and XrdClientReadCache::SubmitXMessage().
| void* XrdClientMessage::GetData | ( | ) | [inline] |
References fData.
Referenced by XrdClient::ProcessUnsolicitedMsg(), XrdClientAdmin::ProcessUnsolicitedMsg(), ParseRedir(), XrdClientConn::SendGenCommand(), XrdClientConn::CheckErrorStatus(), XrdClientConn::ReadPartialAnswer(), XrdClientConn::ProcessAsynResp(), and XrdClientPhyConnection::HandleUnsolicited().
| 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::SendGenCommand(), XrdClientConn::ReadPartialAnswer(), and XrdClientConn::HandleServerError().
| bool XrdClientMessage::IsMarshalled | ( | ) | [inline] |
References fMarshalled.
| void XrdClientMessage::Marshall | ( | ) |
References fMarshalled, ServerResponseHeader2NetFmt(), fHdr, and TRUE.
| bool XrdClientMessage::MatchStreamid | ( | short | sid | ) | [inline] |
References HeaderSID().
Referenced by XrdClientInputBuffer::MsgForStreamidCnt(), and XrdClientInputBuffer::WipeStreamid().
| int XrdClientMessage::ReadRaw | ( | XrdClientPhyConnection * | phy | ) |
References XrdClientPhyConnection::ReadLock(), Info, XrdClientDebug::kDUMPDEBUG, XrdClientPhyConnection::ReadRaw(), fHdr, XrdClientPhyConnection::PauseSelectOnSubstream(), XrdClientPhyConnection::ReadUnLock(), TXSOCK_ERR_TIMEOUT, SetStatusCode(), kXrdMSC_timeout, XrdClientDebug::kNODEBUG, kXrdMSC_readerr, SetMarshalled(), TRUE, Unmarshall(), HeaderSID(), IsAttn(), CreateData(), fData, DonateData(), and XrdClientPhyConnection::RestartSelectOnSubstream().
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 fMarshalled, clientUnmarshall(), fHdr, and FALSE.
Referenced by XrdClientConn::ReadPartialAnswer(), and ReadRaw().
Member Data Documentation
bool XrdClientMessage::fAllocated [private] |
Referenced by XrdClientMessage(), DonateData(), and CreateData().
void* XrdClientMessage::fData [private] |
Referenced by XrdClientMessage(), ~XrdClientMessage(), DonateData(), CreateData(), ReadRaw(), and GetData().
Referenced by XrdClient::ProcessUnsolicitedMsg(), XrdClientConn::ClientServerCmd(), XrdClientConn::SendGenCommand(), XrdClientConn::ReadPartialAnswer(), XrdClientConn::HandleServerError(), XrdClientMessage(), CreateData(), Marshall(), Unmarshall(), ReadRaw(), DataLen(), HeaderStatus(), HeaderSID(), and SetHeaderStatus().
bool XrdClientMessage::fMarshalled [private] |
Referenced by XrdClientMessage(), Marshall(), Unmarshall(), IsMarshalled(), and SetMarshalled().
short XrdClientMessage::fStatusCode [private] |
Referenced by XrdClientMessage(), GetStatusCode(), IsError(), and SetStatusCode().
The documentation for this class was generated from the following files:
