XrdSsiEvent Class Reference

#include <XrdSsiEvent.hh>

Inheritance diagram for XrdSsiEvent:

Collaboration diagram for XrdSsiEvent:

Public Member Functions
	XrdSsiEvent ()
	~XrdSsiEvent ()
void	AddEvent (XrdCl::XRootDStatus *st, XrdCl::AnyObject *resp)
void	ClrEvent ()
virtual void	DoIt ()
virtual void	HandleResponse (XrdCl::XRootDStatus *status, XrdCl::AnyObject *response)
virtual int	XeqEvent (XrdCl::XRootDStatus *st, XrdCl::AnyObject **resp)=0
virtual void	XeqEvFin ()=0
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()
Public Member Functions inherited from XrdCl::ResponseHandler
virtual	~ResponseHandler ()
virtual void	HandleResponseWithHosts (XRootDStatus *status, AnyObject *response, HostList *hostList)

Protected Attributes
char	tident [24]

Additional Inherited Members
Static Public Member Functions inherited from XrdCl::ResponseHandler
static ResponseHandler *	Wrap (std::function< void(XRootDStatus &, AnyObject &)> func)
static ResponseHandler *	Wrap (std::function< void(XRootDStatus *, AnyObject *)> func)
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob

Detailed Description

Definition at line 36 of file XrdSsiEvent.hh.

Constructor & Destructor Documentation

XrdSsiEvent()

XrdSsiEvent::XrdSsiEvent ( )

inline

Definition at line 54 of file XrdSsiEvent.hh.

                           : XrdJob(tident),  lastEvent(0),
                             running(false),  isClear(true)
                             {*tident = 0;}

References XrdJob::XrdJob(), and tident.

Here is the call graph for this function:

~XrdSsiEvent()

XrdSsiEvent::~XrdSsiEvent ( )

inline

Definition at line 58 of file XrdSsiEvent.hh.

{if (!isClear) ClrEvent(&thisEvent);}

References ClrEvent().

Here is the call graph for this function:

Member Function Documentation

AddEvent()

void XrdSsiEvent::AddEvent	(	XrdCl::XRootDStatus *	st,
		XrdCl::AnyObject *	resp )

Definition at line 56 of file XrdSsiEvent.cc.

{
   EPNAME("AddEvent");
   XrdSsiMutexMon monMutex(evMutex);
 
// Indicate there is pending event here
//
   DEBUG("New event: isClear=" <<isClear <<" running=" <<running);
   isClear = false;
 
// If the base object has no status then we need to set it and schedule
// ourselves for processing if not already running.
//
   if (!thisEvent.status)
      {thisEvent.status   = st;
       thisEvent.response = resp;
       if (!running)
          {running = true;
           XrdSsi::schedP->Schedule(this);
          }
       return;
      }
 
// Allocate a new event object and chain it from the base event. This also
// implies that we doesn't need to be scheduled as it already was scheduled.
//
   frMutex.Lock();
   EventData *edP = freeEvent;
   if (!edP) edP = new EventData(st, resp);
      else {freeEvent     = edP->next;
            edP->status   = st;
            edP->response = resp;
            edP->next     = 0;
           }
   frMutex.UnLock();
 
// Establish the last event
//
   if (lastEvent) lastEvent->next = edP;
      else        thisEvent .next = edP;
   lastEvent = edP;
}

References DEBUG, EPNAME, and XrdSsi::schedP.

Referenced by HandleResponse().

Here is the caller graph for this function:

ClrEvent()

void XrdSsiEvent::ClrEvent ( )

inline

Definition at line 42 of file XrdSsiEvent.hh.

{evMutex.Lock();ClrEvent(&thisEvent);evMutex.UnLock();}

References ClrEvent().

Referenced by ~XrdSsiEvent(), ClrEvent(), DoIt(), and XrdSsiServReal::Recycle().

Here is the call graph for this function:

Here is the caller graph for this function:

DoIt()

void XrdSsiEvent::DoIt ( )

virtual

Implements XrdJob.

Definition at line 148 of file XrdSsiEvent.cc.

{
   EPNAME("RunEvent");
   EventData *edP, myEvent;
   int rc;
 
// Process all of the events in our list. This is a tricky proposition because
// the event executor may delete us upon return. Hence we do not directly use
// any data members of this class, only copies. The return rc tells what to do.
// rc > 0: terminate event processing and conclude in a normal fashion.
// rc = 0: reflect next event.
// rc < 0: immediately return as this object has become invalid.
//
   evMutex.Lock();
do{thisEvent.Move2(myEvent);
   lastEvent = 0;
   isClear   = true;
   evMutex.UnLock();
   edP = &myEvent;
 
   do {if ((rc = XeqEvent(edP->status, &edP->response)) != 0) break;
       edP = edP->next;
      } while(edP);
 
   ClrEvent(&myEvent);
 
   if (rc)
      {DEBUG("XeqEvent requested " <<(rc < 0 ? "halt" : "flush"));
       if (rc < 0) return;
       evMutex.Lock();
       break;
      }
 
   evMutex.Lock();
  } while(thisEvent.status);
 
// Indicate we are no longer running
//
   running = false;
   evMutex.UnLock();
 
// The last thing we need to do is to tell the event handler that we are done
// as it may decide to delete this object if no more events will occur.
//
   XeqEvFin();
}

References ClrEvent(), DEBUG, EPNAME, XeqEvent(), and XeqEvFin().

Here is the call graph for this function:

HandleResponse()

virtual void XrdSsiEvent::HandleResponse ( XrdCl::XRootDStatus * status, XrdCl::AnyObject * response )

inlinevirtual

Called when a response to associated request arrives or an error occurs

Parameters

status	status of the request
response	an object associated with the response (request dependent)

Reimplemented from XrdCl::ResponseHandler.

Definition at line 46 of file XrdSsiEvent.hh.

                           {AddEvent(status, response);}

References AddEvent().

Here is the call graph for this function:

XeqEvent()

virtual int XrdSsiEvent::XeqEvent ( XrdCl::XRootDStatus * st, XrdCl::AnyObject ** resp )

pure virtual

Implemented in XrdSsiSessReal, and XrdSsiTaskReal.

Referenced by DoIt().

Here is the caller graph for this function:

XeqEvFin()

virtual void XrdSsiEvent::XeqEvFin ( )

pure virtual

Implemented in XrdSsiSessReal, and XrdSsiTaskReal.

Referenced by DoIt().

Here is the caller graph for this function:

Member Data Documentation

tident

char XrdSsiEvent::tident[24]

protected

Definition at line 62 of file XrdSsiEvent.hh.

Referenced by XrdSsiEvent(), XrdSsiSessReal::InitSession(), and XrdSsiTaskReal::SetTaskID().

---

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

• XrdSsiEvent.hh
• XrdSsiEvent.cc