AthenaPoolSharedIOCnvSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef ATHENAPOOLCNVSVC_ATHENAPOOLSHAREDIOCNVSVC_H
#define ATHENAPOOLCNVSVC_ATHENAPOOLSHAREDIOCNVSVC_H
 
#include "AthenaPoolCnvSvc.h"
#include "AthenaKernel/IDataShare.h"
#include "AthenaKernel/IAthenaSerializeSvc.h"
 
// Forward declarations
class Guid;
 
template <class TYPE> class SvcFactory;
 
class AthenaPoolSharedIOCnvSvc : public extends<AthenaPoolCnvSvc,
                    IDataShare> {
   // Allow the factory class access to the constructor
   friend class SvcFactory<AthenaPoolSharedIOCnvSvc>;
 
public:
 
   virtual StatusCode initialize() override;
   virtual StatusCode finalize() override;
 
   virtual StatusCode connectOutput(const std::string& outputConnectionSpec,
           const std::string& openMode) override;
 
   virtual StatusCode connectOutput(const std::string& outputConnectionSpec) override;
 
   virtual StatusCode commitOutput(const std::string& outputConnectionSpec, bool doCommit) override;
 
   virtual StatusCode disconnectOutput(const std::string& outputConnectionSpec) override;
 
   virtual Token* registerForWrite(Placement* placement, const void* obj, const RootType& classDesc) override;
 
   virtual void setObjPtr(void*& obj, const Token* token) override;
 
   StatusCode createAddress(long svcType,
           const CLID& clid,
           const std::string* par,
           const unsigned long* ip,
           IOpaqueAddress*& refpAddress) override;
 
   virtual StatusCode createAddress(long svcType,
           const CLID& clid,
           const std::string& refAddress,
           IOpaqueAddress*& refpAddress) override;
 
   virtual StatusCode makeServer(int num) override;
 
   virtual StatusCode makeClient(int num) override;
 
   virtual StatusCode readData() override;
 
   virtual StatusCode commitCatalog() override;
 
   StatusCode abortSharedWrClients(int client_n);
 
   virtual void handle(const Incident& incident) override;
 
   AthenaPoolSharedIOCnvSvc(const std::string& name, ISvcLocator* pSvcLocator);
   virtual ~AthenaPoolSharedIOCnvSvc() = default;
 
private: // data
   ServiceHandle<IAthenaSerializeSvc> m_serializeSvc{this,"AthenaRootSerializeSvc","AthenaRootSerializeSvc"};
   ToolHandle<IAthenaIPCTool>    m_inputStreamingTool{this,"InputStreamingTool",{}};
   ToolHandle<IAthenaIPCTool>    m_outputStreamingTool{this,"OutputStreamingTool",{}};
   bool m_streamServerActive=false;
   int m_metadataClient=0;
 
private: // properties
   StringProperty  m_metadataContainerProp{this,"OutputMetadataContainer","MetaData"};
   StringArrayProperty m_metadataContainersAug{this, "OutputMetadataContainers", {}, "Metadata containers used for augmentations"};
 
   IntegerProperty m_makeStreamingToolClient{this,"MakeStreamingToolClient",0};
   IntegerProperty m_streamingTechnology{this,"StreamingTechnology",-1};
   BooleanProperty m_parallelCompression{this,"ParallelCompression",true};
   StringProperty  m_streamPortString{this,"StreamPortString","?pmerge=localhost:0"};
};
 
#endif