ProxyProviderSvc.h

Go to the documentation of this file.

// -*- C++ -*-
 
/*
  Copyright (C) 2002-2021 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; 
  IConversionSvc* m_pDataLoader{nullptr};   
 
  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