Handle/Process/Forward XRootD messages. More...

#include <XrdClXRootDMsgHandler.hh>

Inheritance diagram for XrdCl::XRootDMsgHandler:

Collaboration diagram for XrdCl::XRootDMsgHandler:

Classes
struct	ChunkStatus

Public Member Functions
	XRootDMsgHandler (Message msg, ResponseHandler respHandler, const URL url, SIDManager sidMgr)

	~XRootDMsgHandler ()
	Destructor. More...

virtual uint16_t	Examine (Message *msg)

virtual void	Process (Message *msg)
	Process the message if it was "taken" by the examine action. More...

virtual Status	ReadMessageBody (Message *msg, int socket, uint32_t &bytesRead)

virtual uint8_t	OnStreamEvent (StreamEvent event, uint16_t streamNum, Status status)

virtual void	OnStatusReady (const Message *message, Status status)
	The requested action has been performed and the status is available. More...

virtual bool	IsRaw () const
	Are we a raw writer or not? More...

virtual Status	WriteMessageBody (int socket, uint32_t &bytesRead)

void	WaitDone (time_t now)

void	SetExpiration (time_t expiration)
	Set a timestamp after which we give up. More...

void	SetRedirectAsAnswer (bool redirectAsAnswer)

const Message *	GetRequest () const
	Get the request pointer. More...

void	SetLoadBalancer (const HostInfo &loadBalancer)
	Set the load balancer. More...

void	SetHostList (HostList *hostList)
	Set host list. More...

void	SetChunkList (ChunkList *chunkList)
	Set the chunk list. More...

void	SetRedirectCounter (uint16_t redirectCounter)
	Set the redirect counter. More...

Public Member Functions inherited from XrdCl::IncomingMsgHandler
virtual	~IncomingMsgHandler ()
	Event types that the message handler may receive. More...

Public Member Functions inherited from XrdCl::OutgoingMsgHandler
virtual	~OutgoingMsgHandler ()

virtual void	OnReadyToSend (Message *msg, uint16_t streamNum)

Private Member Functions
Status	ReadRawRead (Message *msg, int socket, uint32_t &bytesRead)
	Handle a kXR_read in raw mode. More...

Status	ReadRawReadV (Message *msg, int socket, uint32_t &bytesRead)
	Handle a kXR_readv in raw mode. More...

Status	ReadRawOther (Message *msg, int socket, uint32_t &bytesRead)
	Handle anything other than kXR_read and kXR_readv in raw mode. More...

Status	ReadAsync (int socket, uint32_t &btesRead)

void	HandleError (Status status, Message *msg=0)
	Recover error. More...

Status	RetryAtServer (const URL &url)
	Retry the request at another server. More...

void	HandleResponse ()
	Unpack the message and call the response handler. More...

XRootDStatus *	ProcessStatus ()
	Extract the status information from the stuff that we got. More...

Status	ParseResponse (AnyObject *&response)

Status	RewriteRequestRedirect (const URL::ParamsMap &newCgi)

Status	RewriteRequestWait ()
	Some requests need to be rewritten also after getting kXR_wait - sigh. More...

Status	PostProcessReadV (VectorReadInfo *vReadInfo)
	Post process vector read. More...

Status	UnPackReadVResponse (Message *msg)
	Unpack a single readv response. More...

void	UpdateTriedCGI ()
	Update the "tried=" part of the CGI of the current message. More...

void	SwitchOnRefreshFlag ()
	Switch on the refresh flag for some requests. More...

Private Attributes
Message *	pRequest

Message *	pResponse

std::vector< Message * >	pPartialResps

ResponseHandler *	pResponseHandler

URL	pUrl

PostMaster *	pPostMaster

SIDManager *	pSidMgr

Status	pStatus

time_t	pExpiration

bool	pRedirectAsAnswer

HostList *	pHosts

bool	pHasLoadBalancer

HostInfo	pLoadBalancer

bool	pHasSessionId

std::string	pRedirectCgi

ChunkList *	pChunkList

std::vector< ChunkStatus >	pChunkStatus

uint16_t	pRedirectCounter

uint32_t	pAsyncOffset

uint32_t	pAsyncReadSize

char *	pAsyncReadBuffer

uint32_t	pAsyncMsgSize

bool	pReadRawStarted

uint32_t	pReadRawCurrentOffset

uint32_t	pReadVRawMsgOffset

bool	pReadVRawChunkHeaderDone

bool	pReadVRawChunkHeaderStarted

bool	pReadVRawSizeError

int32_t	pReadVRawChunkIndex

readahead_list	pReadVRawChunkHeader

bool	pReadVRawMsgDiscard

bool	pOtherRawStarted

Additional Inherited Members
Public Types inherited from XrdCl::IncomingMsgHandler
enum	Action { Take = 0x0001, Ignore = 0x0002, RemoveHandler = 0x0004, Raw = 0x0008, NoProcess = 0x0010 }
	Actions to be taken after a message is processed by the handler. More...

enum	StreamEvent { Ready = 1, Broken = 2, Timeout = 3, FatalError = 4 }
	Events that may have occurred to the stream. More...

Detailed Description

Handle/Process/Forward XRootD messages.

Constructor & Destructor Documentation

XrdCl::XRootDMsgHandler::XRootDMsgHandler	(	Message *	msg,
		ResponseHandler *	respHandler,
		const URL *	url,
		SIDManager *	sidMgr
	)

inline

Constructor

Parameters

msg	message that has been sent out
respHandler	response handler to be called then the final final response arrives
url	the url the message has been sent to
sidMgr	the sid manager used to allocate SID for the initial message

References XrdCl::DefaultEnv::GetPostMaster(), XrdCl::Message::GetSessionId(), pHasSessionId, pPostMaster, and pReadVRawChunkHeader.

XrdCl::XRootDMsgHandler::~XRootDMsgHandler ( )

inline

Destructor.

References pHasSessionId, pPartialResps, pRequest, and pResponse.

Member Function Documentation

uint16_t XrdCl::XRootDMsgHandler::Examine ( Message * msg )

virtual

Examine an incoming message, and decide on the action to be taken

Parameters

msg	the message, may be zero if receive failed

Returns: action type that needs to be take wrt the message and the handler

Implements XrdCl::IncomingMsgHandler.

References ServerResponseBody_Attn::actnum, ServerResponse::attn, ServerResponse::body, ServerResponseHeader::dlen, XrdCl::Log::Dump(), XrdCl::Buffer::GetBuffer(), XrdCl::Message::GetDescription(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), XrdCl::Buffer::GetSize(), ServerResponse::hdr, ClientRequest::header, XrdCl::IncomingMsgHandler::Ignore, kXR_asynresp, kXR_attn, kXR_error, kXR_ok, kXR_oksofar, kXR_read, kXR_readv, kXR_redirect, kXR_wait, kXR_waitresp, XrdCl::IncomingMsgHandler::NoProcess, pAsyncMsgSize, pPartialResps, pReadRawCurrentOffset, pReadRawStarted, pReadVRawMsgOffset, pRequest, pResponse, pUrl, XrdCl::IncomingMsgHandler::Raw, XrdCl::IncomingMsgHandler::RemoveHandler, ClientRequestHdr::requestid, ServerResponseHeader::status, ClientRequestHdr::streamid, ServerResponseHeader::streamid, XrdCl::IncomingMsgHandler::Take, and XrdCl::XRootDMsg.

const Message* XrdCl::XRootDMsgHandler::GetRequest ( ) const

inline

Get the request pointer.

References pRequest.

void XrdCl::XRootDMsgHandler::HandleError	(	Status	status,
		Message *	msg = `0`
	)

private

void XrdCl::XRootDMsgHandler::HandleResponse ( )

private

Unpack the message and call the response handler.

References XrdCl::Status::code, XrdCl::errOperationExpired, XrdCl::Buffer::GetBuffer(), XrdCl::ResponseHandler::HandleResponseWithHosts(), ClientRequest::header, XrdCl::Status::IsOK(), ParseResponse(), pHosts, pRequest, pResponseHandler, ProcessStatus(), pSidMgr, XrdCl::SIDManager::ReleaseSID(), ClientRequestHdr::streamid, XrdCl::SIDManager::TimeOutSID(), and XrdCl::XRootDTransport::UnMarshallRequest().

Referenced by HandleError(), and Process().

bool XrdCl::XRootDMsgHandler::IsRaw ( ) const

virtual

Are we a raw writer or not?

Reimplemented from XrdCl::OutgoingMsgHandler.

References XrdCl::Buffer::GetBuffer(), ClientRequest::header, kXR_write, pRequest, and ClientRequestHdr::requestid.

void XrdCl::XRootDMsgHandler::OnStatusReady	(	const Message *	message,
		Status	status
	)

virtual

The requested action has been performed and the status is available.

Implements XrdCl::OutgoingMsgHandler.

References XrdCl::Log::Dump(), XrdCl::Log::Error(), XrdCl::Message::GetDescription(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), HandleError(), XrdCl::Status::IsOK(), pExpiration, pPostMaster, pUrl, XrdCl::PostMaster::Receive(), and XrdCl::XRootDMsg.

uint8_t XrdCl::XRootDMsgHandler::OnStreamEvent	(	StreamEvent	event,
		uint16_t	streamNum,
		Status	status
	)

virtual

Handle an event other that a message arrival

Parameters

event	type of the event
streamNum	stream concerned
status	status info

Reimplemented from XrdCl::IncomingMsgHandler.

References XrdCl::Log::Dump(), XrdCl::Message::GetDescription(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), HandleError(), pRequest, pUrl, XrdCl::IncomingMsgHandler::Ready, XrdCl::IncomingMsgHandler::RemoveHandler, and XrdCl::XRootDMsg.

Status XrdCl::XRootDMsgHandler::ParseResponse ( AnyObject *& response )

private

Parse the response and put it in an object that could be passed to the user

References XrdCl::Buffer::Allocate(), XrdCl::Buffer::Append(), ServerResponse::body, ServerResponse::buffer, XrdCl::ChunkInfo::buffer, ServerResponseBody_Buffer::data, ClientRequest::dirlist, ClientDirlistRequest::dlen, ServerResponseHeader::dlen, XrdCl::Log::Dump(), XrdCl::errInvalidMessage, XrdCl::errInvalidResponse, XrdCl::Log::Error(), ServerResponseBody_Protocol::flags, XrdCl::Buffer::GetBuffer(), XrdCl::Message::GetDescription(), XrdCl::URL::GetHostId(), XrdCl::URL::GetHostName(), XrdCl::DefaultEnv::GetLog(), XrdCl::URL::GetPort(), XrdCl::Message::GetSessionId(), XrdCl::Buffer::GetSize(), ServerResponse::hdr, ClientRequest::header, XrdCl::Status::IsOK(), kXR_chmod, kXR_close, kXR_dirlist, kXR_locate, kXR_mkdir, kXR_mv, kXR_ok, kXR_open, kXR_ping, kXR_prepare, kXR_protocol, kXR_query, kXR_read, kXR_readv, kXR_redirect, kXR_retstat, kXR_rm, kXR_rmdir, kXR_set, kXR_stat, kXR_sync, kXR_truncate, kXR_vfs, kXR_write, XrdCl::ChunkInfo::length, XrdCl::ChunkInfo::offset, ClientRequest::open, ClientOpenRequest::options, ClientStatRequest::options, pChunkList, pChunkStatus, PostProcessReadV(), pPartialResps, pRedirectAsAnswer, pRedirectCgi, pRequest, pResponse, ServerResponse::protocol, pUrl, ServerResponseBody_Protocol::pval, ClientRequestHdr::requestid, XrdCl::AnyObject::Set(), ClientRequest::stat, ServerResponseHeader::status, XrdCl::stError, and XrdCl::XRootDMsg.

Referenced by HandleResponse().

Status XrdCl::XRootDMsgHandler::PostProcessReadV ( VectorReadInfo * vReadInfo )

private

Post process vector read.

References XrdCl::errInvalidResponse, XrdCl::VectorReadInfo::GetChunks(), XrdCl::Buffer::GetSize(), pChunkList, pChunkStatus, pPartialResps, pResponse, XrdCl::VectorReadInfo::SetSize(), XrdCl::stFatal, and UnPackReadVResponse().

Referenced by ParseResponse().

void XrdCl::XRootDMsgHandler::Process ( Message * msg )

virtual

Process the message if it was "taken" by the examine action.

Process the message if it was "taken" by the examine action

Parameters

msg	the message to be processed

Reimplemented from XrdCl::IncomingMsgHandler.

References XrdCl::Buffer::Append(), ServerResponse::body, ServerResponseHeader::dlen, XrdCl::Log::Dump(), XrdCl::errErrorResponse, XrdCl::errInvalidRedirectURL, XrdCl::errInvalidResponse, ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, XrdCl::Log::Error(), ServerResponse::error, XrdCl::errRedirectLimit, XrdCl::AnyObject::Get(), XrdCl::Buffer::GetBuffer(), XrdCl::Message::GetDescription(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), XrdCl::URL::GetParams(), XrdCl::PostMaster::GetTaskManager(), HandleError(), HandleResponse(), ServerResponse::hdr, ClientRequest::header, ServerResponseBody_Redirect::host, ServerResponseBody_Wait::infomsg, XrdCl::Status::IsOK(), XrdCl::URL::IsValid(), kXR_attn, kXR_attrMeta, kXR_error, kXR_isManager, kXR_ok, kXR_redirect, kXR_wait, kXR_waitresp, pHasLoadBalancer, pHosts, pLoadBalancer, ServerResponseBody_Redirect::port, pPostMaster, pRedirectAsAnswer, pRedirectCgi, pRedirectCounter, pRequest, pResponse, XrdCl::XRootDQuery::ProtocolVersion, pStatus, pUrl, XrdCl::PostMaster::QueryTransport(), ServerResponse::redirect, XrdCl::TaskManager::RegisterTask(), ClientRequestHdr::requestid, RetryAtServer(), RewriteRequestRedirect(), RewriteRequestWait(), ServerResponseBody_Wait::seconds, ServerResponseBody_Waitresp::seconds, XrdCl::XRootDQuery::ServerFlags, XrdCl::Utils::splitString(), ServerResponseHeader::status, XrdCl::stError, XrdCl::stFatal, XrdCl::stOK, XrdCl::suXRDRedirect, XrdCl::XRootDTransport::UnMarshallBody(), XrdCl::XRootDTransport::UnMarshallHeader(), XrdCl::HostInfo::url, ServerResponse::wait, ServerResponse::waitresp, and XrdCl::XRootDMsg.

XRootDStatus * XrdCl::XRootDMsgHandler::ProcessStatus ( )

private

Extract the status information from the stuff that we got.

References ServerResponse::body, XrdCl::Status::code, XrdCl::errErrorResponse, ServerResponseBody_Error::errmsg, XrdCl::Status::errNo, ServerResponseBody_Error::errnum, ServerResponse::error, XrdCl::Buffer::GetBuffer(), XrdCl::Status::IsOK(), pResponse, pStatus, and XrdCl::XRootDStatus::SetErrorMessage().

Referenced by HandleResponse().

Status XrdCl::XRootDMsgHandler::ReadAsync	(	int	socket,
		uint32_t &	btesRead
	)

private

Read a buffer asynchronously - depends on pAsyncBuffer, pAsyncSize and pAsyncOffset

References XrdCl::errSocketError, pAsyncOffset, pAsyncReadBuffer, pAsyncReadSize, read(), XrdCl::stError, XrdCl::stOK, XrdCl::suDone, and XrdCl::suRetry.

Referenced by ReadRawOther(), ReadRawRead(), and ReadRawReadV().

Status XrdCl::XRootDMsgHandler::ReadMessageBody	(	Message *	msg,
		int	socket,
		uint32_t &	bytesRead
	)

virtual

Read message body directly from a socket - called if Examine returns Raw flag - only socket related errors may be returned here

Parameters

msg	the corresponding message header
socket	the socket to read from
bytesRead	number of bytes read by the method

Returns: stOK & suDone if the whole body has been processed stOK & suRetry if more data is needed stError on failure

Reimplemented from XrdCl::IncomingMsgHandler.

References XrdCl::Buffer::GetBuffer(), ClientRequest::header, kXR_read, kXR_readv, pRequest, ReadRawOther(), ReadRawRead(), ReadRawReadV(), and ClientRequestHdr::requestid.

Status XrdCl::XRootDMsgHandler::ReadRawOther	(	Message *	msg,
		int	socket,
		uint32_t &	bytesRead
	)

private

Handle anything other than kXR_read and kXR_readv in raw mode.

References XrdCl::Status::code, XrdCl::Status::IsOK(), pAsyncMsgSize, pAsyncOffset, pAsyncReadBuffer, pAsyncReadSize, pOtherRawStarted, ReadAsync(), and XrdCl::suRetry.

Referenced by ReadMessageBody(), and ReadRawRead().

Status XrdCl::XRootDMsgHandler::ReadRawRead	(	Message *	msg,
		int	socket,
		uint32_t &	bytesRead
	)

private

Handle a kXR_read in raw mode.

References XrdCl::ChunkInfo::buffer, XrdCl::Log::Error(), XrdCl::Message::GetDescription(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), XrdCl::ChunkInfo::length, pAsyncMsgSize, pAsyncOffset, pAsyncReadBuffer, pAsyncReadSize, pChunkList, pChunkStatus, pOtherRawStarted, pReadRawCurrentOffset, pReadRawStarted, pRequest, pUrl, ReadAsync(), ReadRawOther(), and XrdCl::XRootDMsg.

Referenced by ReadMessageBody().

Status XrdCl::XRootDMsgHandler::ReadRawReadV	(	Message *	msg,
		int	socket,
		uint32_t &	bytesRead
	)

private

Handle a kXR_readv in raw mode.

References XrdCl::Status::code, XrdCl::Log::Dump(), XrdCl::Log::Error(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), XrdCl::Status::IsOK(), readahead_list::offset, pAsyncMsgSize, pAsyncOffset, pAsyncReadBuffer, pAsyncReadSize, pChunkList, pChunkStatus, pReadVRawChunkHeader, pReadVRawChunkHeaderDone, pReadVRawChunkHeaderStarted, pReadVRawChunkIndex, pReadVRawMsgDiscard, pReadVRawMsgOffset, pUrl, ReadAsync(), readahead_list::rlen, XrdCl::stOK, XrdCl::suDone, XrdCl::suRetry, and XrdCl::XRootDMsg.

Referenced by ReadMessageBody().

Status XrdCl::XRootDMsgHandler::RetryAtServer ( const URL & url )

private

Retry the request at another server.

References pExpiration, pHosts, pPostMaster, pRequest, pUrl, and XrdCl::PostMaster::Send().

Referenced by HandleError(), Process(), and WaitDone().

Status XrdCl::XRootDMsgHandler::RewriteRequestRedirect ( const URL::ParamsMap & newCgi )

private

Perform the changes to the original request needed by the redirect procedure - allocate new streamid, append redirection data and such

References XrdCl::SIDManager::AllocateSID(), XrdCl::MessageUtils::AppendCGI(), XrdCl::Log::Error(), XrdCl::AnyObject::Get(), XrdCl::Buffer::GetBuffer(), XrdCl::Message::GetDescription(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), ClientRequest::header, XrdCl::Status::IsOK(), XrdCl::XRootDTransport::MarshallRequest(), pPostMaster, pRequest, pSidMgr, pUrl, XrdCl::PostMaster::QueryTransport(), XrdCl::SIDManager::ReleaseSID(), XrdCl::XRootDQuery::SIDManager, ClientRequestHdr::streamid, XrdCl::XRootDTransport::UnMarshallRequest(), and XrdCl::XRootDMsg.

Referenced by Process().

Status XrdCl::XRootDMsgHandler::RewriteRequestWait ( )

private

Some requests need to be rewritten also after getting kXR_wait - sigh.

References XrdCl::Buffer::GetBuffer(), ClientRequest::header, kXR_locate, kXR_open, kXR_refresh, ClientRequest::locate, XrdCl::XRootDTransport::MarshallRequest(), ClientLocateRequest::options, pRequest, ClientRequestHdr::requestid, XrdCl::XRootDTransport::SetDescription(), and XrdCl::XRootDTransport::UnMarshallRequest().

Referenced by Process().

void XrdCl::XRootDMsgHandler::SetChunkList ( ChunkList * chunkList )

inline

Set the chunk list.

References pChunkList, and pChunkStatus.

Referenced by XrdCl::MessageUtils::SendMessage().

void XrdCl::XRootDMsgHandler::SetExpiration ( time_t expiration )

inline

Set a timestamp after which we give up.

References pExpiration.

Referenced by XrdCl::MessageUtils::SendMessage().

void XrdCl::XRootDMsgHandler::SetHostList ( HostList * hostList )

inline

Set host list.

References pHosts.

Referenced by XrdCl::MessageUtils::SendMessage().

void XrdCl::XRootDMsgHandler::SetLoadBalancer ( const HostInfo & loadBalancer )

inline

Set the load balancer.

References XrdCl::URL::IsValid(), pHasLoadBalancer, pLoadBalancer, and XrdCl::HostInfo::url.

Referenced by XrdCl::MessageUtils::SendMessage().

void XrdCl::XRootDMsgHandler::SetRedirectAsAnswer ( bool redirectAsAnswer )

inline

Treat the kXR_redirect response as a valid answer to the message and notify the handler with the URL as a response

References pRedirectAsAnswer.

Referenced by XrdCl::MessageUtils::SendMessage().

void XrdCl::XRootDMsgHandler::SetRedirectCounter ( uint16_t redirectCounter )

inline

Set the redirect counter.

References pRedirectCounter.

Referenced by XrdCl::MessageUtils::SendMessage().

void XrdCl::XRootDMsgHandler::SwitchOnRefreshFlag ( )

private

Switch on the refresh flag for some requests.

References XrdCl::Buffer::GetBuffer(), ClientRequest::header, kXR_locate, kXR_open, kXR_refresh, ClientRequest::locate, XrdCl::XRootDTransport::MarshallRequest(), ClientLocateRequest::options, pRequest, ClientRequestHdr::requestid, XrdCl::XRootDTransport::SetDescription(), and XrdCl::XRootDTransport::UnMarshallRequest().

Referenced by HandleError().

Status XrdCl::XRootDMsgHandler::UnPackReadVResponse ( Message * msg )

private

Unpack a single readv response.

References XrdCl::Log::Dump(), XrdCl::errInvalidResponse, XrdCl::Log::Error(), XrdCl::Buffer::GetBuffer(), XrdCl::Message::GetDescription(), XrdCl::URL::GetHostId(), XrdCl::DefaultEnv::GetLog(), XrdCl::Buffer::GetSize(), readahead_list::offset, pChunkList, pChunkStatus, pRequest, pUrl, readahead_list::rlen, XrdCl::stFatal, and XrdCl::XRootDMsg.

Referenced by PostProcessReadV().

void XrdCl::XRootDMsgHandler::UpdateTriedCGI ( )

private

Update the "tried=" part of the CGI of the current message.

References XrdCl::MessageUtils::AppendCGI(), XrdCl::URL::GetHostName(), XrdCl::XRootDTransport::MarshallRequest(), pRequest, pUrl, and XrdCl::XRootDTransport::UnMarshallRequest().

Referenced by HandleError().

void XrdCl::XRootDMsgHandler::WaitDone ( time_t now )

Called after the wait time for kXR_wait has elapsed

Parameters

now	current timestamp

References HandleError(), pUrl, and RetryAtServer().

Status XrdCl::XRootDMsgHandler::WriteMessageBody	(	int	socket,
		uint32_t &	bytesRead
	)

virtual

Write message body directly to a socket - called if IsRaw returns true - only socket related errors may be returned here

Parameters

socket	the socket to read from
bytesRead	number of bytes read by the method

Returns: stOK & suDone if the whole body has been processed stOK & suRetry if more data needs to be written stError on failure

Reimplemented from XrdCl::OutgoingMsgHandler.

References XrdCl::errSocketError, pAsyncOffset, pChunkList, XrdCl::stError, XrdCl::stOK, XrdCl::suRetry, and write().

Member Data Documentation

uint32_t XrdCl::XRootDMsgHandler::pAsyncMsgSize

private

Referenced by Examine(), ReadRawOther(), ReadRawRead(), and ReadRawReadV().

uint32_t XrdCl::XRootDMsgHandler::pAsyncOffset

private

Referenced by ReadAsync(), ReadRawOther(), ReadRawRead(), ReadRawReadV(), and WriteMessageBody().

char* XrdCl::XRootDMsgHandler::pAsyncReadBuffer

private

Referenced by ReadAsync(), ReadRawOther(), ReadRawRead(), and ReadRawReadV().

uint32_t XrdCl::XRootDMsgHandler::pAsyncReadSize

private

Referenced by ReadAsync(), ReadRawOther(), ReadRawRead(), and ReadRawReadV().

ChunkList* XrdCl::XRootDMsgHandler::pChunkList

private

Referenced by ParseResponse(), PostProcessReadV(), ReadRawRead(), ReadRawReadV(), SetChunkList(), UnPackReadVResponse(), and WriteMessageBody().

std::vector<ChunkStatus> XrdCl::XRootDMsgHandler::pChunkStatus

private

Referenced by ParseResponse(), PostProcessReadV(), ReadRawRead(), ReadRawReadV(), SetChunkList(), and UnPackReadVResponse().

time_t XrdCl::XRootDMsgHandler::pExpiration

private

Referenced by HandleError(), OnStatusReady(), RetryAtServer(), and SetExpiration().

bool XrdCl::XRootDMsgHandler::pHasLoadBalancer

private

Referenced by Process(), and SetLoadBalancer().

bool XrdCl::XRootDMsgHandler::pHasSessionId

private

Referenced by XRootDMsgHandler(), and ~XRootDMsgHandler().

HostList* XrdCl::XRootDMsgHandler::pHosts

private

Referenced by HandleResponse(), Process(), RetryAtServer(), and SetHostList().

HostInfo XrdCl::XRootDMsgHandler::pLoadBalancer

private

Referenced by HandleError(), Process(), and SetLoadBalancer().

bool XrdCl::XRootDMsgHandler::pOtherRawStarted

private

Referenced by ReadRawOther(), and ReadRawRead().

std::vector<Message *> XrdCl::XRootDMsgHandler::pPartialResps

private

Referenced by Examine(), ParseResponse(), PostProcessReadV(), and ~XRootDMsgHandler().

PostMaster* XrdCl::XRootDMsgHandler::pPostMaster

private

Referenced by OnStatusReady(), Process(), RetryAtServer(), RewriteRequestRedirect(), and XRootDMsgHandler().

uint32_t XrdCl::XRootDMsgHandler::pReadRawCurrentOffset

private

Referenced by Examine(), and ReadRawRead().

bool XrdCl::XRootDMsgHandler::pReadRawStarted

private

Referenced by Examine(), and ReadRawRead().

readahead_list XrdCl::XRootDMsgHandler::pReadVRawChunkHeader

private

Referenced by ReadRawReadV(), and XRootDMsgHandler().

bool XrdCl::XRootDMsgHandler::pReadVRawChunkHeaderDone

private

Referenced by ReadRawReadV().

bool XrdCl::XRootDMsgHandler::pReadVRawChunkHeaderStarted

private

Referenced by ReadRawReadV().

int32_t XrdCl::XRootDMsgHandler::pReadVRawChunkIndex

private

Referenced by ReadRawReadV().

bool XrdCl::XRootDMsgHandler::pReadVRawMsgDiscard

private

Referenced by ReadRawReadV().

uint32_t XrdCl::XRootDMsgHandler::pReadVRawMsgOffset

private

Referenced by Examine(), and ReadRawReadV().

bool XrdCl::XRootDMsgHandler::pReadVRawSizeError

private

bool XrdCl::XRootDMsgHandler::pRedirectAsAnswer

private

Referenced by ParseResponse(), Process(), and SetRedirectAsAnswer().

std::string XrdCl::XRootDMsgHandler::pRedirectCgi

private

Referenced by ParseResponse(), and Process().

uint16_t XrdCl::XRootDMsgHandler::pRedirectCounter

private

Referenced by Process(), and SetRedirectCounter().

Message* XrdCl::XRootDMsgHandler::pRequest

private

Referenced by Examine(), GetRequest(), HandleError(), HandleResponse(), IsRaw(), OnStreamEvent(), ParseResponse(), Process(), ReadMessageBody(), ReadRawRead(), RetryAtServer(), RewriteRequestRedirect(), RewriteRequestWait(), SwitchOnRefreshFlag(), UnPackReadVResponse(), UpdateTriedCGI(), and ~XRootDMsgHandler().

Message* XrdCl::XRootDMsgHandler::pResponse

private

Referenced by Examine(), HandleError(), ParseResponse(), PostProcessReadV(), Process(), ProcessStatus(), and ~XRootDMsgHandler().

ResponseHandler* XrdCl::XRootDMsgHandler::pResponseHandler

private

Referenced by HandleResponse().

SIDManager* XrdCl::XRootDMsgHandler::pSidMgr

private

Referenced by HandleResponse(), and RewriteRequestRedirect().

Status XrdCl::XRootDMsgHandler::pStatus

private

Referenced by HandleError(), Process(), and ProcessStatus().

URL XrdCl::XRootDMsgHandler::pUrl

private

Referenced by Examine(), HandleError(), OnStatusReady(), OnStreamEvent(), ParseResponse(), Process(), ReadRawRead(), ReadRawReadV(), RetryAtServer(), RewriteRequestRedirect(), UnPackReadVResponse(), UpdateTriedCGI(), and WaitDone().

The documentation for this class was generated from the following files:

Classes

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation