XrdOfsPoscq Class Reference

#include <XrdOfsPoscq.hh>

Collaboration diagram for XrdOfsPoscq:

Classes
struct	recEnt
struct	Request

Public Member Functions
	XrdOfsPoscq (XrdSysError *erp, XrdOss *oss, const char *fn, int sv=1)
	~XrdOfsPoscq ()
int	Add (const char *Tident, const char *Lfn, bool isNew)
int	Commit (const char *Lfn, int Offset)
int	Del (const char *Lfn, int Offset, int Unlink=0)
recEnt *	Init (int &Ok)
int	Num ()

Static Public Member Functions
static recEnt *	List (XrdSysError *Say, const char *theFN)

Static Public Attributes
static const int	ReqOffs = 64
static const int	ReqSize = sizeof(Request)

Detailed Description

Definition at line 41 of file XrdOfsPoscq.hh.

---

Class Documentation

XrdOfsPoscq::Request

struct XrdOfsPoscq::Request

Definition at line 45 of file XrdOfsPoscq.hh.

Collaboration diagram for XrdOfsPoscq::Request:

Class Members
long long	addT
char	LFN[1024]
char	Reserved[24]
char	User[288]

Constructor & Destructor Documentation

XrdOfsPoscq()

XrdOfsPoscq::XrdOfsPoscq	(	XrdSysError *	erp,
		XrdOss *	oss,
		const char *	fn,
		int	sv = 1
	)

Definition at line 53 of file XrdOfsPoscq.cc.

{
   eDest = erp;
   ossFS = oss;
   pocFN = strdup(fn);
   pocFD = -1;
   pocSZ = 0;
   pocIQ = 0;
   SlotList = SlotLust = 0;
 
   if (sv > 32767) sv = 32767;
      else if (sv < 0) sv = 0;
   pocWS = pocSV = sv-1;
}

~XrdOfsPoscq()

XrdOfsPoscq::~XrdOfsPoscq ( )

inline

Definition at line 80 of file XrdOfsPoscq.hh.

{}

Member Function Documentation

Add()

int XrdOfsPoscq::Add	(	const char *	Tident,
		const char *	Lfn,
		bool	isNew
	)

Definition at line 72 of file XrdOfsPoscq.cc.

{
   XrdSysMutexHelper myHelp(myMutex);
   std::map<std::string,int>::iterator it = pqMap.end();
   XrdOfsPoscq::Request tmpReq;
   struct stat Stat;
   FileSlot *freeSlot;
   int fP;
 
// Add is only called when file is to be created. Therefore, it must not exist
// unless it is being replaced typically due to a retry. If not being replaced
// then We need to check this to avoid deleting already created files.
// Otherwise, we need to see if the file is already in the queue to avoid it
// being deleted after the fact because it would be in the queue twice.
//
   if (!ossFS->Stat(Lfn, &Stat))
      {if (isNew) return -EEXIST;
       it = pqMap.find(std::string(Lfn));
       if (it != pqMap.end() && VerOffset(Lfn, it->second)) return it->second;
      }
 
// Construct the request
//
   tmpReq.addT = 0;
   strlcpy(tmpReq.LFN,  Lfn,    sizeof(tmpReq.LFN));
   strlcpy(tmpReq.User, Tident, sizeof(tmpReq.User));
   memset(tmpReq.Reserved, 0, sizeof(tmpReq.Reserved));
 
// Obtain a free slot
//
   if ((freeSlot = SlotList))
      {fP = freeSlot->Offset;
       SlotList = freeSlot->Next;
       freeSlot->Next = SlotLust;
       SlotLust = freeSlot;
      } else {fP = pocSZ; pocSZ += ReqSize;}
   pocIQ++;
 
// Write out the record
//
   if (!reqWrite((void *)&tmpReq, sizeof(tmpReq), fP))
      {eDest->Emsg("Add", Lfn, "not added to the persist queue.");
       myMutex.Lock(); pocIQ--; myMutex.UnLock();
       return -EIO;
      }
 
// Check if we update the map or simply add it to the map
//
   if (it != pqMap.end()) it->second = fP;
      else pqMap[std::string(Lfn)] = fP;
 
// Return the record offset
//
   return fP;
}

References XrdOfsPoscq::Request::addT, eDest, XrdSysError::Emsg(), XrdOfsPoscq::Request::LFN, XrdSysMutex::Lock(), ReqSize, XrdOfsPoscq::Request::Reserved, Stat, stat, XrdOss::Stat(), strlcpy(), XrdSysMutex::UnLock(), and XrdOfsPoscq::Request::User.

Referenced by XrdOfsFile::open().

Here is the call graph for this function:

Here is the caller graph for this function:

Commit()

int XrdOfsPoscq::Commit	(	const char *	Lfn,
		int	Offset
	)

Definition at line 132 of file XrdOfsPoscq.cc.

{
   long long addT = static_cast<long long>(time(0));
 
// Verify the offset it must be correct
//
   if (!VerOffset(Lfn, Offset)) return -EINVAL;
 
// Indicate the record is free
//
   if (!reqWrite((void *)&addT, sizeof(addT), Offset))
      {eDest->Emsg("Commit", Lfn, "not committed to the persist queue.");
       return -EIO;
      }
 
// Remove entry from the map and return
//
   myMutex.Lock();
   pqMap.erase(std::string(Lfn));
   myMutex.UnLock();
   return 0;
}

References eDest, XrdSysError::Emsg(), XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

Referenced by XrdOfsFile::open().

Here is the call graph for this function:

Here is the caller graph for this function:

Del()

int XrdOfsPoscq::Del	(	const char *	Lfn,
		int	Offset,
		int	Unlink = 0
	)

Definition at line 159 of file XrdOfsPoscq.cc.

{
   static int Zero = 0;
   FileSlot *freeSlot;
   int retc;
 
// Verify the offset it must be correct
//
   if (!VerOffset(Lfn, Offset)) return -EINVAL;
 
// Unlink the file if need be
//
   if (Unlink && (retc = ossFS->Unlink(Lfn)) && retc != -ENOENT)
      {eDest->Emsg("Del", retc, "remove", Lfn);
       return (retc < 0 ? retc : -retc);
      }
 
// Indicate the record is free
//
   if (!reqWrite((void *)&Zero, sizeof(Zero), Offset+offsetof(Request,LFN)))
      {eDest->Emsg("Del", Lfn, "not removed from the persist queue.");
       return -EIO;
      }
 
// Serialize and place this on the free queue
//
   myMutex.Lock();
   if ((freeSlot = SlotLust)) SlotLust = freeSlot->Next;
      else freeSlot = new FileSlot;
   freeSlot->Offset = Offset;
   freeSlot->Next   = SlotList;
   SlotList         = freeSlot;
   if (pocIQ > 0) pocIQ--;
 
// Remove item from the map
//
   pqMap.erase(std::string(Lfn));
   myMutex.UnLock();
 
// All done
//
   return 0;
}

References eDest, XrdSysError::Emsg(), XrdSysMutex::Lock(), XrdOss::Unlink(), and XrdSysMutex::UnLock().

Referenced by XrdOfsFile::close(), XrdOfsFile::open(), and XrdOfs::Unpersist().

Here is the call graph for this function:

Here is the caller graph for this function:

Init()

XrdOfsPoscq::recEnt * XrdOfsPoscq::Init

(

int &

Ok

)

Definition at line 207 of file XrdOfsPoscq.cc.

{
   static const int Mode = S_IRUSR|S_IWUSR|S_IRGRP|S_IROTH;
   Request     tmpReq;
   struct stat buf, Stat;
   recEnt     *First = 0;
   char        Buff[80];
   int         rc, Offs, numreq = 0;
 
// Assume we will fail
//
   Ok = 0;
 
// Open the file first in r/w mode
//
   if ((pocFD = XrdSysFD_Open(pocFN, O_RDWR|O_CREAT, Mode)) < 0)
      {eDest->Emsg("Init",errno,"open",pocFN);
       return 0;
      }
 
// Get file status
//
   if (fstat(pocFD, &buf)) {FailIni("stat"); return 0;}
 
// Check for a new file here
//
   if (buf.st_size < ReqSize)
      {pocSZ = ReqOffs;
       if (ftruncate(pocFD, ReqOffs)) FailIni("trunc");
          else Ok = 1;
       return 0;
      }
 
// Read the full file
//
   for (Offs = ReqOffs; Offs < buf.st_size; Offs += ReqSize)
       {do {rc = pread(pocFD, (void *)&tmpReq, ReqSize, Offs);}
           while(rc < 0 && errno == EINTR);
        if (rc < 0) {eDest->Emsg("Init",errno,"read",pocFN); return First;}
        if (*tmpReq.LFN == '\0'
        ||  ossFS->Stat(tmpReq.LFN, &Stat)
        ||  !(S_ISREG(Stat.st_mode) || !(Stat.st_mode & XRDSFS_POSCPEND))) continue;
        First = new recEnt(tmpReq, Stat.st_mode & S_IAMB, First); numreq++;
       }
 
// Now write out the file and return
//
   sprintf(Buff, " %d pending create%s", numreq, (numreq != 1 ? "s" : ""));
   eDest->Say("Init", Buff, " recovered from ", pocFN);
   if (ReWrite(First)) Ok = 1;
   return First;
}

References eDest, XrdSysError::Emsg(), fstat, ftruncate, XrdOfsPoscq::Request::LFN, Mode, pread, ReqOffs, ReqSize, S_IAMB, XrdSysError::Say(), Stat, stat, XrdOss::Stat(), and XRDSFS_POSCPEND.

Here is the call graph for this function:

List()

XrdOfsPoscq::recEnt * XrdOfsPoscq::List ( XrdSysError *  Say, const char *  theFN  )

static

Definition at line 264 of file XrdOfsPoscq.cc.

{
   XrdOfsPoscq::Request tmpReq;
   struct stat buf;
   recEnt *First = 0;
   int    rc, theFD, Offs;
 
// Open the file first in r/o mode
//
   if ((theFD = XrdSysFD_Open(theFN, O_RDONLY)) < 0)
      {Say->Emsg("Init",errno,"open",theFN);
       return 0;
      }
 
// Get file status
//
   if (fstat(theFD, &buf))
      {Say->Emsg("Init",errno,"stat",theFN);
       close(theFD);
       return 0;
      }
   if (buf.st_size < ReqSize) buf.st_size = 0;
 
// Read the full file
//
   for (Offs = ReqOffs; Offs < buf.st_size; Offs += ReqSize)
       {do {rc = pread(theFD, (void *)&tmpReq, ReqSize, Offs);}
           while(rc < 0 && errno == EINTR);
        if (rc < 0) {Say->Emsg("List",errno,"read",theFN);
                     close(theFD); return First;
                    }
        if (*tmpReq.LFN != '\0') First = new recEnt(tmpReq, 0, First);
       }
 
// All done
//
   close(theFD);
   return First;
}

References close, fstat, XrdOfsPoscq::Request::LFN, pread, ReqOffs, ReqSize, Say, and stat.

Num()

int XrdOfsPoscq::Num ( )

inline

Definition at line 76 of file XrdOfsPoscq.hh.

{return pocIQ;}

Member Data Documentation

ReqOffs

const int XrdOfsPoscq::ReqOffs = 64

static

Definition at line 53 of file XrdOfsPoscq.hh.

Referenced by Init(), and List().

ReqSize

const int XrdOfsPoscq::ReqSize = sizeof(Request)

static

Definition at line 54 of file XrdOfsPoscq.hh.

Referenced by Add(), Init(), and List().

---

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

• XrdOfsPoscq.hh
• XrdOfsPoscq.cc