DDSParentServer.h

Go to the documentation of this file.

#ifndef DDSPARENTSERVER_H
#define DDSPARENTSERVER_H

//                                                                          //
// DDSParentServer                                                          //
//                                                                          //
// Package: DDS (Data Dispatcher System).                                   //
//                                                                          //
// S. Kasahara  2/2001                                                      //
// Based in part on ideas from the LHCb OTT online monitoring system.       //
#include <iosfwd> // ostream forward decl.
using namespace std;

#include "TServerSocket.h" // necessary for TServerSocket::kDefaultBacklog
#include "TMessage.h" // data member
#include "MessageService/Msg.h"
#include "Dispatcher/DDS.h"
#include "Dispatcher/DDSPSStatus.h" // data member

class DDSParentServer;

std::ostream& operator << (std::ostream& ms, DDSParentServer* ps);

class DDSParentServer {

public:

// Typedefs and enumerations
  enum { kMaxChild = 10 }; // max no. of child servers allowed at any one time 
  
// Constructors and destructor.
  DDSParentServer (UInt_t port = 0, UInt_t maxchild = kMaxChild, 
  Int_t logLevel = Msg::kInfo, Int_t maxinactive = 21600, 
  Int_t backlog = TServerSocket::kDefaultBacklog);
  virtual ~DDSParentServer ();  

// State testing member functions.
  bool IsValid () const { 
                 return (fTServerSocket != (TServerSocket*)0) ? true : false; }
  std::ostream& Print(std::ostream& ms) const; 
  
// State changing member functions.
  void Run();                  

private:

// Private member functions.
  bool Authorize() const; 
  UInt_t CheckChildStatus();  
  bool IsLocalClient() const;
  DDS::EMessageType SpawnChildServer(); 
  DDS::EMessageType Shutdown();            
  DDS::EMessageType Status();            

// Data members.
  TServerSocket* fTServerSocket;  // pointer to listening socket
  UInt_t         fMaxChild;       // maximum number of child servers allowed
  Int_t          fLogLevel;       // message service log level
  Int_t          fMaxInactive;    // max inactive time before child is shutdown
  UInt_t         fNumChild;       // current number of child servers running
  bool           fShutdown;       // if true server socket will be shutdown  
  TSocket*       fTSocket;        // pointer to current client socket
  TInetAddress   fServerAddress;  // local internet address of server
  TInetAddress   fClientAddress;  // internet address of current client
  TMessage*      fMessageIn;      // message received from client
  TMessage       fMessageOut;     // message sent to client
  DDSPSStatus    fPSStatus;       // parent server status 

  ClassDef(DDSParentServer,0)   // MINOS Data Dispatcher System Parent Server
};

#endif        // DDSPARENTSERVER_H

---