XrdOfsTPCJob Class Reference

#include <XrdOfsTPCJob.hh>

Inheritance diagram for XrdOfsTPCJob:

Collaboration diagram for XrdOfsTPCJob:

Public Member Functions
	XrdOfsTPCJob (const char *Url, const char *Org, const char *Lfn, const char *Pfn, const char *Cks, short lfnLoc[2], const char *Spr, const char *Tpr)
	~XrdOfsTPCJob ()
void	Del ()
XrdOfsTPCJob *	Done (XrdOfsTPCProg *pgmP, const char *eTxt, int rc)
int	Sync (XrdOucErrInfo *eRR)
Public Member Functions inherited from XrdOfsTPC
	XrdOfsTPC ()
	XrdOfsTPC (const char *Url, const char *Org, const char *Lfn, const char *Pfn, const char *Cks=0, const char *Spr=0, const char *Tpr=0)
virtual	~XrdOfsTPC ()

Additional Inherited Members
Static Public Member Functions inherited from XrdOfsTPC
static const char *	AddAuth (const char *auth, const char *avar)
static void	Allow (char *vDN, char *vGN, char *vHN, char *vVO)
static int	Authorize (XrdOfsTPC **theTPC, Facts &Args, int isPLE=0)
static const char *	credPath ()
static void	Init ()
static void	Init (XrdAccAuthorize *accP)
static void	Require (const char *Auth, int RType)
static int	Restrict (const char *Path)
static int	Start ()
static int	Validate (XrdOfsTPC **theTPC, Facts &Args)
Public Attributes inherited from XrdOfsTPC
XrdOfsTPCInfo	Info
Static Public Attributes inherited from XrdOfsTPC
static const int	reqALL = 0
static const int	reqDST = 1
static const int	reqORG = 2
Static Protected Member Functions inherited from XrdOfsTPC
static int	Death (Facts &Args, const char *eMsg, int eCode, int nomsg=0)
static int	Fatal (Facts &Args, const char *eMsg, int eCode, int nomsg=0)
static int	genOrg (const XrdSecEntity *client, char *Buff, int Blen)
static int	getTTL (XrdOucEnv *Env)
static int	Screen (Facts &Args, XrdOucTList *tP, int wasEnc=0)
static char *	Verify (const char *Who, const char *Name, char *Buf, int Blen)
Protected Attributes inherited from XrdOfsTPC
char	inQ
char	Refs
Static Protected Attributes inherited from XrdOfsTPC
static XrdOfsTPCAllow *	ALList = 0
static XrdOucTList *	AuthDst = 0
static XrdOucTList *	AuthOrg = 0
static char *	cPath = 0
static XrdAccAuthorize *	fsAuth = 0
static XrdOucPListAnchor *	RPList

Detailed Description

Definition at line 38 of file XrdOfsTPCJob.hh.

Constructor & Destructor Documentation

XrdOfsTPCJob()

XrdOfsTPCJob::XrdOfsTPCJob	(	const char *	Url,
		const char *	Org,
		const char *	Lfn,
		const char *	Pfn,
		const char *	Cks,
		short	lfnLoc[2],
		const char *	Spr,
		const char *	Tpr
	)

Definition at line 56 of file XrdOfsTPCJob.cc.

                          : XrdOfsTPC(Url, Org, Lfn, Pfn, Cks, Spr, Tpr),
                            Next(0), myProg(0), eCode(0), Status(isWaiting)
{  lfnPos[0] = lfnLoc[0]; lfnPos[1] = lfnLoc[1]; }

~XrdOfsTPCJob()

XrdOfsTPCJob::~XrdOfsTPCJob ( )

inline

Definition at line 53 of file XrdOfsTPCJob.hh.

{}

Member Function Documentation

Del()

void XrdOfsTPCJob::Del ( )

virtual

Reimplemented from XrdOfsTPC.

Definition at line 68 of file XrdOfsTPCJob.cc.

{
   XrdOfsTPCJob *pP = 0;
   bool tpcCan = false;
 
// Remove from queue if we are still in the queue
//
   jobMutex.Lock();
   if (inQ)
      {if (this == jobQ) jobQ = Next;
          else {pP = jobQ;
                while(pP && pP->Next != this) pP = pP->Next;
                if (pP) pP->Next = Next;
               }
       if (this == jobLast) jobLast = pP;
       inQ = 0; tpcCan = true;
      } else if (Status == isRunning && myProg)
                {myProg->Cancel(); tpcCan = true;}
 
   if (tpcCan && Info.cbP)
      {Refs++; // Make sure this object cannot get deleted
       Info.Reply(SFS_ERROR, ECANCELED, "destination file prematurely closed",
                  &jobMutex); // Mutex is unlocked upon return!
       jobMutex.Lock();
       Refs--; // Undo the extra ref increase
      }
 
// Delete the element if possible
//
   if (Refs <= 1)  {jobMutex.UnLock(); delete this;}
      else {Refs--; jobMutex.UnLock();}
}

References XrdOfsTPCProg::Cancel(), XrdOfsTPCInfo::cbP, XrdOfsTPC::Info, XrdOfsTPC::inQ, XrdSysMutex::Lock(), XrdOfsTPC::Refs, XrdOfsTPCInfo::Reply(), SFS_ERROR, and XrdSysMutex::UnLock().

Here is the call graph for this function:

Done()

XrdOfsTPCJob * XrdOfsTPCJob::Done	(	XrdOfsTPCProg *	pgmP,
		const char *	eTxt,
		int	rc
	)

Definition at line 105 of file XrdOfsTPCJob.cc.

{
   XrdSysMutexHelper jobMon(&jobMutex);
   XrdOfsTPCJob *jP;
 
// Indicate job status
//
   eCode = rc; Status = isDone;
   if (Info.Key) free(Info.Key);
   Info.Key = (rc ? strdup(eTxt) : 0);
 
// Check if we need to do a callback
//
   if (Info.cbP)
      {if (rc) Info.Reply(SFS_ERROR, rc, eTxt);
          else Info.Reply(SFS_OK, 0, "");
      }
 
// Check if anyone is waiting for a program
//
   if ((jP = jobQ))
      {if (jP == jobLast) jobQ = jobLast = 0;
          else            jobQ = jP->Next;
       jP->myProg = pgmP; jP->Refs++; jP->inQ = 0; jP->Status = isRunning;
       if (jP->Info.cbP) jP->Info.Reply(SFS_OK, 0, "");
      }
 
// Free up this job and return the next job, if any
//
   myProg = 0;
   if (Refs <= 1) delete this;
      else Refs--;
   return jP;
}

References XrdOfsTPCInfo::cbP, XrdOfsTPC::Info, XrdOfsTPC::inQ, XrdOfsTPCInfo::Key, XrdOfsTPC::Refs, XrdOfsTPCInfo::Reply(), SFS_ERROR, and SFS_OK.

Referenced by XrdOfsTPCProg::Run().

Here is the call graph for this function:

Here is the caller graph for this function:

Sync()

int XrdOfsTPCJob::Sync ( XrdOucErrInfo *  eRR )

virtual

Reimplemented from XrdOfsTPC.

Definition at line 144 of file XrdOfsTPCJob.cc.

{
   static const int cbWaitTime = 1800;
   XrdSysMutexHelper jobMon(&jobMutex);
   int               rc;
 
// If we are running then simply wait for the copy to complete
//
   if (Status == isRunning)
      {if (Info.SetCB(eRR)) return SFS_ERROR;
       eRR->setErrCode(cbWaitTime);
       Info.Engage();
       return SFS_STARTED;
      }
 
// If we are done then return what we have (this can't change)
//
   if (Status == isDone)
      {if (eCode) {eRR->setErrInfo(eCode, Info.Key); return SFS_ERROR;}
       return SFS_OK;
      }
 
// The only thing left is that we are an unstarted job, so try to start it.
//
   if (inQ) {myProg = 0; rc = 0;}
      else if ((myProg = XrdOfsTPCProg::Start(this, rc)))
              {Refs++; Status = isRunning; return SFS_OK;}
 
// We could not allocate a program to this job. Check if this is due to an err
//
   if (rc)
      {OfsEroute.Emsg("TPC", rc, "create tpc job thread");
       Status = isDone;
       eCode  = ECANCELED;
       if (Info.Key) free(Info.Key);
       Info.Key = strdup("Copy failed; resources unavailable.");
       return Info.Fail(eRR, "resources unavailable", ECANCELED);
      }
 
// No programs available, place this job in callback mode
//
   if (Info.SetCB(eRR)) return SFS_ERROR;
   if (jobLast) {jobLast->Next = this; jobLast = this;}
      else jobQ = jobLast = this;
   inQ = 1;
   eRR->setErrCode(cbWaitTime);
   Info.Engage();
   return SFS_STARTED;
}

References XrdSysError::Emsg(), XrdOfsTPCInfo::Engage(), XrdOfsTPCInfo::Fail(), XrdOfsTPC::Info, XrdOfsTPC::inQ, XrdOfsTPCInfo::Key, OfsEroute, XrdOfsTPC::Refs, XrdOfsTPCInfo::SetCB(), XrdOucErrInfo::setErrCode(), XrdOucErrInfo::setErrInfo(), SFS_ERROR, SFS_OK, SFS_STARTED, and XrdOfsTPCProg::Start().

Here is the call graph for this function:

---

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

• XrdOfsTPCJob.hh
• XrdOfsTPCJob.cc