xrootd: XrdClientMStream Class Reference

xrootd

#include <XrdClientMStream.hh>

List of all members.

Classes
struct	ReadChunk
Static Public Member Functions
static void	GetGoodSplitParameters (XrdClientConn *cliconn, int &spltsize, int &reqsperstream, kXR_int32 len)
static int	EstablishParallelStreams (XrdClientConn *cliconn)
static int	AddParallelStream (XrdClientConn *cliconn, int port, int windowsz, int tempid)
static int	RemoveParallelStream (XrdClientConn *cliconn, int substream)
static bool	BindPendingStream (XrdClientConn *cliconn, int substreamid, int &newid)
static bool	SplitReadRequest (XrdClientConn *cliconn, kXR_int64 offset, kXR_int32 len, XrdClientVector< ReadChunk > &reqlists)

Member Function Documentation

int XrdClientMStream::AddParallelStream	(	XrdClientConn *	cliconn,
		int	port,
		int	windowsz,
		int	tempid
	)		`[static]`

References XrdClientConn::GetPhyConn(), XrdClientConn::GetLogConnID(), XrdClientPhyConnection::GetSockIdCount(), EnvGetLong, NAME_MULTISTREAMCNT, XrdClientPhyConnection::TryConnectParallelStream(), XrdClientPhyConnection::DoHandShake(), kSTError, BindPendingStream(), XrdClientPhyConnection::IsValid(), XrdClientPhyConnection::EstablishPendingParallelStream(), RemoveParallelStream(), XrdClientPhyConnection::UnBanSockDescr(), XrdClientPhyConnection::ReinitFDTable(), Info, and XrdClientDebug::kHIDEBUG.

Referenced by ParStreamOpenerThread().

bool XrdClientMStream::BindPendingStream	(	XrdClientConn *	cliconn,
		int	substreamid,
		int &	newid
	)		`[static]`

int XrdClientMStream::EstablishParallelStreams ( XrdClientConn * cliconn ) [static]

References EnvGetLong, NAME_MULTISTREAMCNT, XrdClientConn::GetServerType(), kSTBaseXrootd, kSTMetaXrootd, XrdClientConn::GetPhyConn(), XrdClientConn::GetLogConnID(), XrdClientPhyConnection::TestAndSetMStreamsGoing(), XrdClientConn::SetSID(), ClientRequest::header, ClientRequestHdr::streamid, ClientRequestHdr::requestid, kXR_query, ClientRequest::query, ClientQueryRequest::infotype, kXR_Qconfig, ClientRequestHdr::dlen, XrdClientConn::SendGenCommand(), XrdClientConn::LastServerResp, ServerResponseHeader::status, kXR_ok, ServerResponseHeader::dlen, Info, XrdClientDebug::kUSERDEBUG, ParStreamOpenerArgs::thr, ParStreamOpenerArgs::cliconn, ParStreamOpenerArgs::wan_port, ParStreamOpenerArgs::wan_window, ParStreamOpenerArgs::tmpid, XrdClientDebug::kHIDEBUG, ParStreamOpenerThread(), XRDCLI_PSOCKTEMP, Error, and XrdClientThread::Join().

Referenced by XrdClient::TryOpen().

void XrdClientMStream::GetGoodSplitParameters	(	XrdClientConn *	cliconn,
		int &	spltsize,
		int &	reqsperstream,
		kXR_int32	len
	)		`[static]`

References DFLT_MULTISTREAMSPLITSIZE, XrdClientConn::GetParallelStreamCount(), and xrdmax.

Referenced by XrdClient::ReadV(), and SplitReadRequest().

int XrdClientMStream::RemoveParallelStream	(	XrdClientConn *	cliconn,
		int	substream
	)		`[static]`

References ConnectionManager, XrdClientConn::GetLogConnID(), XrdClientLogConnection::GetPhyConnection(), and XrdClientPhyConnection::RemoveParallelStream().

Referenced by AddParallelStream().

bool XrdClientMStream::SplitReadRequest	(	XrdClientConn *	cliconn,
		kXR_int64	offset,
		kXR_int32	len,
		XrdClientVector< ReadChunk > &	reqlists
	)		`[static]`

References GetGoodSplitParameters(), XrdClientMStream::ReadChunk::offset, XrdClientMStream::ReadChunk::len, xrdmin, XrdClientMStream::ReadChunk::streamtosend, XrdClientConn::GetParallelStreamToUse(), and XrdClientVector::Push_back().

Referenced by XrdClient::Write(), and XrdClient::Read_Async().

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