XrdCl::XRootDTransport Class Reference

XRootD transport handler. More...

#include <XrdClXRootDTransport.hh>

Inheritance diagram for XrdCl::XRootDTransport:

Collaboration diagram for XrdCl::XRootDTransport:

Public Member Functions
	XRootDTransport ()
	Constructor. More...
	~XRootDTransport ()
	Destructor. More...
virtual Status	GetMessage (Message *message, Socket *socket)
virtual void	InitializeChannel (AnyObject &channelData)
	Initialize channel. More...
virtual void	FinalizeChannel (AnyObject &channelData)
	Finalize channel. More...
virtual Status	HandShake (HandShakeData *handShakeData, AnyObject &channelData)
	HandShake. More...
virtual bool	IsStreamTTLElapsed (time_t time, AnyObject &channelData)
	Check if the stream should be disconnected. More...
virtual PathID	Multiplex (Message *msg, AnyObject &channelData, PathID *hint=0)
virtual PathID	MultiplexSubStream (Message *msg, AnyObject &channelData, PathID *hint=0)
virtual uint16_t	StreamNumber (AnyObject &channelData)
	Return a number of streams that should be created. More...
virtual uint16_t	SubStreamNumber (AnyObject &channelData)
	Return a number of substreams per stream that should be created. More...
virtual bool	NeedControlConnection ()
virtual void	Disconnect (AnyObject &channelData, uint16_t streamId, uint16_t subStreamId)
	The stream has been disconnected, do the cleanups. More...
virtual Status	Query (uint16_t query, AnyObject &result, AnyObject &channelData)
	Query the channel. More...
virtual bool	Highjack (Message *msg, AnyObject &channelData)
	Check whether the transport can highjack the message. More...
Public Member Functions inherited from XrdCl::TransportHandler
virtual	~TransportHandler ()

Static Public Member Functions
static Status	MarshallRequest (Message *msg)
	Marshal the outgoing message. More...
static Status	UnMarshallRequest (Message *msg)
static Status	UnMarshallBody (Message *msg, uint16_t reqType)
	Unmarshal the body of the incomming message. More...
static void	UnMarshallHeader (Message *msg)
	Unmarshal the header incomming message. More...
static void	LogErrorResponse (const Message &msg)
	Log server error response. More...
static void	SetDescription (Message *msg)
	Get the description of a message. More...

Private Types
typedef XrdSecProtocol *(*	XrdSecGetProt_t )(const char *, const sockaddr &, const XrdSecParameters &, XrdOucErrInfo *)

Private Member Functions
Status	HandShakeMain (HandShakeData *handShakeData, AnyObject &channelData)
Status	HandShakeParallel (HandShakeData *handShakeData, AnyObject &channelData)
Message *	GenerateInitialHS (HandShakeData *hsData, XRootDChannelInfo *info)
Message *	GenerateInitialHSProtocol (HandShakeData *hsData, XRootDChannelInfo *info)
Status	ProcessServerHS (HandShakeData *hsData, XRootDChannelInfo *info)
Status	ProcessProtocolResp (HandShakeData *hsData, XRootDChannelInfo *info)
Message *	GenerateBind (HandShakeData *hsData, XRootDChannelInfo *info)
Status	ProcessBindResp (HandShakeData *hsData, XRootDChannelInfo *info)
Message *	GenerateLogIn (HandShakeData *hsData, XRootDChannelInfo *info)
Status	ProcessLogInResp (HandShakeData *hsData, XRootDChannelInfo *info)
Status	DoAuthentication (HandShakeData *hsData, XRootDChannelInfo *info)
Status	GetCredentials (XrdSecCredentials *&credentials, HandShakeData *hsData, XRootDChannelInfo *info)
Status	CleanUpAuthentication (XRootDChannelInfo *info)
XrdSecGetProt_t	GetAuthHandler ()

Static Private Member Functions
static std::string	ServerFlagsToStr (uint32_t flags)
static std::string	FileHandleToStr (const unsigned char handle[4])

Private Attributes
void *	pSecLibHandle
XrdSecGetProt_t	pAuthHandler

Detailed Description

XRootD transport handler.

Member Typedef Documentation

typedef XrdSecProtocol*(* XrdCl::XRootDTransport::XrdSecGetProt_t)(const char *, const sockaddr &, const XrdSecParameters &, XrdOucErrInfo *)

private

Constructor & Destructor Documentation

XrdCl::XRootDTransport::XRootDTransport

(

)

Constructor.

XrdCl::XRootDTransport::~XRootDTransport

(

)

Destructor.

References pSecLibHandle.

Member Function Documentation

Status XrdCl::XRootDTransport::CleanUpAuthentication ( XRootDChannelInfo *  info )

private

References XrdCl::XRootDChannelInfo::authEnv, XrdCl::XRootDChannelInfo::authParams, XrdCl::XRootDChannelInfo::authProtocol, and XrdSecProtocol::Delete().

Referenced by DoAuthentication().

void XrdCl::XRootDTransport::Disconnect ( AnyObject &  channelData, uint16_t  streamId, uint16_t  subStreamId  )

virtual

The stream has been disconnected, do the cleanups.

Implements XrdCl::TransportHandler.

References XrdCl::XRootDStreamInfo::Disconnected, XrdCl::AnyObject::Get(), XrdCl::XRootDChannelInfo::mutex, XrdCl::SIDManager::ReleaseAllTimedOut(), XrdCl::XRootDChannelInfo::sidManager, XrdCl::XRootDStreamInfo::status, and XrdCl::XRootDChannelInfo::stream.

Status XrdCl::XRootDTransport::DoAuthentication ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References ClientRequest::auth, XrdCl::XRootDChannelInfo::authBuffer, XrdCl::XRootDChannelInfo::authEnv, ServerResponse::authmore, XrdCl::XRootDChannelInfo::authParams, XrdCl::XRootDChannelInfo::authProtocol, XrdCl::XRootDChannelInfo::authProtocolName, XrdCl::XRootDStreamInfo::AuthSent, ServerResponse::body, XrdSecBuffer::buffer, CleanUpAuthentication(), XrdCl::HandShakeData::clientName, ClientAuthRequest::credtype, ServerResponseBody_Authmore::data, XrdCl::Log::Debug(), ClientAuthRequest::dlen, ServerResponseHeader::dlen, XrdSecProtocol::Entity, XrdCl::errAuthFailed, ServerResponseBody_Error::errmsg, XrdCl::Log::Error(), ServerResponse::error, XrdCl::Buffer::GetBuffer(), XrdSecProtocol::getCredentials(), GetCredentials(), XrdOucErrInfo::getErrText(), XrdCl::DefaultEnv::GetLog(), ServerResponse::hdr, ClientRequest::header, XrdCl::HandShakeData::in, XrdCl::Status::IsOK(), kXR_auth, kXR_authmore, kXR_error, kXR_ok, XrdCl::XRootDStreamInfo::LoginSent, MarshallRequest(), XrdCl::HandShakeData::out, XrdSecEntity::prot, XrdOucEnv::Put(), ClientRequestHdr::requestid, XrdSecBuffer::size, XrdCl::XRootDStreamInfo::status, ServerResponseHeader::status, XrdCl::stFatal, XrdCl::stOK, XrdCl::XRootDChannelInfo::stream, XrdCl::HandShakeData::streamId, XrdCl::HandShakeData::streamName, XrdCl::suContinue, XrdCl::XRootDTransportMsg, and XrdCl::Buffer::Zero().

Referenced by HandShakeMain().

std::string XrdCl::XRootDTransport::FileHandleToStr ( const unsigned char  handle[4] )

staticprivate

Referenced by SetDescription().

void XrdCl::XRootDTransport::FinalizeChannel ( AnyObject &  channelData )

virtual

Finalize channel.

Implements XrdCl::TransportHandler.

Message * XrdCl::XRootDTransport::GenerateBind ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References XrdCl::Log::Debug(), ClientBindRequest::dlen, XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), kXR_bind, MarshallRequest(), ClientBindRequest::requestid, ClientBindRequest::sessid, XrdCl::XRootDChannelInfo::sessionId, XrdCl::HandShakeData::streamName, and XrdCl::XRootDTransportMsg.

Referenced by HandShakeParallel().

Message * XrdCl::XRootDTransport::GenerateInitialHS ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References XrdCl::Buffer::Allocate(), XrdCl::Log::Debug(), ClientInitHandShake::fifth, ClientInitHandShake::fourth, XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), XrdCl::HandShakeData::streamName, XrdCl::XRootDTransportMsg, and XrdCl::Buffer::Zero().

Referenced by HandShakeParallel().

Message * XrdCl::XRootDTransport::GenerateInitialHSProtocol ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References XrdCl::Buffer::Allocate(), ClientProtocolRequest::clientpv, XrdCl::Log::Debug(), ClientInitHandShake::fifth, ClientInitHandShake::fourth, XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), kXR_protocol, kXR_PROTOCOLVERSION, ClientProtocolRequest::requestid, XrdCl::HandShakeData::streamName, XrdCl::XRootDTransportMsg, and XrdCl::Buffer::Zero().

Referenced by HandShakeMain().

Message * XrdCl::XRootDTransport::GenerateLogIn ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References ClientLoginRequest::capver, XrdCl::Log::Debug(), ClientLoginRequest::dlen, XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), XrdCl::URL::GetUserName(), kXR_asyncap, kXR_login, kXR_useruser, kXR_ver003, MarshallRequest(), ClientLoginRequest::pid, ClientLoginRequest::requestid, ClientLoginRequest::role, XrdCl::HandShakeData::streamName, XrdCl::HandShakeData::url, XrdOucUtils::UserName(), ClientLoginRequest::username, and XrdCl::XRootDTransportMsg.

Referenced by HandShakeMain().

XRootDTransport::XrdSecGetProt_t XrdCl::XRootDTransport::GetAuthHandler ( )

private

References XrdCl::Log::Error(), XrdCl::DefaultEnv::GetLog(), LT_MODULE_EXT, pAuthHandler, pSecLibHandle, and XrdCl::XRootDTransportMsg.

Referenced by GetCredentials().

Status XrdCl::XRootDTransport::GetCredentials ( XrdSecCredentials *&  credentials, HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References XrdCl::XRootDChannelInfo::authEnv, XrdCl::XRootDChannelInfo::authParams, XrdCl::XRootDChannelInfo::authProtocol, XrdCl::Log::Debug(), XrdSecProtocol::Delete(), XrdSecProtocol::Entity, XrdCl::errAuthFailed, XrdCl::Log::Error(), GetAuthHandler(), XrdSecProtocol::getCredentials(), XrdOucErrInfo::getErrText(), XrdCl::URL::GetHostName(), XrdCl::DefaultEnv::GetLog(), XrdSecEntity::prot, XrdCl::HandShakeData::serverAddr, XrdCl::stFatal, XrdCl::stOK, XrdCl::HandShakeData::streamName, XrdCl::suContinue, XrdCl::HandShakeData::url, and XrdCl::XRootDTransportMsg.

Referenced by DoAuthentication().

Status XrdCl::XRootDTransport::GetMessage ( Message *  message, Socket *  socket  )

virtual

Read a message from the socket, the socket is non blocking, so if there is not enough data the function should retutn errRetry in which case it will be called again when more data arrives with the data previousely read stored in the message buffer

Parameters

message	the message
socket	the socket

Returns

stOK if the message has been processed properly, stError & errRetry when the method needs to be called again to finish reading the message stError on faiure

Implements XrdCl::TransportHandler.

References XrdCl::Buffer::AdvanceCursor(), XrdCl::Buffer::Allocate(), XrdCl::Log::Dump(), XrdCl::errSocketError, XrdCl::Buffer::GetBuffer(), XrdCl::Buffer::GetBufferAtCursor(), XrdCl::Buffer::GetCursor(), XrdCl::Socket::GetFD(), XrdCl::DefaultEnv::GetLog(), XrdCl::Socket::GetName(), XrdCl::Buffer::GetSize(), ServerResponse::hdr, read(), XrdCl::Buffer::ReAllocate(), XrdCl::stError, XrdCl::stOK, ServerResponseHeader::streamid, XrdCl::suRetry, UnMarshallHeader(), and XrdCl::XRootDTransportMsg.

Status XrdCl::XRootDTransport::HandShake ( HandShakeData *  handShakeData, AnyObject &  channelData  )

virtual

HandShake.

Implements XrdCl::TransportHandler.

References XrdCl::errInternal, XrdCl::Log::Error(), XrdCl::AnyObject::Get(), XrdCl::DefaultEnv::GetLog(), HandShakeMain(), HandShakeParallel(), XrdCl::XRootDChannelInfo::mutex, XrdCl::stFatal, XrdCl::XRootDChannelInfo::stream, XrdCl::XRootDChannelInfo::streamName, XrdCl::HandShakeData::streamName, XrdCl::HandShakeData::subStreamId, and XrdCl::XRootDTransportMsg.

Status XrdCl::XRootDTransport::HandShakeMain ( HandShakeData *  handShakeData, AnyObject &  channelData  )

private

References XrdCl::XRootDStreamInfo::AuthSent, XrdCl::XRootDStreamInfo::Broken, XrdCl::Status::code, XrdCl::XRootDStreamInfo::Connected, XrdCl::XRootDStreamInfo::Disconnected, DoAuthentication(), GenerateInitialHSProtocol(), GenerateLogIn(), XrdCl::AnyObject::Get(), XrdCl::XRootDStreamInfo::HandShakeReceived, XrdCl::XRootDStreamInfo::HandShakeSent, XrdCl::Status::IsOK(), XrdCl::XRootDStreamInfo::LoginSent, XrdCl::HandShakeData::out, ProcessLogInResp(), ProcessProtocolResp(), ProcessServerHS(), XrdCl::XRootDStreamInfo::status, XrdCl::stOK, XrdCl::XRootDChannelInfo::stream, XrdCl::HandShakeData::subStreamId, XrdCl::suContinue, and XrdCl::suDone.

Referenced by HandShake().

Status XrdCl::XRootDTransport::HandShakeParallel ( HandShakeData *  handShakeData, AnyObject &  channelData  )

private

References XrdCl::XRootDStreamInfo::BindSent, XrdCl::XRootDStreamInfo::Broken, XrdCl::XRootDStreamInfo::Connected, XrdCl::XRootDStreamInfo::Disconnected, GenerateBind(), GenerateInitialHS(), XrdCl::AnyObject::Get(), XrdCl::XRootDStreamInfo::HandShakeSent, XrdCl::Status::IsOK(), XrdCl::HandShakeData::out, ProcessBindResp(), ProcessServerHS(), XrdCl::XRootDStreamInfo::status, XrdCl::stOK, XrdCl::XRootDChannelInfo::stream, XrdCl::HandShakeData::subStreamId, and XrdCl::suContinue.

Referenced by HandShake().

bool XrdCl::XRootDTransport::Highjack ( Message *  msg, AnyObject &  channelData  )

virtual

Check whether the transport can highjack the message.

Implements XrdCl::TransportHandler.

References ServerResponseBody_Attn::actnum, ServerResponse::attn, ServerResponse::body, XrdCl::Log::Error(), XrdCl::AnyObject::Get(), XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), ServerResponse::hdr, XrdCl::SIDManager::IsTimedOut(), kXR_asynresp, kXR_attn, XrdCl::XRootDChannelInfo::mutex, XrdCl::SIDManager::ReleaseTimedOut(), XrdCl::XRootDChannelInfo::sidManager, ServerResponseHeader::status, ServerResponseHeader::streamid, and XrdCl::XRootDTransportMsg.

void XrdCl::XRootDTransport::InitializeChannel ( AnyObject &  channelData )

virtual

Initialize channel.

Implements XrdCl::TransportHandler.

References XrdCl::DefaultSubStreamsPerChannel, XrdCl::DefaultEnv::GetEnv(), XrdCl::Env::GetInt(), XrdCl::XRootDChannelInfo::mutex, XrdCl::AnyObject::Set(), and XrdCl::XRootDChannelInfo::stream.

bool XrdCl::XRootDTransport::IsStreamTTLElapsed ( time_t  time, AnyObject &  channelData  )

virtual

Check if the stream should be disconnected.

Implements XrdCl::TransportHandler.

void XrdCl::XRootDTransport::LogErrorResponse ( const Message &  msg )

static

Log server error response.

References ServerResponseBody_Error::errmsg, ServerResponseBody_Error::errnum, XrdCl::Log::Error(), XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), and XrdCl::XRootDTransportMsg.

Status XrdCl::XRootDTransport::MarshallRequest ( Message *  msg )

static

Marshal the outgoing message.

References ClientRequest::chmod, ClientProtocolRequest::clientpv, ClientReadVRequest::dlen, ClientRequestHdr::dlen, XrdCl::Buffer::GetBuffer(), ClientRequest::header, ClientQueryRequest::infotype, kXR_chmod, kXR_locate, kXR_login, kXR_mkdir, kXR_open, kXR_protocol, kXR_query, kXR_read, kXR_readv, kXR_truncate, kXR_write, ClientRequest::locate, ClientRequest::login, ClientRequest::mkdir, ClientChmodRequest::mode, ClientMkdirRequest::mode, ClientOpenRequest::mode, ClientReadRequest::offset, ClientTruncateRequest::offset, ClientWriteRequest::offset, readahead_list::offset, ClientRequest::open, ClientLocateRequest::options, ClientOpenRequest::options, ClientLoginRequest::pid, ClientRequest::protocol, ClientRequest::query, ClientRequest::read, ClientRequest::readv, ClientRequestHdr::requestid, ClientReadRequest::rlen, readahead_list::rlen, ClientRequest::truncate, and ClientRequest::write.

Referenced by DoAuthentication(), GenerateBind(), GenerateLogIn(), MultiplexSubStream(), XrdCl::XRootDMsgHandler::RewriteRequestRedirect(), XrdCl::XRootDMsgHandler::RewriteRequestWait(), XrdCl::MessageUtils::SendMessage(), XrdCl::XRootDMsgHandler::SwitchOnRefreshFlag(), UnMarshallRequest(), and XrdCl::XRootDMsgHandler::UpdateTriedCGI().

PathID XrdCl::XRootDTransport::Multiplex ( Message *  msg, AnyObject &  channelData, PathID *  hint = 0  )

virtual

Return the ID for the up stream this message should be sent by and the down stream which the answer should be expected at. Modify the message itself if necessary. If hint is non-zero then the message should be modified such that the answer will be returned via the hinted stream.

Implements XrdCl::TransportHandler.

PathID XrdCl::XRootDTransport::MultiplexSubStream ( Message *  msg, AnyObject &  channelData, PathID *  hint = 0  )

virtual

Return the ID for the up substream this message should be sent by and the down substream which the answer should be expected at. Modify the message itself if necessary. If hint is non-zero then the message should be modified such that the answer will be returned via the hinted stream.

Implements XrdCl::TransportHandler.

References XrdCl::XRootDStreamInfo::Connected, XrdCl::Log::Debug(), ClientReadRequest::dlen, XrdCl::PathID::down, XrdCl::AnyObject::Get(), XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), XrdCl::Buffer::GetSize(), kXR_isServer, kXR_read, kXR_readv, kXR_write, MarshallRequest(), XrdCl::XRootDChannelInfo::mutex, ClientReadVRequest::pathid, read_args::pathid, XrdCl::Buffer::ReAllocate(), ClientRequestHdr::requestid, XrdCl::XRootDChannelInfo::serverFlags, XrdCl::XRootDChannelInfo::stream, XrdCl::XRootDChannelInfo::streamName, UnMarshallRequest(), XrdCl::PathID::up, and XrdCl::XRootDTransportMsg.

virtual bool XrdCl::XRootDTransport::NeedControlConnection ( )

inlinevirtual

Return the information whether a control connection needs to be valid before establishing other connections

Status XrdCl::XRootDTransport::ProcessBindResp ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References ServerResponse::bind, ServerResponse::body, XrdCl::Log::Debug(), XrdCl::errHandShakeFailed, XrdCl::Log::Error(), XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), ServerResponse::hdr, XrdCl::HandShakeData::in, XrdCl::Status::IsOK(), kXR_bind, kXR_ok, ServerResponseHeader::status, XrdCl::stFatal, XrdCl::XRootDChannelInfo::stream, XrdCl::HandShakeData::streamName, XrdCl::HandShakeData::subStreamId, ServerResponseBody_Bind::substreamid, UnMarshallBody(), and XrdCl::XRootDTransportMsg.

Referenced by HandShakeParallel().

Status XrdCl::XRootDTransport::ProcessLogInResp ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References XrdCl::XRootDChannelInfo::authBuffer, ServerResponse::body, XrdCl::Log::Debug(), ServerResponseHeader::dlen, XrdCl::errLoginFailed, XrdCl::Log::Error(), XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), ServerResponse::hdr, XrdCl::HandShakeData::in, XrdCl::Status::IsOK(), kXR_login, kXR_ok, ServerResponse::login, ServerResponseBody_Login::sec, ServerResponseBody_Login::sessid, XrdCl::XRootDChannelInfo::sessionId, ServerResponseHeader::status, XrdCl::stFatal, XrdCl::stOK, XrdCl::HandShakeData::streamName, XrdCl::suContinue, UnMarshallBody(), and XrdCl::XRootDTransportMsg.

Referenced by HandShakeMain().

Status XrdCl::XRootDTransport::ProcessProtocolResp ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References ServerResponse::body, XrdCl::Log::Debug(), XrdCl::errHandShakeFailed, XrdCl::Log::Error(), ServerResponseBody_Protocol::flags, XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), ServerResponse::hdr, XrdCl::HandShakeData::in, XrdCl::Status::IsOK(), kXR_ok, kXR_protocol, ServerResponse::protocol, XrdCl::XRootDChannelInfo::protocolVersion, ServerResponseBody_Protocol::pval, XrdCl::XRootDChannelInfo::serverFlags, ServerFlagsToStr(), ServerResponseHeader::status, XrdCl::stFatal, XrdCl::stOK, XrdCl::HandShakeData::streamName, XrdCl::suContinue, UnMarshallBody(), and XrdCl::XRootDTransportMsg.

Referenced by HandShakeMain().

Status XrdCl::XRootDTransport::ProcessServerHS ( HandShakeData *  hsData, XRootDChannelInfo *  info  )

private

References XrdCl::Log::Debug(), XrdCl::errHandShakeFailed, XrdCl::Log::Error(), XrdCl::Buffer::GetBuffer(), XrdCl::DefaultEnv::GetLog(), XrdCl::HandShakeData::in, kXR_DataServer, kXR_isManager, kXR_isServer, kXR_ok, ServerInitHandShake::msgval, XrdCl::XRootDChannelInfo::protocolVersion, ServerInitHandShake::protover, XrdCl::XRootDChannelInfo::serverFlags, ServerFlagsToStr(), ServerResponseHeader::status, XrdCl::stFatal, XrdCl::stOK, XrdCl::HandShakeData::streamName, XrdCl::suContinue, and XrdCl::XRootDTransportMsg.

Referenced by HandShakeMain(), and HandShakeParallel().

Status XrdCl::XRootDTransport::Query ( uint16_t  query, AnyObject &  result, AnyObject &  channelData  )

virtual

Query the channel.

Implements XrdCl::TransportHandler.

References XrdCl::TransportQuery::Auth, XrdCl::XRootDChannelInfo::authProtocolName, XrdCl::errQueryNotSupported, XrdCl::AnyObject::Get(), XrdCl::XRootDChannelInfo::mutex, XrdCl::TransportQuery::Name, XrdCl::XRootDQuery::ProtocolVersion, XrdCl::XRootDChannelInfo::protocolVersion, XrdCl::XRootDQuery::ServerFlags, XrdCl::XRootDChannelInfo::serverFlags, XrdCl::AnyObject::Set(), XrdCl::XRootDQuery::SIDManager, XrdCl::XRootDChannelInfo::sidManager, and XrdCl::stError.

std::string XrdCl::XRootDTransport::ServerFlagsToStr ( uint32_t  flags )

staticprivate

References kXR_attrMeta, kXR_attrProxy, kXR_attrSuper, kXR_isManager, and kXR_isServer.

Referenced by ProcessProtocolResp(), and ProcessServerHS().

void XrdCl::XRootDTransport::SetDescription ( Message *  msg )

static

Get the description of a message.

References ClientProtocolRequest::clientpv, ClientMvRequest::dlen, ClientQueryRequest::dlen, ClientStatRequest::dlen, ClientTruncateRequest::dlen, ClientWriteRequest::dlen, ClientRequestHdr::dlen, ClientCloseRequest::fhandle, ClientReadRequest::fhandle, ClientStatRequest::fhandle, ClientSyncRequest::fhandle, ClientTruncateRequest::fhandle, ClientWriteRequest::fhandle, readahead_list::fhandle, FileHandleToStr(), XrdCl::Buffer::GetBuffer(), ClientQueryRequest::infotype, kXR_chmod, kXR_close, kXR_coloc, kXR_delete, kXR_dirlist, kXR_force, kXR_fresh, kXR_locate, kXR_mkdir, kXR_mkdirpath, kXR_mkpath, kXR_mv, kXR_new, kXR_nowait, kXR_open, kXR_open_apnd, kXR_open_read, kXR_open_updt, kXR_ping, kXR_posc, kXR_prepare, kXR_protocol, kXR_Qckscan, kXR_Qcksum, kXR_Qconfig, kXR_Qopaque, kXR_Qopaquf, kXR_QPrep, kXR_Qspace, kXR_QStats, kXR_query, kXR_Qvisa, kXR_Qxattr, kXR_read, kXR_readv, kXR_refresh, kXR_replica, kXR_rm, kXR_rmdir, kXR_seqio, kXR_set, kXR_stage, kXR_stat, kXR_sync, kXR_truncate, kXR_vfs, kXR_wmode, kXR_write, ClientChmodRequest::mode, ClientMkdirRequest::mode, ClientOpenRequest::mode, ClientReadRequest::offset, ClientTruncateRequest::offset, ClientWriteRequest::offset, ClientLocateRequest::options, ClientMkdirRequest::options, ClientOpenRequest::options, ClientPrepareRequest::options, ClientStatRequest::options, ClientPrepareRequest::prty, ClientRequestHdr::requestid, ClientReadRequest::rlen, readahead_list::rlen, and XrdCl::Message::SetDescription().

Referenced by XrdCl::MessageUtils::AppendCGI(), XrdCl::FileSystem::ChMod(), XrdCl::FileStateHandler::Close(), XrdCl::FileSystem::DirList(), XrdCl::FileSystem::Locate(), XrdCl::FileSystem::MkDir(), XrdCl::FileSystem::Mv(), XrdCl::FileStateHandler::Open(), XrdCl::FileSystem::Ping(), XrdCl::FileSystem::Prepare(), XrdCl::FileSystem::Protocol(), XrdCl::FileSystem::Query(), XrdCl::FileStateHandler::Read(), XrdCl::FileStateHandler::ReOpenFileAtServer(), XrdCl::FileStateHandler::ReWriteFileHandle(), XrdCl::XRootDMsgHandler::RewriteRequestWait(), XrdCl::FileSystem::Rm(), XrdCl::FileSystem::RmDir(), XrdCl::FileSystem::SendInfo(), XrdCl::FileStateHandler::Stat(), XrdCl::FileSystem::Stat(), XrdCl::FileSystem::StatVFS(), XrdCl::XRootDMsgHandler::SwitchOnRefreshFlag(), XrdCl::FileStateHandler::Sync(), XrdCl::FileStateHandler::Truncate(), XrdCl::FileSystem::Truncate(), XrdCl::FileStateHandler::VectorRead(), and XrdCl::FileStateHandler::Write().

uint16_t XrdCl::XRootDTransport::StreamNumber ( AnyObject &  channelData )

virtual

Return a number of streams that should be created.

Implements XrdCl::TransportHandler.

uint16_t XrdCl::XRootDTransport::SubStreamNumber ( AnyObject &  channelData )

virtual

Return a number of substreams per stream that should be created.

Implements XrdCl::TransportHandler.

References XrdCl::AnyObject::Get(), kXR_isServer, XrdCl::XRootDChannelInfo::mutex, XrdCl::XRootDChannelInfo::serverFlags, and XrdCl::XRootDChannelInfo::stream.

Status XrdCl::XRootDTransport::UnMarshallBody ( Message *  msg, uint16_t  reqType  )

static

Unmarshal the body of the incomming message.

References ServerResponseBody_Attn::actnum, ServerResponse::attn, ServerResponse::body, ServerResponseHeader::dlen, XrdCl::errInvalidMessage, ServerResponseBody_Error::errnum, ServerResponse::error, ServerResponseBody_Protocol::flags, XrdCl::Buffer::GetBuffer(), ServerResponse::hdr, kXR_attn, kXR_error, kXR_ok, kXR_protocol, kXR_redirect, kXR_wait, kXR_waitresp, ServerResponseBody_Redirect::port, ServerResponse::protocol, ServerResponseBody_Protocol::pval, ServerResponse::redirect, ServerResponseBody_Wait::seconds, ServerResponseBody_Waitresp::seconds, ServerResponseHeader::status, XrdCl::stError, ServerResponse::wait, and ServerResponse::waitresp.

Referenced by XrdCl::XRootDMsgHandler::OnIncoming(), ProcessBindResp(), ProcessLogInResp(), and ProcessProtocolResp().

void XrdCl::XRootDTransport::UnMarshallHeader ( Message *  msg )

static

Unmarshal the header incomming message.

References ServerResponseHeader::dlen, XrdCl::Buffer::GetBuffer(), and ServerResponseHeader::status.

Referenced by GetMessage(), and XrdCl::XRootDMsgHandler::OnIncoming().

Status XrdCl::XRootDTransport::UnMarshallRequest ( Message *  msg )

static

Unmarshal the request - sometimes the requests need to be rewritten, so we need to unmarshall them

References ClientRequestHdr::dlen, XrdCl::Buffer::GetBuffer(), ClientRequest::header, MarshallRequest(), and ClientRequestHdr::requestid.

Referenced by XrdCl::XRootDMsgHandler::HandleResponse(), MultiplexSubStream(), XrdCl::XRootDMsgHandler::RewriteRequestRedirect(), XrdCl::XRootDMsgHandler::RewriteRequestWait(), XrdCl::MessageUtils::SendMessage(), XrdCl::XRootDMsgHandler::SwitchOnRefreshFlag(), and XrdCl::XRootDMsgHandler::UpdateTriedCGI().

Member Data Documentation

XrdSecGetProt_t XrdCl::XRootDTransport::pAuthHandler

private

Referenced by GetAuthHandler().

void* XrdCl::XRootDTransport::pSecLibHandle

private

Referenced by GetAuthHandler(), and ~XRootDTransport().

---

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

• XrdClXRootDTransport.hh
• XrdClXRootDTransport.cc