ONCRPCServerSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef JIVEXML_ONCRPCSERVERSVC_H
#define JIVEXML_ONCRPCSERVERSVC_H
 
#include "AthenaBaseComps/AthService.h"
#include "CxxUtils/checker_macros.h"
#include "GaudiKernel/ServiceHandle.h"
#include "GaudiKernel/MsgStream.h"
#include "JiveXML/EventStream.h"
#include "JiveXML/IServerSvc.h"
#include "JiveXML/IServer.h"
 
namespace JiveXML {
 
  //forward declarations
  class ThreadCollection;

 
  class ONCRPCServerSvc : public extends<AthService, IServerSvc>, 
                          virtual public IServer {
   public:
    
    ONCRPCServerSvc(const std::string& name, ISvcLocator* sl);
    virtual ~ONCRPCServerSvc();

    virtual StatusCode initialize() override;
    virtual StatusCode finalize() override;
 


    virtual int GetState() const 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 StatusCode UpdateEventForStream( const EventStreamID& evtStreamID, const std::string & event) override;
    
    virtual
    void Message( const MSG::Level level, const std::string& mesg ) const override;
    virtual MSG::Level LogLevel() const override;
 

    virtual bool GetRunServerFlag () const override { return m_runServerThread; };
    StatusCode StartServer();
    StatusCode StopServer();
    virtual void ServerThreadStopped() override;
 
  private:
 
    //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;
  };
 
} //namespace
 
#endif