ConsumerExport.h

Go to the documentation of this file.

//-------------------------------------------------------------------------
// File: ConsumerExport.hh
// Header file for ConsumerExport.cc
//
// The ConsumerExport class provides methods for the communication of the
// consumer with its display server.
//
// File history:
//
// 07/05/2000  Started class                         Wolfgang Wagner 
// 07/28/2000  Added benchmarking and CANVAS mode    Wolfgang Wagner 
//------------------------------------------------------------------------
//****************************************************************************
// RCS Current Revision Record
//-----------------------------------------------------------------------------
// $Source: /cvs/minoscvs/rep1/minossoft/CDFMonitoringFwk/ConsumerExport.h,v $
// $Revision: 1.1 $
// $Date: 2001/07/16 18:33:48 $
// $Author: dap56 $
// $State: Exp $
// $Locker:  $
//*****************************************************************************

#ifndef CONSUMEREXPORT_HH
#define CONSUMEREXPORT_HH 1

#include <stdio.h>
#include <sys/types.h>
#include <time.h>

#include <iostream>

#include "TSocket.h"
#include "TServerSocket.h"
#include "TMessage.h"
#include "TMonitor.h"
#include "TList.h"

class TConsumerInfo;

class ConsumerExport
{
public:
  ConsumerExport(const int firstPort, const bool restartEnable=false, 
                 const int reportToStateManager=2);
  ~ConsumerExport();
    
  int send(TConsumerInfo *consinfo, Bool_t modFlag=kFALSE);
  int send(const char *messString);
  pid_t getServerPid();
  static int getMaxString() {return _maxStringLength;}
  static void setMaxString(int newLength) {_maxStringLength = newLength;}

private:
  bool           _debug;
  bool           _restartEnable;
  bool           _sendingEnable;
  int            _reportToStateManager;  
  int            _port;
  pid_t          _serverPid;
  time_t         _serverStartTime;
  static int     _maxStringLength;
  char*          _canvasString;
  TMonitor*      _consMonitor;
  TServerSocket* _consSS;
  TSocket*       _consSock;

  // Declare the copy constructor private, but don't define it.
  ConsumerExport(const ConsumerExport& ce);
  ConsumerExport& operator=(const ConsumerExport& ce);

  int send(TList *list);
  int send(const TObject *object); 
  void errorReact(const Int_t sendRes);
  void createCanvasString(TList *canvasList);
  int  lengthNeeded(TList *canvasList);
  int  startServer();
  int  connectServer();
  int  reestablishServer(); 
};

#endif

---