XrdMain.cc File Reference

#include <unistd.h>
#include <cctype>
#include <cerrno>
#include <cstdint>
#include <signal.h>
#include <cstdlib>
#include <cstring>
#include <strings.h>
#include <cstdio>
#include <sys/param.h>
#include "Xrd/XrdConfig.hh"
#include "Xrd/XrdInet.hh"
#include "Xrd/XrdLink.hh"
#include "Xrd/XrdProtLoad.hh"
#include "Xrd/XrdScheduler.hh"
#include "XrdSys/XrdSysError.hh"
#include "XrdSys/XrdSysHeaders.hh"
#include "XrdSys/XrdSysPthread.hh"
#include "XrdSys/XrdSysUtils.hh"

Include dependency graph for XrdMain.cc:

Go to the source code of this file.

Classes
class	XrdMain

Functions
int	main (int argc, char *argv[])
void *	mainAccept (void *parg)
void *	mainAdmin (void *parg)

Function Documentation

main()

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

Definition at line 161 of file XrdMain.cc.

{
   XrdMain   Main;
   pthread_t tid;
   char      buff[128];
   int       i, retc;
 
// Set TZ environment variable to read the system timezone from /etc/localtime
// if it is not already set, to avoid race conditions between localtime_r() and
// mktime() during the multi-threaded phase of the initialization.
 
   if (access("/etc/localtime", R_OK) == 0)
       setenv("TZ", ":/etc/localtime", /* overwrite */ false);
 
// Call tzset() early to ensure thread-safety of localtime_r() and mktime().
   tzset();
 
// Turn off sigpipe and host a variety of others before we start any threads
//
   XrdSysUtils::SigBlock();
 
// Set the default stack size here. Note that on modern Linux the default
// stack size is set at about 8MB. We force a lower limit to not have a huge
// virtual address space mostly for core file debugging purposes.
//
   if (sizeof(long) > 4) XrdSysThread::setStackSize((size_t)2097152, true);
      else               XrdSysThread::setStackSize((size_t)1048576, true);
 
// Process configuration file
//
   if (Main.Config.Configure(argc, argv)) _exit(1);
 
// Start the admin thread if an admin network is defined
//
   if (Main.Config.NetADM && (retc = XrdSysThread::Run(&tid, mainAdmin,
                             (void *)new XrdMain(Main.Config.NetADM),
                             XRDSYSTHREAD_BIND, "Admin handler")))
      {Main.Config.ProtInfo.eDest->Emsg("main", retc, "create admin thread");
       _exit(3);
      }
 
// At this point we should be able to accept new connections. Spawn a
// thread for each network except the first. The main thread will handle
// that network as some implementations require a main active thread.
//
   for (i = 1; i < (int)Main.Config.NetTCP.size(); i++)
       if (Main.Config.NetTCP[i])
          {XrdMain *Parms = new XrdMain(Main.Config.NetTCP[i]);
           sprintf(buff, "Port %d handler", Parms->thePort);
//???      if (Parms->theNet == Main.Config.NetTCP[XrdProtLoad::ProtoMax])
//             Parms->thePort = -(Parms->thePort);
           if ((retc = XrdSysThread::Run(&tid, mainAccept, (void *)Parms,
                                         XRDSYSTHREAD_BIND, strdup(buff))))
              {Main.Config.ProtInfo.eDest->Emsg("main", retc, "create", buff);
               _exit(3);
              }
          }
 
// Finally, start accepting connections on the main port
//
   Main.theNet  = Main.Config.NetTCP[0];
   Main.thePort = Main.Config.NetTCP[0]->Port();
   mainAccept((void *)&Main);
 
// We should never get here
//
   pthread_exit(0);
}

References access, XrdMain::Config, XrdConfig::Configure(), XrdProtocol_Config::eDest, XrdSysError::Emsg(), mainAccept(), mainAdmin(), XrdConfig::NetADM, XrdConfig::NetTCP, XrdConfig::ProtInfo, XrdSysThread::Run(), XrdSysThread::setStackSize(), XrdSysUtils::SigBlock(), XrdMain::theNet, XrdMain::thePort, and XRDSYSTHREAD_BIND.

Here is the call graph for this function:

mainAccept()

void * mainAccept

(

void *

parg

)

Definition at line 115 of file XrdMain.cc.

{  XrdMain        *Parms   = (XrdMain *)parg;
   XrdScheduler   *mySched =  Parms->Config.ProtInfo.Sched;
   XrdProtLoad     ProtSelect(Parms->thePort);
   XrdSysSemaphore accepted(0);
 
// Complete the parms
//
   Parms->theSem  = &accepted;
   Parms->theProt = (XrdProtocol *)&ProtSelect;
 
// Simply schedule new accepts
//
   while(1) {mySched->Schedule((XrdJob *)Parms);
             accepted.Wait();
            }
 
   return (void *)0;
}

References XrdMain::Config, XrdConfig::ProtInfo, XrdProtocol_Config::Sched, XrdScheduler::Schedule(), XrdMain::thePort, XrdMain::theProt, XrdMain::theSem, and XrdSysSemaphore::Wait().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

mainAdmin()

void * mainAdmin

(

void *

parg

)

Definition at line 139 of file XrdMain.cc.

{  XrdMain      *Parms   = (XrdMain *)parg;
   XrdInet      *NetADM  =  Parms->theNet;
   XrdLink      *newlink;
// static XrdProtocol_Admin  ProtAdmin;
   int           ProtAdmin;
 
// At this point we should be able to accept new connections. Noe that we don't
// support admin connections as of yet so the following code is superflous.
//
   while(1) if ((newlink = NetADM->Accept()))
               {newlink->setProtocol((XrdProtocol *)&ProtAdmin);
                newlink->setProtName("xrdadmin");
                Parms->Config.ProtInfo.Sched->Schedule((XrdJob *)newlink);
               }
   return (void *)0;
}

References XrdInet::Accept(), XrdMain::Config, XrdConfig::ProtInfo, XrdProtocol_Config::Sched, XrdScheduler::Schedule(), XrdLink::setProtName(), XrdLink::setProtocol(), and XrdMain::theNet.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function: