DataListenerSvc.h

Go to the documentation of this file.

#ifndef GAUDIKERNEL_DATALISTENERSVC_H
#define GAUDIKERNEL_DATALISTENERSVC_H


#include "GaudiKernel/Service.h"
#include "GaudiKernel/IIncidentSvc.h"
#include "GaudiKernel/IMonitorSvc.h"
#include "GaudiKernel/IIncidentListener.h"
#include "ValueMap.h"
#include "XmlCode.h"
#include "ApMon.h"
#include <iostream>
#include <fstream>
#include <ctime>
#include <string>
#include <map>
#include <set>


#include <stdio.h>


// Forward declarations
class ISvcLocator;

class DataListenerSvc : public extends2<Service, IMonitorSvc, IIncidentListener> {
public:
  DataListenerSvc(const std::string& name, ISvcLocator* sl);

  virtual ~DataListenerSvc() {}

  // Service pure virtual member functions
  StatusCode initialize();
  StatusCode finalize();

  void declareInfo(const std::string& name, const bool&  var,
                   const std::string& desc, const IInterface* owner) ;
  void declareInfo(const std::string& name, const int&  var,
                   const std::string& desc, const IInterface* owner) ;
  void declareInfo(const std::string& name, const long&  var,
                   const std::string& desc, const IInterface* owner) ;
  void declareInfo(const std::string& name, const double& var,
                   const std::string& desc, const IInterface* owner) ;
  void declareInfo(const std::string& name, const std::string& var,
                   const std::string& desc, const IInterface* owner) ;
  void declareInfo(const std::string& name, const std::pair<double,double>&var,
                   const std::string& desc, const IInterface* owner) ;
  void declareInfo(const std::string& name, const AIDA::IBaseHistogram* var,
                   const std::string& desc, const IInterface* owner) ;
  void declareInfo(const std::string& name, const StatEntity& var,
                   const std::string& desc, const IInterface* owner) ;
  void declareInfo(const std::string& name, const std::string& format,
                   const void * var, int size, const std::string& desc,
                   const IInterface* owner) ;

  // Declaration of declareProperty which is virtual in one of my includes
  // (that would be service.h)
  //  StatusCode declareProperty(const std::string& name, const int& var);


  void undeclareInfo( const std::string& name, const IInterface* owner ) ;

  void undeclareAll( const IInterface* owner ) ;

  virtual void handle(const Incident&);


  std::set<std::string> * getInfos(const IInterface* owner = 0);



  void apmSend(char* clusterName, char* moduleName, char* key, double val);
  void apmSend(char* clusterName, char* moduleName, char* key, int val);
  void apmSend(char* clusterName, char* moduleName, char* key, long val);
  void apmSend(char* clusterName, char* moduleName, char* key, bool val);
  void apmSend(char* clusterName, char* moduleName, char* key, char* val);

private:


  ApMon *apm;


  // ValueMap stores declared data information
  ValueMap m_ValueMap;
  ValueMap m_ValueMapTemp;

  time_t rawTime;
  time_t rawTime2;

  char buffer[50];
  char buffer2[50];
  std::string timeDate;
  std::string timeDate2;
  std::string valToWrite;


  // Used to hold variable name and data information
  typedef std::pair< std::string, ValueMap > Entry;
  typedef std::map<const IInterface*, std::set<std::string> > InfoNamesMap;

  typedef std::map< std::string, ValueMap > ValNamesMap;

  void writeMap(ValNamesMap*, const Incident&, std::ofstream*);
  void writeXML(ValNamesMap*, const Incident&, std::ofstream*);
  std::string resizeString ( const std::string, const unsigned int );

  // Converts types INTO a string with a stringstream
  std::string stringConverter ( const int convertee );
  std::string stringConverter ( const double convertee );
  std::string stringConverter ( const bool convertee );
  std::string stringConverter ( const long convertee );



  InfoNamesMap m_InfoNamesMap;
  InfoNamesMap::iterator m_InfoNamesMapIt;

  ValNamesMap m_ValNamesMap;
  ValNamesMap::iterator m_ValNamesMapIt;
  XmlCode xml;


  // Map associating to each algorithm name a set with the info
  // names from this algorithm
  IIncidentSvc* m_incidentSvc;
  FILE* MonitorLog;
  std::ofstream Log4;
  std::ofstream XMLLog;


  int FreqCriterion;
  int m_EventFrequency;


  void sendData(ValNamesMap*);

  // The container below is necessary because usually the descriptions of
  // the services are constant strings, not variables. DimService expects
  // a variable address to monitor as its second argument and we are using
  // a DimService for strings to publish the descriptions.
  std::map<std::string,std::string> m_infoDescriptions;
  std::string infoOwnerName( const IInterface* owner );

  // MonALISA optionsfile variables
  int m_MLjobID;
  int m_MLEventFrequency;
  std::string m_MLClusterName;
  std::string m_ApMonSettingsFile;
  std::string jobIDString;
  int m_MonALISAMonitoring;
  int m_XMLMonitoring;
  int m_FileMonitoring;


  char *keyToSend;


};

#endif // GAUDIKERNEL_DATALISTENERSVC_H