XrdXrootdAioFob Class Reference

#include <XrdXrootdAioFob.hh>

Collaboration diagram for XrdXrootdAioFob:

Public Member Functions
	XrdXrootdAioFob ()
	~XrdXrootdAioFob ()
void	Reset ()
void	Reset (XrdXrootdProtocol *protP)
void	Schedule (XrdXrootdAioTask *aioP)
void	Schedule (XrdXrootdProtocol *protP)

Detailed Description

Definition at line 37 of file XrdXrootdAioFob.hh.

Constructor & Destructor Documentation

XrdXrootdAioFob()

XrdXrootdAioFob::XrdXrootdAioFob ( )

inline

Definition at line 49 of file XrdXrootdAioFob.hh.

: maxQ(0) {}

~XrdXrootdAioFob()

XrdXrootdAioFob::~XrdXrootdAioFob ( )

inline

Definition at line 51 of file XrdXrootdAioFob.hh.

{Reset();}

References Reset().

Here is the call graph for this function:

Member Function Documentation

Reset() [1/2]

void XrdXrootdAioFob::Reset

(

)

Definition at line 73 of file XrdXrootdAioFob.cc.

{
   XrdXrootdAioTask *aioP;
 
// Recycle all outstanding aio tasks
//
   fobMutex.Lock();
 
   for (int i = 0; i < maxQ; i++)
       {while((aioP = aioQ[i].first))
             {aioQ[i].first = aioP->nextTask;
              if (TRACING(TRACE_FSAIO)) Notify(aioP, "Discarding");
              aioP->Recycle(true);
             }
        aioQ[i].last = 0;
        Running[i] = false;
       }
 
   fobMutex.UnLock();
}

References XrdXrootdAioTask::Recycle(), TRACE_FSAIO, and TRACING.

Referenced by ~XrdXrootdAioFob(), and XrdXrootdFile::~XrdXrootdFile().

Here is the call graph for this function:

Here is the caller graph for this function:

Reset() [2/2]

void XrdXrootdAioFob::Reset

(

XrdXrootdProtocol *

protP

)

Definition at line 96 of file XrdXrootdAioFob.cc.

{
   XrdXrootdAioTask *aioP;
   int pathID = protP->getPathID();
 
// Recycle all outstanding aio tasks
//
   fobMutex.Lock();
 
   while((aioP = aioQ[pathID].first))
        {aioQ[pathID].first = aioP->nextTask;
         if (TRACING(TRACE_FSAIO)) Notify(aioP, "Discarding");
         aioP->Recycle(true);
        }
   aioQ[pathID].last = 0;
   Running[pathID] = false;
 
   fobMutex.UnLock();
}

References XrdXrootdProtocol::getPathID(), XrdXrootdAioTask::Recycle(), TRACE_FSAIO, and TRACING.

Here is the call graph for this function:

Schedule() [1/2]

void XrdXrootdAioFob::Schedule

(

XrdXrootdAioTask *

aioP

)

Definition at line 120 of file XrdXrootdAioFob.cc.

{
   int pathID = aioP->Protocol->getPathID();
 
// Run or queue this task
//
   fobMutex.Lock();
 
   if (Running[pathID])
      {if (aioQ[pathID].last) aioQ[pathID].last->nextTask = aioP;
          else aioQ[pathID].first = aioP;
       aioQ[pathID].last = aioP;
       aioP->nextTask = 0;
       if (maxQ <= pathID) maxQ = pathID+1;
       if (TRACING(TRACE_FSAIO)) Notify(aioP, "Queuing");
      } else {
       Sched->Schedule(aioP);
       Running[pathID] = true;
       if (TRACING(TRACE_FSAIO)) Notify(aioP, "Running");
      }
 
   fobMutex.UnLock();
}

References XrdXrootdProtocol::getPathID(), XrdXrootdAioTask::Protocol, XrdXrootd::Sched, XrdScheduler::Schedule(), TRACE_FSAIO, and TRACING.

Here is the call graph for this function:

Schedule() [2/2]

void XrdXrootdAioFob::Schedule

(

XrdXrootdProtocol *

protP

)

Definition at line 146 of file XrdXrootdAioFob.cc.

{
   int pathID = protP->getPathID();
 
// Schedule the next task.
//
   fobMutex.Lock();
 
   if (aioQ[pathID].first)
      {XrdXrootdAioTask *aioP = aioQ[pathID].first;
       if (!(aioQ[pathID].first = aioP->nextTask)) aioQ[pathID].last = 0;
       aioP->nextTask = 0;
       Sched->Schedule(aioP);
       Running[pathID] = true;
       if (TRACING(TRACE_FSAIO)) Notify(aioP, "Running");
      } else  Running[pathID] = false;
 
   fobMutex.UnLock();
}

References XrdXrootdProtocol::getPathID(), XrdXrootd::Sched, XrdScheduler::Schedule(), TRACE_FSAIO, and TRACING.

Here is the call graph for this function:

---

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

• XrdXrootdAioFob.hh
• XrdXrootdAioFob.cc