#include <XrdStats.hh>

Collaboration diagram for XrdStats:

Classes
class	CallBack

Public Member Functions
	XrdStats (XrdSysError eP, XrdScheduler sP, XrdBuffManager bP, const char hn, int port, const char in, const char pn, const char *sn)

virtual	~XrdStats ()

void	Report (char **Dest=0, int iVal=600, int Opts=0)

virtual void	Stats (CallBack *InfoBack, int opts)

Detailed Description

Definition at line 51 of file XrdStats.hh.

Constructor & Destructor Documentation

◆ XrdStats()

XrdStats::XrdStats	(	XrdSysError *	eP,
		XrdScheduler *	sP,
		XrdBuffManager *	bP,
		const char *	hn,
		int	port,
		const char *	in,
		const char *	pn,
		const char *	sn
	)

Definition at line 80 of file XrdStats.cc.

{
   static const char *head =
          "<statistics tod=\"%%ld\" ver=\"" XrdVERSION "\" src=\"%s:%d\" "
                      "tos=\"%ld\" pgm=\"%s\" ins=\"%s\" pid=\"%d\" "
                      "site=\"%s\">";
   char myBuff[1024];
 
   XrdLog   = eP;
   XrdSched = sP;
   BuffPool = bP;
 
   Hlen = sprintf(myBuff, head, hname, port, tBoot, pname, iname,
                          static_cast<int>(getpid()), (site ? site : ""));
   Head = strdup(myBuff);
   buff = 0;
   blen = 0;
   myHost = hname;
   myName = iname;
   myPort = port;
}

◆ ~XrdStats()

virtual XrdStats::~XrdStats ( )

inlinevirtual

Definition at line 70 of file XrdStats.hh.

70{if (buff) free(buff);}

Member Function Documentation

◆ Report()

void XrdStats::Report	(	char **	Dest = `0`,
		int	iVal = `600`,
		int	Opts = `0`
	)

Definition at line 108 of file XrdStats.cc.

{
   static XrdNetMsg *netDest[2] = {0,0};
   static int autoSync, repOpts = Opts;
   const char *Data;
          int theOpts, Dlen;
 
// If we have dest then this is for initialization
//
   if (Dest)
   // Establish up to two destinations
   //
      {if (Dest[0]) netDest[0] = new XrdNetMsg(XrdLog, Dest[0]);
       if (Dest[1]) netDest[1] = new XrdNetMsg(XrdLog, Dest[1]);
       if (!(repOpts & XRD_STATS_ALL)) repOpts |= XRD_STATS_ALL;
       autoSync = repOpts & XRD_STATS_SYNCA;
 
   // Get and schedule a new job to report
   //
      if (netDest[0]) new XrdStatsJob(XrdSched, this, iVal);
       return;
      }
 
// This is a re-entry for reporting purposes, establish the sync flag
//
   if (!autoSync || XrdSched->Active() <= 30) theOpts = repOpts;
      else theOpts = repOpts & ~XRD_STATS_SYNC;
 
// Now get the statistics
//
   statsMutex.Lock();
   if ((Data = GenStats(Dlen, theOpts)))
      {netDest[0]->Send(Data, Dlen);
       if (netDest[1]) netDest[1]->Send(Data, Dlen);
      }
   statsMutex.UnLock();
}

References XrdScheduler::Active(), XrdSysMutex::Lock(), XrdNetMsg::Send(), XrdSysMutex::UnLock(), XRD_STATS_ALL, and XRD_STATS_SYNCA.

Referenced by XrdStatsJob::DoIt().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Stats()

void XrdStats::Stats	(	XrdStats::CallBack *	cbP,
		int	opts
	)

virtual

Definition at line 150 of file XrdStats.cc.

{
   const char *info;
   int sz;
 
// Lock the buffer,
//
   statsMutex.Lock();
 
// Obtain the stats, if we have some, do the callback
//
   if ((info = GenStats(sz, opts))) cbP->Info(info, sz);
 
// Unlock the buffer
//
   statsMutex.UnLock();
}

References XrdStats::CallBack::Info(), XrdSysMutex::Lock(), opts, and XrdSysMutex::UnLock().

Referenced by XrdXrootdStats::Stats().