AthenaSharedMemoryTool.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2017 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef ATHENASHAREDMEMORYTOOL_H
#define ATHENASHAREDMEMORYTOOL_H
 
#include "GaudiKernel/ServiceHandle.h"
#include "AthenaBaseComps/AthAlgTool.h"
#include "AthenaKernel/IAthenaIPCTool.h"
 
#include <set>
#include <string>
 
// Forward declarations.
class IIncidentSvc;
 
namespace boost {
   namespace interprocess {
      class shared_memory_object;
      class mapped_region;
   }
}
 
class AthenaSharedMemoryTool : public ::AthAlgTool, virtual public IAthenaIPCTool {
public: 
   AthenaSharedMemoryTool(const std::string& type, const std::string& name, const IInterface* parent);
   virtual ~AthenaSharedMemoryTool();
 
   StatusCode initialize();
   StatusCode stop();
   StatusCode finalize();
 
   StatusCode makeServer(int num, const std::string& streamPortSuffix);
   bool isServer() const;
   StatusCode makeClient(int num, std::string& streamPortSuffix);
   bool isClient() const;
 
   StatusCode putEvent ATLAS_NOT_THREAD_SAFE (long eventNumber, const void* source, size_t nbytes, unsigned int status) const;
   StatusCode getLockedEvent(void** target, unsigned int& status) const;
   StatusCode lockEvent(long eventNumber) const;
 
   StatusCode putObject(const void* source, size_t nbytes, int num = 0);
   StatusCode getObject(void** target, size_t& nbytes, int num = 0);
   StatusCode clearObject(const char** tokenString, int& num);
   StatusCode lockObject(const char* tokenString, int num = 0);
 
private:
   StringProperty m_sharedMemory;
   const size_t m_maxSize;
   const int m_maxDataClients;
   int m_num;
   int m_lastClient;
   std::set<int> m_dataClients;
   boost::interprocess::mapped_region* m_payload;
   boost::interprocess::mapped_region* m_status;
   long m_fileSeqNumber;
   bool m_isServer;
   bool m_isClient;
   ServiceHandle<IIncidentSvc> m_incidentSvc;
};
 
#endif