XrdOssArcStopMon Class Reference

#include <XrdOssArcStopMon.hh>

Inheritance diagram for XrdOssArcStopMon:

Collaboration diagram for XrdOssArcStopMon:

Public Member Functions
	XrdOssArcStopMon (const char *apath, int chkT, bool &aOK)
	XrdOssArcStopMon (const XrdOssArcStopMon &other)=delete
	XrdOssArcStopMon (XrdOssArcStopMon *parent)
virtual	~XrdOssArcStopMon ()
void	Activate ()
void	Deactivate ()
virtual void	DoIt () override
XrdOssArcStopMon &	operator= (const XrdOssArcStopMon &)=delete
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Additional Inherited Members
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob

Detailed Description

Definition at line 42 of file XrdOssArcStopMon.hh.

Constructor & Destructor Documentation

XrdOssArcStopMon() [1/3]

XrdOssArcStopMon::XrdOssArcStopMon	(	const char *	apath,
		int	chkT,
		bool &	aOK )

Definition at line 65 of file XrdOssArcStopMon.cc.

                                  : XrdJob("StopMon"),
                                    xsLock(*(new XrdSysXSLock())),
                                    admPath(aPath), chkInterval(chkT)
{
// Tty to open the admin path. This is where the STOP file should appear and
// where we plce the IDLE file once we have safely stopped all the archiving
// and restores.
//
   if ((admDirFD = XrdSysFD_Open(aPath,  O_DIRECTORY|O_RDONLY)) < 0)
      {Elog.Emsg("Config", errno, "open admin path", aPath);
       aOK = false;
       return;
      }
 
// Remove any idle file left over from previous run
//
   if (unlinkat(admDirFD, IdleFN, 0) && errno != ENOENT)
      {Elog.Emsg("Config", errno, "remove IDLE file in admin path", aPath);
       aOK = false;
       close(admDirFD);
       admDirFD = -1;
       return;
      }
 
// Now schedule ourselves to see if a stop file appears
//
   schedP->Schedule(this, time(0)+chkT);
 
// All done
//
   aOK = true;
}

References XrdJob::XrdJob(), close, XrdOssArcGlobals::Elog, XrdOssArcGlobals::IdleFN, and XrdOssArcGlobals::schedP.

Referenced by XrdOssArcStopMon(), XrdOssArcStopMon(), and operator=().

Here is the call graph for this function:

Here is the caller graph for this function:

XrdOssArcStopMon() [2/3]

XrdOssArcStopMon::XrdOssArcStopMon ( XrdOssArcStopMon * parent )

inline

Definition at line 68 of file XrdOssArcStopMon.hh.

                                                    : xsLock(parent->xsLock),
                          admPath(0), admDirFD(-1), isActive(true)
                         {xsLock.Lock(xs_Shared);}

References XrdOssArcStopMon(), parent(), and xs_Shared.

Here is the call graph for this function:

~XrdOssArcStopMon()

XrdOssArcStopMon::~XrdOssArcStopMon ( )

virtual

Definition at line 103 of file XrdOssArcStopMon.cc.

{
// Parent instances of this class may not be destroyed. A parent instance
// is indicated by admDirFD being non-negative.
//
   if (admDirFD >= 0)
      {Elog.Emsg("StopMon", "Invalid deletion of StopMon parent instance for",
                            admPath);
       std::abort();
      }
 
// We are not a parent, release the lock since the constructor obtained it.
//
   Deactivate();
}

References Deactivate(), and XrdOssArcGlobals::Elog.

Here is the call graph for this function:

XrdOssArcStopMon() [3/3]

XrdOssArcStopMon::XrdOssArcStopMon ( const XrdOssArcStopMon & other )

delete

References XrdOssArcStopMon().

Here is the call graph for this function:

Member Function Documentation

Activate()

void XrdOssArcStopMon::Activate ( )

inline

Definition at line 53 of file XrdOssArcStopMon.hh.

{if (!isActive.exchange(true)) xsLock.Lock(xs_Shared);}

References xs_Shared.

Referenced by XrdOssArcBackupTask::BkpXeq().

Here is the caller graph for this function:

Deactivate()

void XrdOssArcStopMon::Deactivate ( )

inline

Definition at line 57 of file XrdOssArcStopMon.hh.

                           {if (isActive.exchange(false))
                               xsLock.UnLock(xs_Shared);
                           }

References xs_Shared.

Referenced by ~XrdOssArcStopMon(), and XrdOssArcBackupTask::BkpXeq().

Here is the caller graph for this function:

DoIt()

void XrdOssArcStopMon::DoIt ( )

overridevirtual

Implements XrdJob.

Definition at line 123 of file XrdOssArcStopMon.cc.

{
   static const mode_t idleMode = S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH;
   static const int    idleOflg = O_CREAT | O_RDWR  | O_CLOEXEC;
   struct stat Stat;
 
// This method is only valid for the parent class.
//
   if (admDirFD < 0)
      {Elog.Emsg("StopMon","Invalid DoIt() call on child instance for",admPath);
       return;
      }
 
// Check if a STOP file exists in the admpath. If it does, try to obtain a
// write lock. Only one thread may it and when we get it we know no other
// threads are actively executing a backup or restore. Once we have it,
// Issue a message and create an IDLE file.
//
   if (fstatat(admDirFD, StopFN, &Stat, 0) == 0)
      {Elog.Emsg("StopMon", "STOP file found in", admPath);
       xsLock.Lock(xs_Exclusive);
       Elog.Emsg("StopMon", "Drain complete; entering idle state...");
       int iFD = openat(admDirFD, IdleFN, idleOflg, idleMode);
       if (iFD < 0) Elog.Emsg("StopMon",errno,"create IDLE file in",admPath);
          else close(iFD);
       do {XrdSysTimer::Snooze(10);} while(!fstatat(admDirFD,StopFN,&Stat,0));
       unlinkat(admDirFD, IdleFN, 0);
       xsLock.UnLock(xs_Exclusive);
       Elog.Emsg("StopMon", "Resuming execution; STOP file removed!");
      }
 
// Reschedule ourselves
//
   schedP->Schedule(this, time(0)+chkInterval);
}

References close, XrdOssArcGlobals::Elog, XrdOssArcGlobals::IdleFN, XrdOssArcGlobals::schedP, XrdSysTimer::Snooze(), Stat, stat, XrdOssArcGlobals::StopFN, and xs_Exclusive.

Here is the call graph for this function:

operator=()

XrdOssArcStopMon & XrdOssArcStopMon::operator= ( const XrdOssArcStopMon & )

delete

References XrdOssArcStopMon().

Here is the call graph for this function:

---

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

• XrdOssArcStopMon.hh
• XrdOssArcStopMon.cc