XrdCmsRespQ Class Reference

#include <XrdCmsResp.hh>

Collaboration diagram for XrdCmsRespQ:

Public Member Functions
	XrdCmsRespQ ()
	~XrdCmsRespQ ()
void	Add (XrdCmsResp *rp)
void	Purge ()
XrdCmsResp *	Rem (int msgid)

Detailed Description

Definition at line 123 of file XrdCmsResp.hh.

Constructor & Destructor Documentation

XrdCmsRespQ()

XrdCmsRespQ::XrdCmsRespQ

(

)

Definition at line 241 of file XrdCmsResp.cc.

{
   memset(mqTab, 0, sizeof(mqTab));
}

~XrdCmsRespQ()

XrdCmsRespQ::~XrdCmsRespQ ( )

inline

Definition at line 133 of file XrdCmsResp.hh.

{Purge();}

References Purge().

Here is the call graph for this function:

Member Function Documentation

Add()

void XrdCmsRespQ::Add

(

XrdCmsResp *

rp

)

Definition at line 250 of file XrdCmsResp.cc.

{
   int i;
 
// Compute index and either add or chain the entry
//
   i = rp->myID % mqSize;
   myMutex.Lock();
   rp->next = (mqTab[i] ? mqTab[i] : 0);
   mqTab[i] = rp;
   myMutex.UnLock();
}

References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

Referenced by XrdCmsClientMan::delayResp().

Here is the call graph for this function:

Here is the caller graph for this function:

Purge()

void XrdCmsRespQ::Purge

(

)

Definition at line 267 of file XrdCmsResp.cc.

{
   XrdCmsResp *rp;
   int i;
 
   myMutex.Lock();
   for (i = 0; i < mqSize; i++)
       {while ((rp = mqTab[i])) {mqTab[i] = rp->next; delete rp;}}
   myMutex.UnLock();
}

References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

Referenced by ~XrdCmsRespQ(), and XrdCmsClientMan::delayResp().

Here is the call graph for this function:

Here is the caller graph for this function:

Rem()

XrdCmsResp * XrdCmsRespQ::Rem

(

int

msgid

)

Definition at line 282 of file XrdCmsResp.cc.

{
   int i;
   XrdCmsResp *rp, *pp = 0;
 
// Compute the index and find the entry
//
   i = msgid % mqSize;
   myMutex.Lock();
   rp = mqTab[i];
   while(rp && rp->myID != msgid) {pp = rp; rp = rp->next;}
 
// Remove the entry if we found it
//
   if (rp) {if (pp) pp->next = rp->next;
               else mqTab[i] = rp->next;
           }
 
// Return what we found
//
   myMutex.UnLock();
   return rp;
}

References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().

Here is the call graph for this function:

---

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

• XrdCmsResp.hh
• XrdCmsResp.cc