ddschildserver.cc

Go to the documentation of this file.

#include <cstdlib>
#include <unistd.h>  // required for nice function
#include "TROOT.h"
#include "TSystem.h"
#include "MessageService/MsgService.h"
#include "Dispatcher/DDSChildServer.h"

TROOT root("ddschildserver","MINOS Data Dispatcher System childserver");
CVSID("$Id: ddschildserver.cc,v 1.7 2009/02/28 21:46:12 gmieg Exp $");

//                                                                          //
// Data Distribution System child server program.  This program uses the    //
// DDSChildServer class to handle client connections.                       //
//                                                                          //
// Arguments: sockfd  = connected socket descriptor passed in exec from     //
//                      parent server.                                      //
//            niceincr = value by which to increment nice level. Raising    //
//                       the nice value lowers the priority of the child    //
//                       server process.                                    //
//            loglevel = level at which to log messages, default = Info     //
//            maxinactive = max inactive time period before connection      //
//                          shutdown                                        //
//                                                                          //
// S. Kasahara  2/2001                                                      //
//                                                                          //
// Notes: This program is executed from the ddsparentserver program when it //
//        receives a new client request for data.                           //

int main(int argc, char **argv) {

  pid_t pid = gSystem -> GetPid(); //get process id for identification purposes


  gROOT -> SetBatch(kTRUE);

  //  gSystem -> Sleep(60*1000); // sleep to give debugger time to attach

  // Process arguments
  if (argc < 5) {
    cerr << pid << ":Error: ddschildserver called with missing argument.\n" 
    << "Usage:\n"
    << "ddschildserver <socketdescriptor> <niceinc> <loglevel> <maxinactive>." 
    << endl;
    return 1;
  }

  // Connected socket descriptor.
  Int_t sockfd = atoi(argv[1]);
  // Nice incrementation for this child server
  Int_t niceincr = atoi(argv[2]);
  nice(niceincr); // adjusts the priority of this child server by niceincr.

  // Customize message service 
  Int_t logLevel = atoi(argv[3]);
  MsgStream* msdds = MsgService::Instance() -> GetStream("DDS");
  MsgStream* msper = MsgService::Instance() -> GetStream("Per");
  msdds -> SetLogLevel(logLevel);
  // require time stamping for all log levels equal to or above this
  for (int i = logLevel; i < Msg::kNLogLevel; i++) {
    msdds -> AddFormat(i,Msg::kTime);
    msper -> AddFormat(i,Msg::kTime);
  }
  msdds-> RemoveFormat(Msg::kWarning,Msg::kName+Msg::kFile+Msg::kLine);
  msdds-> RemoveFormat(Msg::kInfo,Msg::kName+Msg::kFile+Msg::kLine);
  msdds-> RemoveFormat(Msg::kDebug,Msg::kName+Msg::kFile+Msg::kLine);
  msdds-> RemoveFormat(Msg::kVerbose,Msg::kName+Msg::kFile+Msg::kLine);

  // Customize max inactive time limit (sec)
  Int_t maxinactive = atoi(argv[4]);

  // Create a DDSChildServer object with the connected socket descriptor
  DDSChildServer *cs = new DDSChildServer(sockfd,maxinactive);

  if (! cs->IsValid() ) {
    // Error in creation of child server
    MSG("DDS",Msg::kFatal) << "CS_" << pid 
    << ": Error in creation of child server. Program terminating." <<endl;
    return 1;
  }

  TDatime starttime;
  MSG("DDS",Msg::kInfo) << "CS_" << pid << ": child server created on " 
       << starttime.AsString() << endl;
  MSG("DDS",Msg::kInfo) << cs << endl;

// Run the main loop to listen for and process client requests
// The child server will stay in this loop until it receives a 
// DDS::kShutdown message from a connected client 
  Int_t rc = cs -> Run();

// Print final stats from the child server socket
  TDatime endtime;
  MSG("DDS",Msg::kInfo) << "CS_" << pid << ": child server shutdown on " << endtime.AsString() << endl;

// delete child server socket
  delete cs;

  return rc;

}

---