AthenaRootSharedWriterSvc.h

Go to the documentation of this file.

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

 
#include "AthenaBaseComps/AthService.h"
#include "AthenaKernel/IAthenaSharedWriterSvc.h"
#include "AthenaPoolSharedIOCnvSvc.h"
 
#include "THashTable.h"
#include <unordered_map>
 
class TServerSocket;
class TMonitor;

class AthenaRootSharedWriterSvc : public extends<AthService, IAthenaSharedWriterSvc> {
   // Allow the factory class access to the constructor
   friend class SvcFactory<AthenaRootSharedWriterSvc>;
 
public: // Constructor and Destructor
   AthenaRootSharedWriterSvc(const std::string& name, ISvcLocator* pSvcLocator);
   virtual ~AthenaRootSharedWriterSvc() = default;
 
public:
   virtual StatusCode initialize() override;
   virtual StatusCode stop() override;
   virtual StatusCode finalize() override;
 
   virtual StatusCode share(int numClients = 0, bool motherClient = false) override;
 
private:
   ServiceHandle<AthenaPoolSharedIOCnvSvc> m_cnvSvc{this,"AthenaPoolSharedIOCnvSvc","AthenaPoolSharedIOCnvSvc"};
 
   TServerSocket* m_rootServerSocket;
   TMonitor* m_rootMonitor;
   THashTable m_rootMergers;
   std::unordered_map<TClass*, void*> m_dummyCache;
   int m_rootClientIndex;
   int m_rootClientCount;
   int m_numberOfStreams;
};
 
#endif