XrdXrootdPgrwAio Class Reference

#include <XrdXrootdPgrwAio.hh>

Inheritance diagram for XrdXrootdPgrwAio:

Collaboration diagram for XrdXrootdPgrwAio:

Public Member Functions
void	DoIt () override
void	Read (long long offs, int dlen) override
void	Recycle (bool release) override
int	Write (long long offs, int dlen) override
Public Member Functions inherited from XrdXrootdAioTask
void	Completed (XrdXrootdAioBuff *aioP)
const char *	ID ()
void	Init (XrdXrootdProtocol *protP, XrdXrootdResponse &resp, XrdXrootdFile *fP)
XrdXrootdProtocol *	urProtocol ()
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Static Public Member Functions
static XrdXrootdPgrwAio *	Alloc (XrdXrootdProtocol *protP, XrdXrootdResponse &resp, XrdXrootdFile *fP, XrdXrootdPgwBadCS *bcsP=0)

Static Public Attributes
static const int	aioSZ = 64*1024

Additional Inherited Members
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob
Protected Member Functions inherited from XrdXrootdAioTask
	XrdXrootdAioTask (const char *what="aio request")
virtual	~XrdXrootdAioTask ()
bool	Drain ()
int	gdDone () override
void	gdFail () override
XrdXrootdAioBuff *	getBuff (bool wait)
void	SendError (int rc, const char *eText)
void	SendFSError (int rc)
bool	Validate (XrdXrootdAioBuff *aioP)
Protected Attributes inherited from XrdXrootdAioTask
union {
XrdXrootdNormAio *	nextNorm
XrdXrootdPgrwAio *	nextPgrw
XrdXrootdAioTask *	nextTask
};
union {
XrdXrootdAioBuff *	finalRead
XrdXrootdAioBuff *	pendWrite
};
XrdSysMutex	aioMutex
XrdSysCondVar2	aioReady
char	aioState
XrdXrootdFile *	dataFile
int	dataLen
XrdLink *	dataLink
off_t	dataOffset
off_t	highOffset
RAtomic_uchar	inFlight
RAtomic_bool	isDone
XrdXrootdAioBuff *	pendQ
XrdXrootdAioBuff *	pendQEnd
XrdXrootdProtocol *	Protocol
XrdXrootdResponse	Response
char	Status
Static Protected Attributes inherited from XrdXrootdAioTask
static const int	aioDead = 0x01
static const int	aioHeld = 0x02
static const int	aioPage = 0x04
static const int	aioRead = 0x08
static const int	aioSchd = 0x10
static const int	Offline = 0
static const int	Running = 1
static const char *	TraceID = "AioTask"
static const int	Waiting = 2

Detailed Description

Definition at line 38 of file XrdXrootdPgrwAio.hh.

Member Function Documentation

Alloc()

XrdXrootdPgrwAio * XrdXrootdPgrwAio::Alloc ( XrdXrootdProtocol *  protP, XrdXrootdResponse &  resp, XrdXrootdFile *  fP, XrdXrootdPgwBadCS *  bcsP = 0  )

static

Definition at line 87 of file XrdXrootdPgrwAio.cc.

{
   XrdXrootdPgrwAio *reqP;
 
// Obtain a preallocated aio request object
//
   fqMutex.Lock();
   if ((reqP = fqFirst))
      {fqFirst = reqP->nextPgrw;
       numFree--;
      }
   fqMutex.UnLock();
 
// If we have no object, create a new one
//
   if (!reqP) reqP = new XrdXrootdPgrwAio;
 
// Initialize the object and return it
//
   reqP->Init(protP, resp, fP);
   reqP->nextPgrw = 0;
   reqP->badCSP   = bcsP;
   return reqP;
}

References XrdXrootdAioTask::Init().

Here is the call graph for this function:

DoIt()

void XrdXrootdPgrwAio::DoIt ( )

overridevirtual

Implements XrdJob.

Definition at line 352 of file XrdXrootdPgrwAio.cc.

{
// Reads run disconnected as they will never read from the link.
//
   if (aioState & aioRead) CopyF2L();
}

References XrdXrootdAioTask::aioRead, and XrdXrootdAioTask::aioState.

Read()

void XrdXrootdPgrwAio::Read ( long long  offs, int  dlen  )

overridevirtual

Implements XrdXrootdAioTask.

Definition at line 363 of file XrdXrootdPgrwAio.cc.

{
 
// Setup the copy from the file to the network
//
   dataOffset = highOffset = offs;
   dataLen    = dlen;
   aioState   = aioRead | aioPage;
 
// Reads run disconnected and are self-terminating, so we need to inclreas the
// refcount for the link we will be using to prevent it from disaapearing.
// Recycle will decrement it but does so only for reads. We always up the file
// refcount and number of requests.
//
   dataLink->setRef(1);
   dataFile->Ref(1);
   Protocol->aioUpdReq(1);
 
// Schedule ourselves to run this asynchronously and return
//
   dataFile->aioFob->Schedule(this);
}

References XrdXrootdFile::aioFob, XrdXrootdAioTask::aioPage, XrdXrootdAioTask::aioRead, XrdXrootdAioTask::aioState, XrdXrootdProtocol::aioUpdReq(), XrdXrootdAioTask::dataFile, XrdXrootdAioTask::dataLen, XrdXrootdAioTask::dataLink, XrdXrootdAioTask::dataOffset, XrdXrootdAioTask::highOffset, XrdXrootdAioTask::Protocol, XrdXrootdFile::Ref(), XrdXrootdAioFob::Schedule(), and XrdLink::setRef().

Here is the call graph for this function:

Recycle()

void XrdXrootdPgrwAio::Recycle ( bool  release )

overridevirtual

Implements XrdXrootdAioTask.

Definition at line 390 of file XrdXrootdPgrwAio.cc.

{
// Update request count, file and link reference count
//
   if (!(aioState & aioHeld))
       {Protocol->aioUpdReq(-1);
        if (aioState & aioRead)
           {dataLink->setRef(-1);
            dataFile->Ref(-1);
           }
        aioState |= aioHeld;
       }
 
// Do some traceing
//
   TRACEP(FSAIO,"pgrw recycle "<<(release ? "" : "hold ")
                <<(aioState & aioRead ? 'R' : 'W')<<" D-S="
                <<isDone<<'-'<<int(Status));
 
// Place the object on the free queue if possible
//
   if (release)
      {fqMutex.Lock();
       if (numFree >= maxKeep)
          {fqMutex.UnLock();
           delete this;
          } else {
           nextPgrw = fqFirst;
           fqFirst = this;
           numFree++;
           fqMutex.UnLock();
          }
      }
}

References XrdXrootdAioTask::aioHeld, XrdXrootdAioTask::aioRead, XrdXrootdAioTask::aioState, XrdXrootdProtocol::aioUpdReq(), XrdXrootdAioTask::dataFile, XrdXrootdAioTask::dataLink, XrdXrootdAioTask::isDone, XrdXrootdAioTask::Protocol, XrdXrootdFile::Ref(), XrdLink::setRef(), XrdXrootdAioTask::Status, and TRACEP.

Here is the call graph for this function:

Write()

int XrdXrootdPgrwAio::Write ( long long  offs, int  dlen  )

overridevirtual

Implements XrdXrootdAioTask.

Definition at line 544 of file XrdXrootdPgrwAio.cc.

{
 
// Update request count. Note that dataLink and dataFile references are
// handled outboard as writes are inextricably tied to the data link.
//
   Protocol->aioUpdReq(1);
 
// Setup the copy from the network to the file
//
   aioState  &= ~aioRead;
   dataOffset = highOffset = offs;
   dataLen    = dlen;
 
// Since this thread can't do anything else since it's blocked by the socket
// we simply initiate the write operation via a simulated getData() callback.
//
   return gdDone();
}

References XrdXrootdAioTask::aioState, XrdXrootdProtocol::aioUpdReq(), XrdXrootdAioTask::dataLen, XrdXrootdAioTask::dataOffset, XrdXrootdAioTask::gdDone(), XrdXrootdAioTask::highOffset, and XrdXrootdAioTask::Protocol.

Here is the call graph for this function:

Member Data Documentation

aioSZ

const int XrdXrootdPgrwAio::aioSZ = 64*1024

static

Definition at line 55 of file XrdXrootdPgrwAio.hh.

---

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

• XrdXrootdPgrwAio.hh
• XrdXrootdPgrwAio.cc