IPoolSvc.h

Go to the documentation of this file.

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

 
#include "GaudiKernel/IService.h"
#include "GaudiKernel/IFileMgr.h"
 
#include "DataModelRoot/RootType.h"
 
#include "StorageSvc/FileDescriptor.h"
 
#include <string>
 
namespace pool {
   class DbType;
}
 
class Placement;
class Token;
 

class IPoolSvc : virtual public IService {
 
public: // static members
   enum PoolStream { kInputStream, kOutputStream };
 
public: // Non-static members
   DeclareInterfaceID(IPoolSvc, 1, 0);

   virtual Token* registerForWrite(const Placement* placement,
                                   const void* obj,
                                   const RootType& classDesc) = 0;

   virtual void setObjPtr(void*& obj, const Token* token) = 0;

   virtual unsigned int getOutputContext(const std::string& label) = 0;

   virtual unsigned int getInputContext(const std::string& label, unsigned int maxFile = 0) = 0;

   virtual std::map<std::string, unsigned int> getInputContextMap() const  = 0;

   virtual unsigned int getInputContextMapSize() const = 0;

   virtual pool::FileDescriptor getInputFileDescriptor(unsigned int contextId,
                                                       const std::string& connection) = 0;

   virtual void setShareMode(bool shareCat) = 0;

   virtual void startCatalog() = 0;

   virtual void commitCatalog() = 0;

   virtual void lookupBestPfn(const std::string& dbID, std::string& pfn, std::string& type) const = 0;

   virtual StatusCode connectCollection(const std::string& connection,
       const std::string& collectionName,
       unsigned int contextId = IPoolSvc::kInputStream) = 0;

   virtual
   StatusCode checkCollection(const std::string& connection,
           unsigned int contextId,
           bool noContainer) = 0;

   virtual Token* getToken(const std::string& connection,
       const std::string& collection,
       const unsigned long ientry) = 0;

   virtual StatusCode connect(Io::IoFlag type,
       unsigned int contextId = IPoolSvc::kInputStream) = 0;

   virtual StatusCode commit(unsigned int contextId = IPoolSvc::kInputStream) = 0;

   virtual StatusCode commitAndHold(unsigned int contextId = IPoolSvc::kInputStream) = 0;

   virtual StatusCode disconnect(unsigned int contextId = IPoolSvc::kInputStream) = 0;

   virtual StatusCode disconnectDb(const std::string& connection,
       unsigned int contextId = IPoolSvc::kInputStream) = 0;

   virtual StatusCode getAttribute(const std::string& optName,
       std::string& data,
       long tech,
       unsigned int contextId = IPoolSvc::kInputStream) = 0;

   virtual StatusCode getAttribute(const std::string& optName,
       std::string& data,
       long tech,
       const std::string& dbName,
       const std::string& contName = "",
       unsigned int contextId = IPoolSvc::kInputStream) = 0;

   virtual StatusCode setAttribute(const std::string& optName,
       const std::string& data,
       long tech,
       unsigned int contextId = IPoolSvc::kOutputStream) = 0;

   virtual StatusCode setAttribute(const std::string& optName,
       const std::string& data,
       long tech,
       const std::string& dbName,
       const std::string& contName = "",
       unsigned int contextId = IPoolSvc::kOutputStream) = 0;
 
};
 
#endif