DisplayServer.h

Go to the documentation of this file.

//-------------------------------------------------------------------------
// File: DisplayServer.hh
//
// The DisplayServer class comprises methods to receive monitoring data from
// the consumers, store them and send them to the HistoDisplay clients.
// The communication between the consumers, the DisplayServer and the
// HistoDisplay is implemented with TSockets.
//
// Author: Wolfgang Wagner 
//
//-------------------------------------------------------------------------
//****************************************************************************
// RCS Current Revision Record
//-----------------------------------------------------------------------------
// $Source: /cvs/minoscvs/rep1/minossoft/CDFMonitoringFwk/DisplayServer.h,v $
// $Revision: 1.1 $
// $Date: 2001/07/16 18:33:48 $
// $Author: dap56 $
// $State: Exp $
// $Locker:  $
//*****************************************************************************
#ifndef DISPLAYSERVER_HH
#define DISPLAYSERVER_HH

#include <string>
#include <map>

#include "TServerSocket.h"
#include "TSocket.h"
#include "TMonitor.h"
#include "TList.h"
#include "TROOT.h"
#include "TTimer.h"
#include "TNamed.h"

// Include files from Consumer Framework
#include "TConsumerInfo.h"
#include "ConsumerList.h"


using std::string;
using std::map;

const char spaces[]  = "               ";
const char barrier[] = 
  "===========================================================================";


class DisplayServer : TNamed
{
public:
  DisplayServer(char* host, int consPort, TROOT* rt, ConsumerList* cl, 
  bool useTimer=true);
  ~DisplayServer();

  enum DSErrorCode {
    DS_OK = 0,
    DS_NO_CONNECTION = -1,
    DS_BAD_CLIENT_SSOCKET = -2
  };
  // Error code explaination:
  // DS_NO_CONNECTION = It was not possible to connect to the server socket 
  //                    of the consumer.  


  int  pollConsumer();
  void connectClient();
  void pollClients();
  TConsumerInfo* getCurrentInfo();
  int  errorFlag() const { return _error;}
                 
private:
  static const string _clName;
  string _hostName;
  int   _consumerPort;
  int   _clientPort;
  int   _error;
  int   _debugFlags;
  int   _updateTimeDiff;
  bool  _useTimer; 
  map<string,bool> _clientMap;
  TServerSocket* _ss;      // Server socket for the display clients.
  TSocket* _conSock;       // Socket for consumer connection. 
  TMonitor _consMoni;      // Monitor for the consumer socket.
  TMonitor _clientMoni;    // Monitor for the client sockets. 
  TList _currList;         // List to store the objects currently provided.
  TList _outdatedList;     // List of objects which are not provided anymore.
  TConsumerInfo* _currInfo;
  ConsumerList*  _conList; 
  TROOT*     _glRoot;      // Global Root
  TTimer*    _updateTimer; // ROOT timer for triggering the status update   

  // private methods
  Bool_t HandleTimer(TTimer* timer);
  void editStorageList(const string& nameString);
  void updateStateManager();
  void setRequireUpdateBits();
  int openClientServerSocket(); 

  DisplayServer(const DisplayServer& ds);
  DisplayServer& operator=(const DisplayServer& ds);

};  
  
#endif

---