XrdMpxOut Class Reference

Collaboration diagram for XrdMpxOut:

Classes
struct	statsBuff

Public Member Functions
	XrdMpxOut ()
	~XrdMpxOut ()
void	Add (statsBuff *sbP)
statsBuff *	getBuff ()
void *	Run (XrdMpxXml *xP)

Detailed Description

Definition at line 67 of file XrdMpxStats.cc.

---

Class Documentation

XrdMpxOut::statsBuff

struct XrdMpxOut::statsBuff

Definition at line 71 of file XrdMpxStats.cc.

Collaboration diagram for XrdMpxOut::statsBuff:

Class Members
char	Data[8190]
int	Dlen
XrdNetSockAddr	From
statsBuff *	Next
char	Pad[2]

Constructor & Destructor Documentation

XrdMpxOut()

XrdMpxOut::XrdMpxOut ( )

inline

Definition at line 85 of file XrdMpxStats.cc.

: Ready(0), inQ(0), Free(0) {}

~XrdMpxOut()

XrdMpxOut::~XrdMpxOut ( )

inline

Definition at line 86 of file XrdMpxStats.cc.

{}

Member Function Documentation

Add()

void XrdMpxOut::Add

(

statsBuff *

sbP

)

Definition at line 101 of file XrdMpxStats.cc.

{
 
// Add this to the queue and signal the processing thread
//
   myMutex.Lock();
   sbP->Next = inQ;
   inQ = sbP;
   Ready.Post();
   myMutex.UnLock();
}

References XrdMpxOut::statsBuff::Next.

Referenced by main().

Here is the caller graph for this function:

getBuff()

XrdMpxOut::statsBuff * XrdMpxOut::getBuff

(

)

Definition at line 117 of file XrdMpxStats.cc.

{
   statsBuff *sbP;
 
// Use an available buffer or allocate one
//
   myMutex.Lock();
   if ((sbP = Free)) Free = sbP->Next;
      else sbP = new statsBuff;
   myMutex.UnLock();
   return sbP;
}

References XrdMpxOut::statsBuff::Next.

Referenced by main().

Here is the caller graph for this function:

Run()

void * XrdMpxOut::Run

(

XrdMpxXml *

xP

)

Definition at line 134 of file XrdMpxStats.cc.

{
   XrdNetAddr theAddr;
   const char *Host = 0;
   char *bP, obuff[sizeof(statsBuff)*2];
   statsBuff *sbP;
   int wLen, rc;
 
// Simply loop formating and outputing the buffers
//
   while(1)
        {Ready.Wait();
         myMutex.Lock();
         if ((sbP = inQ)) inQ = sbP->Next;
         myMutex.UnLock();
         if (!sbP) continue;
         if (xP)
            {if (!(Opts & addSender)) Host = 0;
                else if (theAddr.Set(&(sbP->From.Addr))) Host = 0;
                        else Host = theAddr.Name();
             wLen = xP->Format(Host, sbP->Data, obuff);
             bP = obuff;
            } else {
             bP = sbP->Data;
             *(bP + sbP->Dlen) = '\n';
             wLen = sbP->Dlen+1;
            }
 
         while(wLen > 0)
              {do {rc = write(STDOUT_FILENO, bP, wLen);}
                  while(rc < 0 && errno == EINTR);
               wLen -= rc; bP += rc;
              }
 
         myMutex.Lock(); sbP->Next = Free; Free = sbP; myMutex.UnLock();
        }
 
// Should never get here
//
   return (void *)0;
}

References XrdMpx::addSender, XrdMpxXml::Format(), XrdNetAddrInfo::Name(), XrdMpxOut::statsBuff::Next, XrdMpx::Opts, XrdNetAddr::Set(), and write().

Referenced by mainOutput().

Here is the call graph for this function:

Here is the caller graph for this function:

---

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

• XrdMpxStats.cc