DDSChildServer.h

Go to the documentation of this file.

#ifndef DDSCHILDSERVER_H
#define DDSCHILDSERVER_H

//                                                                          //
// DDSChildServer                                                           //
//                                                                          //
// Package: DDS (Data Dispatcher System).                                   //
//                                                                          //
// S. Kasahara 5/2001                                                       //
// Based in part on ideas from the LHCb OTT online monitoring system.       //
//                                                                          //
#include <iosfwd> // ostream forward decl.
#ifndef __CINT__
#include <sys/types.h>  // defines pid_t type
#endif
#include "TInetAddress.h"
#include "TMessage.h"
#include "Persistency/PerInputStreamManager.h"

#include "Dispatcher/DDS.h"

class TSocket;
class MomNavigator;
class DDSChildServer;
class DDSSubscription;
class DDSFileHandler;

std::ostream& operator << (std::ostream& ms, DDSChildServer* cs);

class DDSChildServer {

public:
  // Typedefs and enumerations.

  // Constructor and destructor.
  DDSChildServer (Int_t sockfd, Int_t maxinactive);   
  virtual ~DDSChildServer ();       

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

  // State changing member functions.
  Int_t Run();                      

private:

  // Private member functions.
  void Get();       // load current entry from stream manager
  void GoToFile();  // advance to user-specified file
  bool IsClientConnected() const;  // status of client-server socket connection
  void Next();      // send next entry satisfying subscription
  void Shutdown();  // shutdown the child server
  void Subscribe(); // receive and process new subscription 

  // Data members.
  TSocket*  fTSocket;          // pointer to connected socket
  DDSSubscription* fSubscription; // client subscription
  DDSFileHandler* fFileHandler; // pointer to file handler
  bool      fShutdown;         // if true child server will be shutdown  
  int       fPid;              // process id of this child 
  // while properly this should be of type "pid_t" (defined in <sys/types.h>)
  // this value is set by gSystem->GetPid() which returns an "int" 
  // and ROOTCINT can't handle pid_t on IRIX6.5 with current compiler flags
  MomNavigator *fMom;          // pointer to container for retrieved objects
  TMessage* fMessageIn;        // message buffer for received message objects
  TMessage  fMessageOut;       // message buffer for outgoing objects
  PerInputStreamManager fInputStreamManager; // manager for input streams 
  TInetAddress fServerAddress; // child server internet address
  TInetAddress fClientAddress; // client internet address
  Int_t     fMaxInactive;  // limit of client inactivity,def is 21600 sec    
  ClassDef(DDSChildServer,0)  // MINOS Data Dispatcher System Child Server

};

#endif                                    // DDSCHILDSERVER_H

---