JiveXMLServer.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef JIVEXML_JIVEXMLSERVER_H
#define JIVEXML_JIVEXMLSERVER_H

 
#include <vector>
#include <string>
 
//athena includes
#include <GaudiKernel/IMessageSvc.h>
#include <GaudiKernel/StatusCode.h>
#include <CxxUtils/checker_macros.h>
 
//JiveXML includes
#include <JiveXML/IServer.h>
#include <JiveXML/EventStream.h>
 
//tdaq includes
#include <owl/semaphore.h>
 
namespace JiveXML {
 
  //Forward declarations
  class ThreadCollection;
 
  class JiveXMLServer: virtual public IServer {
 
    public:
      //Constructor with port number
      JiveXMLServer( int port = 0 );
 
      //Destructor
      virtual ~JiveXMLServer();


      virtual StatusCode UpdateEventForStream( const EventStreamID& evtStreamID, const std::string & event) override;


      virtual std::vector<std::string> GetStreamNames() const override;
      virtual const EventStreamID GetEventStreamID(const std::string& streamName) const override;
      virtual const std::string GetEvent( const EventStreamID& evtStreamID ) const override;
      virtual int GetState() const override;
      

      virtual void Message( const MSG::Level level, const std::string& msg ) const override;
      virtual MSG::Level LogLevel() const override;


      StatusCode StartServingThread();
      StatusCode StopServingThread();
      virtual bool GetRunServerFlag () const override { return m_runServerThread; };
      virtual void ServerThreadStopped() override;
      void Wait();
      
      
    private:
 
      //Signal handler must be static function
      static void signalHandler (int signum);
 
      //Static semaphore used to suspend main thread while server thread is
      //running. The semaphore will reach its post-condition either by
      // a) receiving a signal through the signal handler
      // b) the ServerThreadStopped callback being called
      inline static OWLSemaphore m_lock ATLAS_THREAD_SAFE;
 
      //Store the received signal in a static member
      inline static std::atomic<int> m_receivedSignal{0};
 
      //Port number property - defaults to zero in which case
      //it is dynamically assigned
      int m_portNumber;
 
      //A map of the streams and their current events
      EventStreamMap m_eventStreamMap;
 
      //A mutex (mutual exclusive) lock for the data map
      mutable pthread_mutex_t m_accessLock ATLAS_THREAD_SAFE;
 
      //A handle to the server thread
      pthread_t m_ServerThreadHandle;
 
      //Once this flag is set to false, the thread will stop after handling its
      //last request
      bool m_runServerThread;
  };
}
 
#endif