XrdOfsEvr Class Reference

#include <XrdOfsEvr.hh>

Collaboration diagram for XrdOfsEvr:

Classes
class	theClient
struct	theEvent

Public Member Functions
	XrdOfsEvr ()
	~XrdOfsEvr ()
void	flushEvents ()
int	Init (XrdCmsClient *trg=0)
int	Init (XrdSysError *eObj)
void	recvEvents ()
void	Wait4Event (const char *path, XrdOucErrInfo *einfo)
void	Work4Event (theClient *Client)

Detailed Description

Definition at line 42 of file XrdOfsEvr.hh.

Constructor & Destructor Documentation

XrdOfsEvr()

XrdOfsEvr::XrdOfsEvr ( )

inline

Definition at line 59 of file XrdOfsEvr.hh.

: mySem(0), eDest(0), Balancer(0) {runQ = 0; deferQ = 0;}

Referenced by XrdOfsEvr::theClient::theClient().

Here is the caller graph for this function:

~XrdOfsEvr()

XrdOfsEvr::~XrdOfsEvr

(

)

Definition at line 75 of file XrdOfsEvr.cc.

{
 
// Close the FIFO. This will cause the reader to exit
//
   myMutex.Lock();
   eventFIFO.Close();
   myMutex.UnLock();
}

Member Function Documentation

flushEvents()

void XrdOfsEvr::flushEvents

(

)

Definition at line 89 of file XrdOfsEvr.cc.

{
   theClient *tp, *ntp;
   int expWait, expClock;
 
// Compute the hash flush interval
//
   if ((expWait = maxLife/4) == 0) expWait = 60;
   expClock = expWait;
 
// We wait for the right period of time, unless there is a deferred event
//
   do {myMutex.Lock(); 
       if ((ntp = deferQ)) deferQ = 0;
          else runQ = 0;
       myMutex.UnLock();
       while(ntp)
            {XrdSysTimer::Wait(1000*60);
             expClock -= 60;
             myMutex.Lock();
             while((tp = ntp))
                  {Events.Del(tp->Path);
                   ntp = tp->Next;
                   delete tp;
                  }
             if ((ntp = deferQ)) deferQ = 0;
                else runQ = 0;
             myMutex.UnLock();
             if (expClock <= 0)
                {myMutex.Lock(); 
                 Events.Apply(XrdOfsScrubScan, (void *)0);
                 myMutex.UnLock();
                 expClock = expWait;
                }
            }
       mySem.Wait();
      } while(1);
}

References XrdOfsEvr::theClient::Next, XrdOfsEvr::theClient::Path, XrdSysTimer::Wait(), and XrdOfsScrubScan().

Referenced by XrdOfsEvFlush().

Here is the call graph for this function:

Here is the caller graph for this function:

Init() [1/2]

int XrdOfsEvr::Init

(

XrdCmsClient *

trg = 0

)

Definition at line 167 of file XrdOfsEvr.cc.

{
   pthread_t     tid;
   int rc;
 
// Set the balancer pointers (err object set in 1st phase Init).
//
   Balancer = trgp;
 
// Now start a thread to get incoming messages
//
   if ((rc = XrdSysThread::Run(&tid, XrdOfsEvRecv, static_cast<void *>(this),
                          0, "Event receiver")))
      {eDest->Emsg("Evr", rc, "create event reader thread");
       return 0;
      }
 
// Now start a thread to flush posted events
//
   if ((rc = XrdSysThread::Run(&tid, XrdOfsEvFlush,static_cast<void *>(this),
                          0, "Event flusher")))
      {eDest->Emsg("Evr", rc, "create event flush thread");
       return 0;
      }
 
// All done
//
   return 1;
}

References XrdSysThread::Run(), XrdOfsEvFlush(), and XrdOfsEvRecv().

Here is the call graph for this function:

Init() [2/2]

int XrdOfsEvr::Init

(

XrdSysError *

eObj

)

Definition at line 132 of file XrdOfsEvr.cc.

{
   XrdNetSocket *msgSock;
   char *p, path[2048];
   int n;
 
// Set he error object (need to do only once)
//
   eDest    = eobj;
 
// Create path to the pipe we will creat
//
   if (!(p = getenv("XRDADMINPATH")) || !*p)
      {eobj->Emsg("Events", "XRDADMINPATH not defined");
       return 0;
      }
   strcpy(path, p); n = strlen(p);
   if (path[n-1] != '/') {path[n] = '/'; n++;}
   strcpy(&path[n], "ofsEvents");
   XrdOucEnv::Export("XRDOFSEVENTS", path);
 
// Now create a socket to a path
//
   if (!(msgSock = XrdNetSocket::Create(eobj,path,0,0660,XRDNET_FIFO)))
      return 0;
   msgFD = msgSock->Detach();
   delete msgSock;
 
// We succeeded and are now ready for the call to he second stage below
//
   return 1;
}

References XrdNetSocket::Create(), XrdNetSocket::Detach(), XrdSysError::Emsg(), XrdOucEnv::Export(), and XRDNET_FIFO.

Here is the call graph for this function:

recvEvents()

void XrdOfsEvr::recvEvents

(

)

Definition at line 201 of file XrdOfsEvr.cc.

{
   EPNAME("recvEvent");
   const char *tident = 0;
   char *lp,*tp;
 
// Attach the fifo FD to the stream
//
   eventFIFO.Attach(msgFD);
 
// Now just start reading the events until the FD is closed
//
   while((lp = eventFIFO.GetLine()))
        {DEBUG("-->" <<lp);
         if ((tp = eventFIFO.GetToken()) && *tp)
            {if (!strcmp(tp, "stage")) eventStage();
                else eDest->Emsg("Evr", "Unknown event name -", tp);
            }
        }
}

References DEBUG, EPNAME, and tident.

Referenced by XrdOfsEvRecv().

Here is the caller graph for this function:

Wait4Event()

void XrdOfsEvr::Wait4Event	(	const char *	path,
		XrdOucErrInfo *	einfo )

Definition at line 226 of file XrdOfsEvr.cc.

{
 
// Replace original callback with our callback so we can queue this event
// after the wait request has been sent to the client. This avoids a race
// where the client might get the resume signal before the wait request.
//
   einfo->setErrCB((XrdOucEICB *)new theClient(this, einfo, path));
}

References XrdOucErrInfo::setErrCB().

Here is the call graph for this function:

Work4Event()

void XrdOfsEvr::Work4Event

(

theClient *

Client

)

Definition at line 240 of file XrdOfsEvr.cc.

{
   struct theEvent *anEvent;
   theClient *aClient = 0;
 
// First ste is to see if this event was posted
//
   myMutex.Lock();
   if (!(anEvent = Events.Find(Client->Path)))
      Events.Add(Client->Path, new theEvent(0, 0, Client), maxLife);
      else {aClient = anEvent->aClient;
            while(aClient)
                 {if (aClient->evtCB->Same(Client->evtCBarg,aClient->evtCBarg))
                     {aClient->evtCBarg = Client->evtCBarg;
                      break;
                     }
                  aClient = aClient->Next;
                 }
            if (!aClient) {Client->Next = anEvent->aClient;
                           anEvent->aClient = Client;
                          }
            if (anEvent->Happened) sendEvent(anEvent);
           }
   myMutex.UnLock();
 
// Delete the Client object if we really don't need it
//
   if (aClient) delete Client;
}

References XrdOfsEvr::theEvent::aClient, XrdOfsEvr::theClient::evtCB, XrdOfsEvr::theClient::evtCBarg, XrdOfsEvr::theEvent::Happened, XrdOfsEvr::theClient::Next, XrdOfsEvr::theClient::Path, and XrdOucEICB::Same().

Here is the call graph for this function:

---

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

• XrdOfsEvr.hh
• XrdOfsEvr.cc