ddsparentserver.cc

Go to the documentation of this file.

#include <cstdlib>
#include <unistd.h>
#include "TROOT.h"
#include "MessageService/Msg.h"
#include "MessageService/MsgService.h"
#include "Dispatcher/DDSParentServer.h"

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

//                                                                          //
// Data Dispatcher System parentserver program.  This program uses the      //
// DDSParentServer class and drives the parent server portion of the        //
// dispatcher system.                                                       //
//                                                                          //
// usage: ddsparentserver -p<port #> -m<max no. of clients> -l<loglevel>    //
//                        -t<maxinactive>                                   //
// -p: port number assigned to listening socket (default = 9090)            //
// -m: maximum number of concurrent clients allowed (default = 10)          //
// -l: loglevel at which to print messages (default = Info)                 //
// -t: inactive client time limit (sec) before child server will disconnect //
//     (def = 21600)                                                        //
// -h: print usage message                                                  //

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

  Int_t port = 9090;
  Int_t maxchild = 10;
  Int_t maxinactive = 21600;
  Int_t logLevel = Msg::GetLevelCode("Info");
 
  gROOT -> SetBatch(kTRUE);

  // Process the command line arguments
  int c;
  while ((c = getopt(argc,argv,"p:m:l:t:h")) != -1) {
    switch (c) {
    case 'p':
      port = atoi(optarg);
      break;
    case 'm':
      maxchild = atoi(optarg);
      break;
    case 'l':
      logLevel = Msg::GetLevelCode(optarg);
      if ( logLevel < Msg::kMinLogLevel ) {
        fprintf(stderr,
                "-l (loglevel) option has invalid argument %s.\n",optarg);
        fprintf(stderr,"   valid arguments are:");
        fprintf(stderr," %s",Msg::LevelAsString(Msg::kMinLogLevel));
        for (int i = Msg::kMinLogLevel+1;
                 i < (Msg::kNLogLevel+Msg::kMinLogLevel); i++) {
          if ( strcmp("Unknown?!",Msg::LevelAsString(i)) ) 
             fprintf(stderr,", %s",Msg::LevelAsString(i));
        }
        fprintf(stderr,"\n");
        exit(1);
      }
      break;
    case 't':
      maxinactive = atoi(optarg);
      break;
    case 'h':
      fprintf(stdout,"usage: %s -p<port#> -m<max no. clients> -l<loglevel> -t<maxinactive>\n",argv[0]);
      fprintf(stdout," -p: port number to listen on (default=%i)\n",DDS::kPort);
      fprintf(stdout," -m: maximum number of concurrent clients (default = 10)\n");
      fprintf(stdout,
              " -l: loglevel at which to print messages (default=Info).\n");
      fprintf(stdout,"     valid arguments are:");
      fprintf(stdout," %s",Msg::LevelAsString(Msg::kMinLogLevel));
      for (int i = Msg::kMinLogLevel+1;
               i < (Msg::kNLogLevel+Msg::kMinLogLevel); i++) {
        if ( strcmp("Unknown?!",Msg::LevelAsString(i)) ) 
          fprintf(stdout,", %s",Msg::LevelAsString(i));
      }
      fprintf(stdout,"\n");
      fprintf(stdout,
      " -t: inactive client time limit(sec) before child server will disconnect\n");
      fprintf(stdout," -h: print this message\n");
      exit(0);
      break;
    default:
      fprintf(stderr,"unknown command line option: %c\n",(char)optopt);
      exit(1);
      break; 
    }
  }

  MsgService::Instance() -> GetStream("DDS") -> SetLogLevel(logLevel);
  // require time stamping for all log levels above this
  for (int i = logLevel; i < Msg::kNLogLevel; i++) {
    MsgService::Instance() -> GetStream("DDS")->AddFormat(i,Msg::kTime);
  }

// Create a DDSParentServer object attached to port 9090 
  DDSParentServer *ps =new DDSParentServer(port,maxchild,logLevel,maxinactive);
  if (! ps->IsValid() ) {
    // Error in creation of parent server
    MSG("DDS",Msg::kFatal) 
    << "PS: Error in creation of parent server. Program terminating." <<endl;
    return 1;
  }

// Print some information about the parent server socket
  MSG("DDS",Msg::kInfo)
        << "PS: Successfully opened parent server listening socket." << endl;
  MSG("DDS",Msg::kInfo) << ps << endl;

// Run the main loop to listen for and process client connections
// The parent server will stay in this loop until it receives a 
// DDS::kShutdown message from a connected client 
  ps -> Run();

// Print final stats from the parent server socket
  MSG("DDS",Msg::kInfo)<<"PS: Shutdown message received by parent server."
                       << endl; 
  MSG("DDS",Msg::kInfo)<< ps << endl;;

// delete parent server socket
  delete ps;

  return 0;

}

---