ProxyProviderSvc.h

Go to the documentation of this file.

// -*- C++ -*-
 
/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/

 
 
#ifndef SGCOMPS_PROXYPROVIDERSVC_H
# define SGCOMPS_PROXYPROVIDERSVC_H 1
 
#include "AthenaKernel/IProxyProviderSvc.h"
#include "AthenaKernel/StoreID.h"
#include "Gaudi/Property.h" /*StringArrayProperty*/
#include "GaudiKernel/StatusCode.h"
#include <cassert>
#include <list>
#include <string>
#include <algorithm>
#include <vector>
 
// framework includes
#include "AthenaBaseComps/AthService.h"
 
namespace SG {
  class DataProxy;
  class TransientAddress;
}
 
class IAddressProvider;
class IProxyRegistry; //this is DataStore
class IConversionSvc;
class IOpaqueAddress;
class ISvcLocator;

class ProxyProviderSvc : public extends<AthService, IProxyProviderSvc>
{
public:
  typedef std::list<IAddressProvider*>::iterator  pAPiterator;
  typedef std::list<SG::TransientAddress*> TAdList;
  typedef TAdList::iterator TAdIterator;



  virtual StatusCode preLoadProxies(IProxyRegistry& storeToModify) override;

  virtual StatusCode loadProxies(IProxyRegistry& storeToModify) override;

  virtual SG::DataProxy* retrieveProxy(const CLID& id, const std::string& key,
                       IProxyRegistry& storeToModify) override;

  SG::DataProxy* addAddress(IProxyRegistry& storeToModify, 
                SG::TransientAddress&& tad);
 

  virtual void addProvider(IAddressProvider* aProvider) override final;


  virtual StatusCode initialize() override;

  ProxyProviderSvc(const std::string& name, ISvcLocator* svcLoc);
  virtual ~ProxyProviderSvc();
 
private:
   const EventContext& contextFromStore (IProxyRegistry& ds) const;
 

  StatusCode addAddresses(IProxyRegistry& store, 
                          TAdList& tList);
 
  
  StringArrayProperty m_providerNames{this,"ProviderNames",{},
      "names of the services to be use as address providers","OrderedSet<std::string>"};

  void providerNamesPropertyHandler( Gaudi::Details::PropertyBase& theProp );
  
  StatusCode doPreLoadProxies(IProxyRegistry& storeToModify);

  std::list<IAddressProvider*> m_providers; 
  ServiceHandle<IConversionSvc> m_pDataLoader;

  std::vector<IProxyRegistry*> m_pendingLoad;
};
 
 
inline void ProxyProviderSvc::addProvider(IAddressProvider* aProvider) {
  assert(aProvider);
  if (find(m_providers.begin(), m_providers.end(), aProvider) == m_providers.end()) {
    m_providers.push_back(aProvider);
  }
}
 
#endif // !SGCOMPS_PROXYPROVIDERSVC_H