XrdXrootdAioBuff Class Reference

#include <XrdXrootdAioBuff.hh>

Inheritance diagram for XrdXrootdAioBuff:

Collaboration diagram for XrdXrootdAioBuff:

Public Member Functions
	XrdXrootdAioBuff (XrdXrootdAioPgrw *pgrwP, XrdXrootdAioTask *tP, XrdBuffer *bP)
	XrdXrootdAioBuff (XrdXrootdAioTask *tP, XrdBuffer *bP)
void	doneRead () override
void	doneWrite () override
virtual void	Recycle () override
Public Member Functions inherited from XrdSfsAio
	XrdSfsAio ()
virtual	~XrdSfsAio ()

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

Public Attributes
XrdXrootdAioBuff *	next
XrdXrootdAioPgrw *const	pgrwP
Public Attributes inherited from XrdSfsAio
uint32_t *	cksVec
ssize_t	Result
struct aiocb	sfsAio
const char *	TIdent

Protected Attributes
XrdBuffer *	buffP
XrdXrootdAioTask *	reqP

Static Protected Attributes
static const char *	TraceID = "AioBuff"

Detailed Description

Definition at line 40 of file XrdXrootdAioBuff.hh.

Constructor & Destructor Documentation

XrdXrootdAioBuff() [1/2]

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

inline

Definition at line 57 of file XrdXrootdAioBuff.hh.

                                  : pgrwP(0),     reqP(tP), buffP(bP) {}

XrdXrootdAioBuff() [2/2]

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

inline

Definition at line 60 of file XrdXrootdAioBuff.hh.

                                  : pgrwP(pgrwP), reqP(tP), buffP(bP) {}

Member Function Documentation

Alloc()

XrdXrootdAioBuff * XrdXrootdAioBuff::Alloc ( XrdXrootdAioTask *  arp )

static

Definition at line 72 of file XrdXrootdAioBuff.cc.

{
   XrdXrootdAioBuff *aiobuff;
   XrdBuffer *bP;
 
// Obtain a buffer as we never hold on to them (unlike pgaio)
//
   if (!(bP = BPool->Obtain(XrdXrootdProtocol::as_segsize))) return 0;
 
// 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.
//
   if (!aiobuff) aiobuff = new XrdXrootdAioBuff(arp, bP);
      else {aiobuff->reqP   = arp;
            aiobuff->buffP  = bP;
           }
    aiobuff->cksVec = 0;
    aiobuff->sfsAio.aio_buf = bP->buff;
    aiobuff->sfsAio.aio_nbytes = bP->bsize;
 
// Update aio counters
//
   arp->urProtocol()->aioUpdate(1);
 
// All done
//
   return aiobuff;
}

References aiocb::aio_buf, aiocb::aio_nbytes, XrdXrootdProtocol::aioUpdate(), XrdXrootdProtocol::as_segsize, XrdXrootd::BPool, XrdBuffer::bsize, XrdBuffer::buff, buffP, XrdSfsAio::cksVec, next, XrdBuffManager::Obtain(), reqP, XrdSfsAio::sfsAio, and XrdXrootdAioTask::urProtocol().

Here is the call graph for this function:

doneRead()

void XrdXrootdAioBuff::doneRead ( )

overridevirtual

Implements XrdSfsAio.

Definition at line 113 of file XrdXrootdAioBuff.cc.

{
// Tell the request this data is available to be sent to the client
//
   reqP->Completed(this);
}

References XrdXrootdAioTask::Completed(), and reqP.

Here is the call graph for this function:

doneWrite()

void XrdXrootdAioBuff::doneWrite ( )

overridevirtual

Implements XrdSfsAio.

Definition at line 124 of file XrdXrootdAioBuff.cc.

{
// Tell the request this data is has been dealth with
//
   reqP->Completed(this);
}

References XrdXrootdAioTask::Completed(), and reqP.

Here is the call graph for this function:

Recycle()

void XrdXrootdAioBuff::Recycle ( )

overridevirtual

Implements XrdSfsAio.

Reimplemented in XrdXrootdAioPgrw.

Definition at line 135 of file XrdXrootdAioBuff.cc.

{
 
// Do some tracing
//
   TRACEI(FSAIO, "Recycle " <<sfsAio.aio_nbytes<<'@'
                            <<sfsAio.aio_offset<<" numF="<<numFree);
 
// Update aio counters
//
   reqP->urProtocol()->aioUpdate(-1);
 
// Recycle the buffer as we don't want to hold on to it
//
   if (buffP) {BPool->Release(buffP); buffP = 0;}
 
// 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 aiocb::aio_nbytes, aiocb::aio_offset, XrdXrootdProtocol::aioUpdate(), XrdXrootd::BPool, buffP, next, XrdBuffManager::Release(), reqP, XrdSfsAio::sfsAio, TRACEI, and XrdXrootdAioTask::urProtocol().

Referenced by XrdXrootdAioTask::Completed(), and XrdXrootdAioTask::Drain().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

buffP

XrdBuffer* XrdXrootdAioBuff::buffP

protected

Definition at line 67 of file XrdXrootdAioBuff.hh.

Referenced by XrdXrootdAioPgrw::~XrdXrootdAioPgrw(), Alloc(), Recycle(), XrdXrootdAioPgrw::Setup2Recv(), and XrdXrootdAioPgrw::Setup2Send().

next

XrdXrootdAioBuff* XrdXrootdAioBuff::next

Definition at line 53 of file XrdXrootdAioBuff.hh.

Referenced by Alloc(), XrdXrootdAioPgrw::Alloc(), XrdXrootdAioTask::Completed(), XrdXrootdAioTask::Drain(), XrdXrootdAioTask::getBuff(), Recycle(), and XrdXrootdAioPgrw::Recycle().

pgrwP

XrdXrootdAioPgrw* const XrdXrootdAioBuff::pgrwP

Definition at line 55 of file XrdXrootdAioBuff.hh.

Referenced by XrdXrootdAioPgrw::Alloc().

reqP

XrdXrootdAioTask* XrdXrootdAioBuff::reqP

protected

Definition at line 66 of file XrdXrootdAioBuff.hh.

Referenced by Alloc(), XrdXrootdAioPgrw::Alloc(), doneRead(), doneWrite(), Recycle(), and XrdXrootdAioPgrw::Recycle().

TraceID

const char * XrdXrootdAioBuff::TraceID = "AioBuff"

staticprotected

Definition at line 65 of file XrdXrootdAioBuff.hh.

---

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

• XrdXrootdAioBuff.hh
• XrdXrootdAioBuff.cc