ddscomm.cc

Go to the documentation of this file.

#include <cstdlib>
#include <unistd.h>
#include "TROOT.h"
#include "TSystem.h"
#include "MessageService/MsgService.h"
#include "Dispatcher/DDS.h"
#include "Dispatcher/DDSClient.h"
#include "Dispatcher/DDSPSStatus.h"

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

//                                                                          //
// Data Dispatcher System communications program.  This program uses        //
// the DDSClient class to communicate with the ddsparentserver.             //
//                                                                          //
// S. Kasahara  8/2001                                                      //
//                                                                          //
// usage:  ddscomm -i<host ip> -p<port #> -s -r                             //
// -i: ip address of ddsparentserver (default is local host ip)             //
// -p: port # ddsparentserver listens on (default is DDS::kPort)            //
// -s: shutdown ddsparentserver                                             //
// -r: ddsparentserver report status                                        //
// -h: print usage message                                                  //
//                                                                          //
// Notes:  Currently supports 3 communication messages:                     //
//         ddscomm                                                          //
//           - prints abbreviated ddsparentserver status                    //
//         ddscomm -r                                                       //
//           - prints full ddsparentserver status report                    //
//         ddscomm -s                                                       //
//           - shuts down dispatcher parent server.                         //
//             This command must be issued on the same host as the          //
//             dispatcher parent server.                                    //
//                                                                          //
//         Options -p and -i may be specified with any communication        //
//         message.                                                         //
//                                                                          //

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

  MsgStream& ms = MSGSTREAM("DDS",Msg::kInfo);

  // Determine host name of current machine, default port #, default msg type
  const char* hostname = gSystem -> HostName();  
  Int_t port = DDS::kPort;
  DDS::EMessageType msgrequest = DDS::kStatus;

  gROOT -> SetBatch(kTRUE);

  // Process the command line arguments
  int c;
  bool isreport = false;
  while ((c = getopt(argc,argv,"i:p:srh")) != -1) {
    switch (c) {
    case 'i':
      hostname = optarg;
      break;
    case 'p':
      port = atoi(optarg);
      break;
    case 's':
      msgrequest = DDS::kShutdown;
      break;
    case 'r':
      msgrequest = DDS::kStatus;
      isreport = true;
      break;
    case 'h':
      fprintf(stderr,"usage: %s -i<host ip> -p<port #> -r -s\n",argv[0]);
      fprintf(stderr," -i: ip address of ddsparentserver (default is local ip)\n");
      fprintf(stderr," -p: port # ddsparentserver listens on (default is %i)\n",DDS::kPort);
      fprintf(stderr," -r: report full status of ddsparentserver\n");
      fprintf(stderr," -s: shutdown ddsparentserver\n");
      fprintf(stderr," -h: print this message\n");
      fprintf(stderr,"no opt: prints brief status of ddsparentserver\n");
      exit(0);
      break;
    default:
      fprintf(stderr,"unknown command line option:%c\n",(char)optopt);
      exit(1);
      break;
    }
  }

  int retstat=0;
  DDSClient* ddsclient = 0;
  if (msgrequest != DDS::kMessageUnknown) {

    const DDSPSStatus* psstatus = 0;
    switch (msgrequest) {
    
    case DDS::kShutdown:
      ms << "Sending shutdown message to parent server on host " 
         << hostname << " port " << port << "." << endl;
      // Need to fix how this is done
      ddsclient = new DDSClient(hostname,port,msgrequest);
      delete ddsclient;
      break;

    case DDS::kStatus:
      if ( isreport ) {
        ms << "Request full status report from parent server on host " 
           << hostname << " port " << port << "." << endl;
      }
      else {
        ms << "Request abbreviated status of parent server on host "
           << hostname << " port " << port << "." << endl;
      }

      ddsclient = new DDSClient(hostname,port,msgrequest);
      ms << "ddsparentserver " << hostname << " port " 
         << port << " status " << DDS::AsString(ddsclient->GetStatus()) 
         << endl;
      psstatus = ddsclient->GetPSStatus();
      if ( psstatus && isreport ) psstatus -> Print();
       
      if ( ddsclient->GetStatus() != DDS::kOk ) {
        retstat = 1;
      }
      delete ddsclient;
      
      break;

    default:
      break;

    }// end of msgrequest switch
  }

  return retstat;

}

---