XrdFrmPurgMain.cc File Reference

#include <unistd.h>
#include <cctype>
#include <cerrno>
#include <cstdlib>
#include <cstring>
#include <strings.h>
#include <cstdio>
#include <sys/param.h>
#include "XrdFrc/XrdFrcTrace.hh"
#include "XrdFrm/XrdFrmConfig.hh"
#include "XrdFrm/XrdFrmPurge.hh"
#include "XrdNet/XrdNetOpts.hh"
#include "XrdNet/XrdNetSocket.hh"
#include "XrdOuc/XrdOucUtils.hh"
#include "XrdSys/XrdSysError.hh"
#include "XrdSys/XrdSysHeaders.hh"
#include "XrdSys/XrdSysLogger.hh"
#include "XrdSys/XrdSysPthread.hh"
#include "XrdSys/XrdSysTimer.hh"
#include "XrdSys/XrdSysUtils.hh"

Include dependency graph for XrdFrmPurgMain.cc:

Go to the source code of this file.

Functions
int	main (int argc, char *argv[])
int	mainConfig ()
void *	mainServer (void *parg)

Variables
XrdOucTrace XrdTrace &	Say
static const char *	XrdFrmOpts = ":bc:dfhk:l:n:O:s:S:Tvz"
static const char *	XrdFrmUsage
XrdSysError	XrdLog (0, "")

Function Documentation

main()

int main	(	int	argc,
		char *	argv[] )

Definition at line 130 of file XrdFrmPurgMain.cc.

{
   XrdSysLogger Logger;
   extern int mainConfig();
 
// Turn off sigpipe and host a variety of others before we start any threads
//
   XrdSysUtils::SigBlock();
 
// Set the default stack size here
//
   if (sizeof(long) > 4) XrdSysThread::setStackSize((size_t)1048576);
      else               XrdSysThread::setStackSize((size_t)786432);
 
// Perform configuration
//
   Say.logger(&Logger);
   XrdLog.logger(&Logger);
   if (!Config.Configure(argc, argv, &mainConfig)) exit(4);
 
// Display configuration (deferred because mum might have been in effect)
//
   if (!Config.isOTO || Config.Verbose) XrdFrmPurge::Display();
 
// Now simply poke the server every so often
//
   if (Config.isOTO) XrdFrmPurge::Purge();
      else do {if (Config.StopPurge)
                  {int n = 0;
                   struct stat buf;
                   while(!stat(Config.StopPurge, &buf))
                        {if (!n--)
                            {Say.Emsg("PurgMain", Config.StopPurge,
                                      "exists; purging suspended."); n = 12;}
                         XrdSysTimer::Snooze(5);
                        }
                  }
               XrdFrmPurge::Purge();
               XrdSysTimer::Snooze(Config.WaitPurge);
              } while(1);
 
// All done
//
   exit(0);
}

References XrdFrm::Config, XrdFrmPurge::Display(), Logger, mainConfig(), XrdFrmPurge::Purge(), Say, XrdSysThread::setStackSize(), XrdSysUtils::SigBlock(), XrdSysTimer::Snooze(), stat, and XrdLog.

Here is the call graph for this function:

mainConfig()

int mainConfig

(

)

Definition at line 180 of file XrdFrmPurgMain.cc.

{
   XrdFrmConfig::Policy *pP = Config.dfltPolicy.Next;
   XrdFrmConfig::VPInfo *vP = Config.VPList;
   XrdNetSocket *udpSock;
   pthread_t tid;
   int retc, udpFD;
 
// If test is in effect, remove the fix flag
//
   if (Config.Test) Config.Fix = 0;
 
// Go through the policy list and add each policy
//
   while((pP = Config.dfltPolicy.Next))
        {if (!XrdFrmPurge::Policy(pP->Sname))
            XrdFrmPurge::Policy(pP->Sname, pP->minFree, pP->maxFree,
                                pP->Hold,  pP->Ext);
         Config.dfltPolicy.Next = pP->Next;
         delete pP;
        }
 
// Make sure we have a public policy
//
   if (!XrdFrmPurge::Policy("public"))
       XrdFrmPurge::Policy("public", Config.dfltPolicy.minFree,
                               Config.dfltPolicy.maxFree,
                               Config.dfltPolicy.Hold,
                               Config.dfltPolicy.Ext);
 
// Now add any missing policies (we need one for every space)
//
   while(vP)
      {if (!XrdFrmPurge::Policy(vP->Name))
          XrdFrmPurge::Policy(vP->Name, Config.dfltPolicy.minFree,
                                  Config.dfltPolicy.maxFree,
                                  Config.dfltPolicy.Hold,
                                  Config.dfltPolicy.Ext);
       vP = vP->Next;
      }
 
// Enable the appropriate spaces and over-ride config value
//
   if (!XrdFrmPurge::Init(Config.spacList, Config.cmdFree, Config.cmdHold))
      return 1;
 
// We are done if this is a one-time-only call
//
   if (Config.isOTO) return 0;
 
// Get a UDP socket for the server
//
   if (!(udpSock = XrdNetSocket::Create(&Say, Config.AdminPath,
                   "purg.udp", Config.AdminMode, XRDNET_UDPSOCKET))) return 1;
      else {udpFD = udpSock->Detach(); delete udpSock;}
 
// Start the Server thread
//
   if ((retc = XrdSysThread::Run(&tid, mainServer, (void *)&udpFD,
                                  XRDSYSTHREAD_BIND, "Server")))
      {Say.Emsg("main", retc, "create server thread"); return 1;}
 
// All done
//
   return 0;
}

References XrdFrm::Config, XrdNetSocket::Create(), XrdNetSocket::Detach(), XrdFrmConfig::Policy::Ext, XrdFrmConfig::Policy::Hold, XrdFrmPurge::Init(), mainServer(), XrdFrmConfig::Policy::maxFree, XrdFrmConfig::Policy::minFree, XrdFrmConfig::VPInfo::Name, XrdFrmConfig::Policy::Next, XrdFrmConfig::VPInfo::Next, XrdFrmPurge::Policy(), XrdSysThread::Run(), Say, XrdFrmConfig::Policy::Sname, XRDNET_UDPSOCKET, and XRDSYSTHREAD_BIND.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

mainServer()

void * mainServer

(

void *

parg

)

Definition at line 119 of file XrdFrmPurgMain.cc.

{
//  int udpFD = *static_cast<int *>(parg);
//  XrdFrmPurge::Server(udpFD);
    return (void *)0;
}

Referenced by mainConfig().

Here is the caller graph for this function:

Variable Documentation

Say

XrdOucTrace XrdTrace& Say

Definition at line 113 of file XrdFrmPurgMain.cc.

XrdFrmOpts

const char* XrdFrmOpts = ":bc:dfhk:l:n:O:s:S:Tvz"

static

Definition at line 33 of file XrdFrmPurgMain.cc.

XrdFrmUsage

const char* XrdFrmUsage

static

Initial value:

=
 
  " [-b] [-c <cfgfile>] [-d] [-f] [-k {num|sz{k|m|g}|sig] [-l [=]<fn>] [-n name]"
  " [-O free[,hold]] [-s pidfile] [-S site] [-T] [-v] [-z] [<spaces>] [<paths>]\n"

Definition at line 34 of file XrdFrmPurgMain.cc.

XrdLog

XrdSysError XrdLog(0, "")	(	0	,
		""	)