XrdXrootdAioPgrw Class Reference

#include <XrdXrootdAioPgrw.hh>

Inheritance diagram for XrdXrootdAioPgrw:

Collaboration diagram for XrdXrootdAioPgrw:

Public Member Functions
	XrdXrootdAioPgrw (XrdXrootdAioTask *tP, XrdBuffer *bP)
	~XrdXrootdAioPgrw ()
struct iovec *	iov4Data (int &iovNum)
struct iovec *	iov4Recv (int &iovNum)
struct iovec *	iov4Send (int &iovNum, int &iovLen, bool cs2net=false)
bool	noChkSums (bool reset=true)
void	Recycle () override
int	Setup2Recv (off_t offs, int dlen, const char *&eMsg)
int	Setup2Send (off_t offs, int dlen, const char *&eMsg)
Public Member Functions inherited from XrdXrootdAioBuff
	XrdXrootdAioBuff (XrdXrootdAioPgrw *pgrwP, XrdXrootdAioTask *tP, XrdBuffer *bP)
	XrdXrootdAioBuff (XrdXrootdAioTask *tP, XrdBuffer *bP)
void	doneRead () override
void	doneWrite () override
Public Member Functions inherited from XrdSfsAio
	XrdSfsAio ()
virtual	~XrdSfsAio ()

Static Public Member Functions
static XrdXrootdAioPgrw *	Alloc (XrdXrootdAioTask *arp)
Static Public Member Functions inherited from XrdXrootdAioBuff
static XrdXrootdAioBuff *	Alloc (XrdXrootdAioTask *arp)

Static Public Attributes
static const int	acsSZ = aioSZ/XrdProto::kXR_pgPageSZ
static const int	aioSZ = XrdXrootdPgrwAio::aioSZ

Additional Inherited Members
Public Attributes inherited from XrdXrootdAioBuff
XrdXrootdAioBuff *	next
XrdXrootdAioPgrw *const	pgrwP
Public Attributes inherited from XrdSfsAio
uint32_t *	cksVec
ssize_t	Result
struct aiocb	sfsAio
const char *	TIdent
Protected Attributes inherited from XrdXrootdAioBuff
XrdBuffer *	buffP
XrdXrootdAioTask *	reqP
Static Protected Attributes inherited from XrdXrootdAioBuff
static const char *	TraceID = "AioBuff"

Detailed Description

Definition at line 47 of file XrdXrootdAioPgrw.hh.

Constructor & Destructor Documentation

XrdXrootdAioPgrw()

XrdXrootdAioPgrw::XrdXrootdAioPgrw	(	XrdXrootdAioTask *	tP,
		XrdBuffer *	bP )

Definition at line 80 of file XrdXrootdAioPgrw.cc.

                 : XrdXrootdAioBuff(this, tP, bP)
{
   char *buff = bP->buff;
   uint32_t *csV = csVec;
 
// Fill out the iovec
//
   for (int i = 1; i <= acsSZ<<1; i+= 2)
       {ioVec[i  ].iov_base = csV;
        ioVec[i  ].iov_len  = csLen;
        ioVec[i+1].iov_base = buff;
        ioVec[i+1].iov_len  = XrdProto::kXR_pgPageSZ;
        csV++;
        buff += XrdProto::kXR_pgPageSZ;
       }
 
// Complete initialization
//
   Result = 0;
   iovReset = 0;
   cksVec = csVec;
   TIdent = "AioPgrw";
}

References XrdXrootdAioBuff::XrdXrootdAioBuff(), acsSZ, XrdBuffer::buff, XrdSfsAio::cksVec, XrdProto::kXR_pgPageSZ, XrdSfsAio::Result, and XrdSfsAio::TIdent.

Referenced by Alloc().

Here is the call graph for this function:

Here is the caller graph for this function:

~XrdXrootdAioPgrw()

XrdXrootdAioPgrw::~XrdXrootdAioPgrw

(

)

Definition at line 109 of file XrdXrootdAioPgrw.cc.

{
// Recycle the buffer if we have one
//
   if (buffP) BPool->Release(buffP);
}

References XrdXrootd::BPool, and XrdXrootdAioBuff::buffP.

Member Function Documentation

Alloc()

XrdXrootdAioPgrw * XrdXrootdAioPgrw::Alloc ( XrdXrootdAioTask * arp )

static

Definition at line 120 of file XrdXrootdAioPgrw.cc.

{
   XrdXrootdAioBuff *aiobuff;
 
// Obtain a preallocated aio object
//
   fqMutex.Lock();
   if ((aiobuff = fqFirst))
      {fqFirst = aiobuff->next;
       numFree--;
      }
   fqMutex.UnLock();
 
// If we have no object, create a new one. Otherwise initialize n old one
//
   if (!aiobuff)
      {XrdBuffer *bP = BPool->Obtain(aioSZ);
       if (!bP) return 0;
       aiobuff = new XrdXrootdAioPgrw(arp, bP);
      } else {
       aiobuff->Result = 0;
       aiobuff->cksVec = aiobuff->pgrwP->csVec;
       aiobuff->pgrwP->reqP = arp;
      }
 
// Update aio counters
//
   arp->urProtocol()->aioUpdate(1);
 
// All done
//
   return aiobuff->pgrwP;
}

References XrdXrootdAioBuff::XrdXrootdAioBuff(), XrdXrootdAioPgrw(), aioSZ, XrdXrootdProtocol::aioUpdate(), XrdXrootd::BPool, XrdSfsAio::cksVec, XrdXrootdAioBuff::next, XrdXrootdAioBuff::pgrwP, XrdXrootdAioBuff::reqP, XrdSfsAio::Result, and XrdXrootdAioTask::urProtocol().

Here is the call graph for this function:

iov4Data()

struct iovec * XrdXrootdAioPgrw::iov4Data ( int & iovNum )

inline

Definition at line 54 of file XrdXrootdAioPgrw.hh.

{iovNum = csNum<<1; return &ioVec[1];}

iov4Recv()

struct iovec * XrdXrootdAioPgrw::iov4Recv

(

int &

iovNum

)

Definition at line 158 of file XrdXrootdAioPgrw.cc.

{
// Readjust ioVec as needed
//
   if (aioSZ != (int)sfsAio.aio_nbytes)
      {int fLen, lLen;
       csNum = XrdOucPgrwUtils::csNum(sfsAio.aio_offset, sfsAio.aio_nbytes,
                                      fLen, lLen);
       ioVec[2].iov_len = fLen;
       if (csNum > 1 && lLen != XrdProto::kXR_pgPageSZ)
          {iovReset = csNum<<1;
           ioVec[iovReset].iov_len = lLen;
          }
      } else csNum = acsSZ;
 
// Return the iovec reception args
//
   iovNum = (csNum<<1);
   return &ioVec[1];
}

References acsSZ, aioSZ, XrdOucPgrwUtils::csNum(), XrdProto::kXR_pgPageSZ, and XrdSfsAio::sfsAio.

Here is the call graph for this function:

iov4Send()

struct iovec * XrdXrootdAioPgrw::iov4Send	(	int &	iovNum,
		int &	iovLen,
		bool	cs2net = false )

Definition at line 183 of file XrdXrootdAioPgrw.cc.

{
   int fLen, lLen;
 
// Recalculate the iovec values for first and last read and summary values
//
   if (Result > 0)
      {csNum = XrdOucPgrwUtils::csNum(sfsAio.aio_offset, Result, fLen, lLen);
       iovNum = (csNum<<1) + 1;
       iovLen = Result + (csNum * sizeof(uint32_t));
       ioVec[2].iov_len = fLen;
       if (csNum > 1 && lLen != XrdProto::kXR_pgPageSZ)
          {iovReset = csNum<<1;
           ioVec[iovReset].iov_len = lLen;
          }
      } else csNum = 0;
 
// Convert checksums to net order if so requested
//
   if (cs2net) for (int i = 0; i < csNum; i++) csVec[i] = htonl(csVec[i]);
 
// Return the iovec
//
   return ioVec;
}

References XrdOucPgrwUtils::csNum(), XrdProto::kXR_pgPageSZ, XrdSfsAio::Result, and XrdSfsAio::sfsAio.

Here is the call graph for this function:

noChkSums()

bool XrdXrootdAioPgrw::noChkSums ( bool reset = true )

inline

Definition at line 60 of file XrdXrootdAioPgrw.hh.

                             {bool retval = cksVec == 0;
                              if (retval && reset) cksVec = csVec;
                              return retval;
                             }

References XrdSfsAio::cksVec.

Recycle()

void XrdXrootdAioPgrw::Recycle ( )

overridevirtual

Reimplemented from XrdXrootdAioBuff.

Definition at line 213 of file XrdXrootdAioPgrw.cc.

{
// Do some tracing
//
   TRACE(FSAIO, " Recycle " <<sfsAio.aio_nbytes<<'@'
                            <<sfsAio.aio_offset<<" numF="<<numFree);
 
// Update aio counters
//
   reqP->urProtocol()->aioUpdate(-1);
 
// Place the object on the free queue if possible
//
   fqMutex.Lock();
   if (numFree >= maxKeep) 
      {fqMutex.UnLock();
       delete this;
      } else {
       next = fqFirst;
       fqFirst = this;
       numFree++;
       fqMutex.UnLock();
      }
}

References XrdXrootdAioBuff::next, XrdXrootdAioBuff::reqP, XrdSfsAio::sfsAio, and TRACE.

Setup2Recv()

int XrdXrootdAioPgrw::Setup2Recv	(	off_t	offs,
		int	dlen,
		const char *&	eMsg )

Definition at line 242 of file XrdXrootdAioPgrw.cc.

{
   XrdOucPgrwUtils::Layout layout;
 
// Reset any truncated segement in the iov vector
//
   if (iovReset)
      {ioVec[iovReset].iov_len = XrdProto::kXR_pgPageSZ;
       iovReset = 0;
      }
 
// Get the layout for the iovec
//
   if (!(csNum = XrdOucPgrwUtils::recvLayout(layout, offs, dlen, aioSZ)))
      {eMsg = layout.eWhy;
       return 0;
      }
   eMsg = 0;
 
// Set the length of the first and last segments. Note that our iovec has
// an extra leading element meant for writing to the network.
//
   ioVec[2].iov_len = layout.fLen;
   if (csNum > 1 && layout.lLen < XrdProto::kXR_pgPageSZ)
      {iovReset = csNum<<1;
       ioVec[iovReset].iov_len = layout.lLen;
      }
 
// Setup for actual writing of the data
//
   sfsAio.aio_buf    = ioVec[2].iov_base =  buffP->buff + layout.bOffset;
   sfsAio.aio_nbytes = layout.dataLen;
   sfsAio.aio_offset = offs;
 
// Return how much we can read from the socket
//
   return layout.sockLen;
}

References aioSZ, XrdOucPgrwUtils::Layout::bOffset, XrdXrootdAioBuff::buffP, XrdOucPgrwUtils::Layout::dataLen, eMsg, XrdOucPgrwUtils::Layout::eWhy, XrdOucPgrwUtils::Layout::fLen, XrdProto::kXR_pgPageSZ, XrdOucPgrwUtils::Layout::lLen, XrdOucPgrwUtils::recvLayout(), XrdSfsAio::sfsAio, and XrdOucPgrwUtils::Layout::sockLen.

Here is the call graph for this function:

Setup2Send()

int XrdXrootdAioPgrw::Setup2Send	(	off_t	offs,
		int	dlen,
		const char *&	eMsg )

Definition at line 285 of file XrdXrootdAioPgrw.cc.

{
   XrdOucPgrwUtils::Layout layout;
 
// Reset any truncated segement in the iov vector
//
   if (iovReset)
      {ioVec[iovReset].iov_len = XrdProto::kXR_pgPageSZ;
       iovReset = 0;
      }
 
// Get the layout for the iovec
//
   if (!(csNum = XrdOucPgrwUtils::sendLayout(layout, offs, dlen, aioSZ)))
      {eMsg = layout.eWhy;
       return 0;
      }
   eMsg = 0;
 
// Set the length of the first and last segments. Note that our iovec has
// an extra leading element meant for writing to the network.
//
   ioVec[2].iov_len = layout.fLen;
   if (csNum > 1 && layout.lLen < XrdProto::kXR_pgPageSZ)
      {iovReset = csNum<<1;
       ioVec[iovReset].iov_len = layout.lLen;
      }
 
// Setup for actual writing of the data
//
   sfsAio.aio_buf    = ioVec[2].iov_base =  buffP->buff + layout.bOffset;
   sfsAio.aio_nbytes = layout.dataLen;
   sfsAio.aio_offset = offs;
 
// Return how much we can write to the socket
//
   return layout.dataLen;
}

References aioSZ, XrdOucPgrwUtils::Layout::bOffset, XrdXrootdAioBuff::buffP, XrdOucPgrwUtils::Layout::dataLen, eMsg, XrdOucPgrwUtils::Layout::eWhy, XrdOucPgrwUtils::Layout::fLen, XrdProto::kXR_pgPageSZ, XrdOucPgrwUtils::Layout::lLen, XrdOucPgrwUtils::sendLayout(), and XrdSfsAio::sfsAio.

Here is the call graph for this function:

Member Data Documentation

acsSZ

const int XrdXrootdAioPgrw::acsSZ = aioSZ/XrdProto::kXR_pgPageSZ

static

Definition at line 76 of file XrdXrootdAioPgrw.hh.

Referenced by XrdXrootdAioPgrw(), and iov4Recv().

aioSZ

const int XrdXrootdAioPgrw::aioSZ = XrdXrootdPgrwAio::aioSZ

static

Definition at line 75 of file XrdXrootdAioPgrw.hh.

Referenced by Alloc(), iov4Recv(), Setup2Recv(), and Setup2Send().

---

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

• XrdXrootdAioPgrw.hh
• XrdXrootdAioPgrw.cc