XrdXrootdPgwFob Class Reference

#include <XrdXrootdPgwFob.hh>

Collaboration diagram for XrdXrootdPgwFob:

Public Member Functions
	XrdXrootdPgwFob (XrdXrootdFile *fP)
	~XrdXrootdPgwFob ()
bool	addOffs (kXR_int64 foffs, int dlen)
bool	delOffs (kXR_int64 foffs, int dlen)
bool	hasOffs (kXR_int64 foffs, int dlen)
int	numOffs (int *errs=0, int *fixs=0)

Detailed Description

Definition at line 41 of file XrdXrootdPgwFob.hh.

Constructor & Destructor Documentation

XrdXrootdPgwFob()

XrdXrootdPgwFob::XrdXrootdPgwFob ( XrdXrootdFile * fP )

inline

Definition at line 77 of file XrdXrootdPgwFob.hh.

                                : fileP(fP), numErrs(0), numFixd(0) {}

~XrdXrootdPgwFob()

XrdXrootdPgwFob::~XrdXrootdPgwFob

(

)

Definition at line 56 of file XrdXrootdPgwFob.cc.

{
   int len, n = badOffs.size();
 
// Write an error message if this file has any outstanding checksum errors
//
   if (n)
      {char buff[128];
       snprintf(buff, sizeof(buff), "Warning! %d checksum error(s) in", n);
       eLog.Emsg("PgwFob", buff, fileP->FileKey);
      }
 
// Check if we have anything to do and if we do, dump the list of bad checksums.
//
   if (TRACING(TRACE_PGCS))
      {const char *TraceID = "FileFob", *fname = fileP->FileKey;
       if (n)
          {XrdOucString lolist((1+4+1+13)*n);
           char item[128];
           kXR_int64 val;
 
           for (std::set<kXR_int64>::iterator it =  badOffs.begin();
                                              it != badOffs.end(); ++it)
               {val = *it;
                len = val & (XrdProto::kXR_pgPageSZ-1);
                if (!len) len = XrdProto::kXR_pgPageSZ;
                val = val >> XrdProto::kXR_pgPageBL;
                snprintf(item, sizeof(item), " %d@%lld", len, val);
                lolist += item;
               }
           TRACEI(PGCS,fname<<" had "<<numErrs<<" cksum errs and "<<numFixd
                            <<" fixes"<<"; areas in error:"<<lolist.c_str());
          } else if (numErrs)
                    {TRACEI(PGCS,fname<<" had "<<numErrs<<" cksum errs and "
                                      <<numFixd<<" fixes.");
                    }
      }
}

References XrdOucString::c_str(), XrdXrootd::eLog, XrdSysError::Emsg(), TRACE_PGCS, TRACEI, and TRACING.

Here is the call graph for this function:

Member Function Documentation

addOffs()

bool XrdXrootdPgwFob::addOffs ( kXR_int64 foffs, int dlen )

inline

Definition at line 46 of file XrdXrootdPgwFob.hh.

                        {XrdSysMutexHelper mHelp(fobMutex);
                         foffs = foffs << XrdProto::kXR_pgPageBL;
                         if (dlen < XrdProto::kXR_pgPageSZ) foffs |= dlen;
                         badOffs.insert(foffs);
                         numErrs++;
                         return badOffs.size() <= XrdProto::kXR_pgMaxEos;
                        }

Referenced by XrdXrootdPgwBadCS::boAdd().

Here is the caller graph for this function:

delOffs()

bool XrdXrootdPgwFob::delOffs ( kXR_int64 foffs, int dlen )

inline

Definition at line 55 of file XrdXrootdPgwFob.hh.

                        {XrdSysMutexHelper mHelp(fobMutex);
                         foffs = foffs << XrdProto::kXR_pgPageBL;
                         if (dlen < XrdProto::kXR_pgPageSZ) foffs |= dlen;
                         numFixd++;
                         return badOffs.erase(foffs) != 0;
                        }

hasOffs()

bool XrdXrootdPgwFob::hasOffs ( kXR_int64 foffs, int dlen )

inline

Definition at line 63 of file XrdXrootdPgwFob.hh.

                        {XrdSysMutexHelper mHelp(fobMutex);
                         foffs = foffs << XrdProto::kXR_pgPageBL;
                         if (dlen < XrdProto::kXR_pgPageSZ) foffs |= dlen;
                         return badOffs.find(foffs) != badOffs.end();
                        }

numOffs()

int XrdXrootdPgwFob::numOffs ( int * errs = 0, int * fixs = 0 )

inline

Definition at line 70 of file XrdXrootdPgwFob.hh.

                        {XrdSysMutexHelper mHelp(fobMutex);
                         if (errs) *errs = numErrs;
                         if (fixs) *fixs = numFixd;
                         return badOffs.size();
                        }

Referenced by XrdXrootdPgwBadCS::boAdd().

Here is the caller graph for this function:

---

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

• XrdXrootdPgwFob.hh
• XrdXrootdPgwFob.cc