![Logo](../../ATLAS-Logo-Square-Blue-RGB.png) |
ATLAS Offline Software
|
Go to the documentation of this file.
12 #include "GaudiKernel/IIoComponentMgr.h"
13 #include "GaudiKernel/ConcurrencyFlags.h"
17 #include "CoralKernel/Context.h"
36 #include "RelationalAccess/ConnectionService.h"
37 #include "RelationalAccess/IConnectionServiceConfiguration.h"
38 #include "RelationalAccess/IWebCacheControl.h"
39 #include "RelationalAccess/IWebCacheInfo.h"
40 #include "RelationalAccess/ILookupService.h"
41 #include "RelationalAccess/IDatabaseServiceSet.h"
42 #include "RelationalAccess/IDatabaseServiceDescription.h"
53 return !
s.empty() and ( isdigit(
s[0]) or
s[0]==
'+' or
s[0]==
'-' );
60 return(StatusCode::FAILURE);
65 if (!iomgr.retrieve().isSuccess()) {
67 return(StatusCode::FAILURE);
69 if (!iomgr->io_register(
this).isSuccess()) {
70 ATH_MSG_FATAL(
"Could not register myself with the IoComponentMgr !");
71 return(StatusCode::FAILURE);
76 if (
catalog.compare(0, 16,
"xmlcatalog_file:") == 0) {
86 if (
m_writeCatalog.value().compare(0, 16,
"xmlcatalog_file:") == 0) {
96 return(StatusCode::FAILURE);
101 return(StatusCode::FAILURE);
103 coral::ConnectionService conSvcH;
104 coral::IConnectionServiceConfiguration& csConfig = conSvcH.configuration();
108 csConfig.enablePoolAutomaticCleanUp();
109 csConfig.setConnectionTimeOut(
m_timeOut);
111 csConfig.disablePoolAutomaticCleanUp();
112 csConfig.setConnectionTimeOut(0);
114 ATH_MSG_INFO(
"Set connectionsvc retry/timeout/IDLE timeout to "
120 <<
" seconds with connection cleanup "
121 << (csConfig.isPoolAutomaticCleanUpEnabled() ?
"enabled" :
"disabled"));
123 coral::IWebCacheControl& webCache = conSvcH.webCacheControl();
125 ATH_MSG_INFO(
"Frontier compression level set to " << webCache.compressionLevel());
129 if (Gaudi::svcLocator()->service(
"DBReplicaSvc", replicasvc).isSuccess()) {
130 csConfig.setReplicaSortingAlgorithm(*replicasvc);
131 ATH_MSG_INFO(
"Successfully setup replica sorting algorithm");
146 if (!iomgr.retrieve().isSuccess()) {
148 return(StatusCode::FAILURE);
150 if (!iomgr->io_hasitem(
this)) {
151 ATH_MSG_FATAL(
"IoComponentMgr does not know about myself !");
152 return(StatusCode::FAILURE);
155 for (std::size_t icat = 0,
imax = readcat.size(); icat <
imax; icat++) {
156 if (readcat[icat].
compare(0, 16,
"xmlcatalog_file:") == 0) {
157 std::string
fileName = readcat[icat].substr(16);
158 if (iomgr->io_contains(
this,
fileName)) {
159 if (!iomgr->io_retrieve(
this,
fileName).isSuccess()) {
161 return(StatusCode::FAILURE);
163 readcat[icat] =
"xmlcatalog_file:" +
fileName;
169 if (
m_writeCatalog.value().compare(0, 16,
"xmlcatalog_file:") == 0) {
171 if (iomgr->io_contains(
this,
fileName)) {
172 if (!iomgr->io_retrieve(
this,
fileName).isSuccess()) {
174 return(StatusCode::FAILURE);
192 return(StatusCode::FAILURE);
198 ATH_MSG_FATAL(
"Failed to enable thread safety in ROOT via PersistencySvc.");
199 return(StatusCode::FAILURE);
204 return(StatusCode::FAILURE);
215 return(StatusCode::SUCCESS);
222 ATH_MSG_FATAL(
"Failed to enable implicit multithreading in ROOT via PersistencySvc.");
223 return(StatusCode::FAILURE);
227 return(StatusCode::SUCCESS);
231 bool retError =
false;
238 return(retError ? StatusCode::FAILURE : StatusCode::SUCCESS);
245 delete persistencySvc;
248 for (
const auto& persistencyMutex :
m_pers_mut) {
249 delete persistencyMutex;
275 return(StatusCode::SUCCESS);
280 *ppvInterface =
dynamic_cast<IPoolSvc*
>(
this);
283 return(::AthService::queryInterface(riid, ppvInterface));
286 return(StatusCode::SUCCESS);
293 const std::string& auxString = placement->
auxString();
294 if (!auxString.empty()) {
295 if (auxString.compare(0, 6,
"[CTXT=") == 0) {
296 ::sscanf(auxString.c_str(),
"[CTXT=%08X]", &contextId);
297 }
else if (auxString.compare(0, 8,
"[CLABEL=") == 0) {
301 ATH_MSG_WARNING(
"registerForWrite: Using default output Stream instead of id = " << contextId);
305 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
307 if (token ==
nullptr) {
315 const std::string& auxString = token->
auxString();
316 if (!auxString.empty()) {
317 if (auxString.compare(0, 6,
"[CTXT=") == 0) {
318 ::sscanf(auxString.c_str(),
"[CTXT=%08X]", &contextId);
319 }
else if (auxString.compare(0, 8,
"[CLABEL=") == 0) {
323 ATH_MSG_WARNING(
"setObjPtr: Using default input Stream instead of id = " << contextId);
327 ATH_MSG_VERBOSE(
"setObjPtr: token=" << token->
toString() <<
", auxString=" << auxString <<
", contextID=" << contextId);
329 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
331 std::map<unsigned int, unsigned int>::const_iterator maxFileIter =
m_contextMaxFile.find(contextId);
333 m_guidLists[contextId].remove(token->
dbID());
334 m_guidLists[contextId].push_back(token->
dbID());
335 while (m_guidLists[contextId].
size() > maxFileIter->second) {
352 return(contextIter->second);
370 if (!
label.empty()) {
376 return(contextIter->second);
386 if (!
label.empty()) {
415 if (token.compare(0, 4,
"PFN:") == 0) {
417 }
else if (token.compare(0, 4,
"LFN:") == 0) {
419 }
else if (token.compare(0, 4,
"FID:") == 0) {
420 dbID = token.substr(4);
432 std::string dbID,
type;
447 const std::string& connection,
448 const std::string& collectionName,
449 unsigned int contextId)
const {
450 ATH_MSG_DEBUG(
"createCollection() type="<< collectionType <<
", connection=" << connection
451 <<
", name=" << collectionName <<
", contextID=" << contextId);
452 std::string collection(collectionName);
453 if (collectionType ==
"RootCollection") {
454 if (collectionName.find(
"PFN:") == std::string::npos
455 && collectionName.find(
"LFN:") == std::string::npos
456 && collectionName.find(
"FID:") == std::string::npos) {
457 collection =
"PFN:" + collectionName;
461 ATH_MSG_WARNING(
"createCollection: Using default input Stream instead of id = " << contextId);
464 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
466 bool insertFile =
false;
467 if (connection.compare(0, 4,
"PFN:") == 0) {
468 std::string fid, fileType;
472 ATH_MSG_INFO(
"File is not in Catalog! Attempt to open it anyway.");
476 if (collectionType ==
"ImplicitCollection") {
477 std::unique_ptr<pool::IDatabase> dbH =
getDbHandle(contextId, connection);
478 if (dbH ==
nullptr) {
479 ATH_MSG_INFO(
"Failed to get Session/DatabaseHandle to create POOL collection.");
486 std::map<unsigned int, unsigned int>::const_iterator maxFileIter =
m_contextMaxFile.find(contextId);
487 if (maxFileIter !=
m_contextMaxFile.end() && maxFileIter->second > 0 && !dbH->
fid().empty()) {
489 m_guidLists[contextId].remove(
guid);
490 m_guidLists[contextId].push_back(
guid);
491 while (m_guidLists[contextId].
size() > maxFileIter->second + 1) {
496 if (contH ==
nullptr) {
497 ATH_MSG_INFO(
"Failed to find container " << collection <<
" to create POOL collection.");
504 ATH_MSG_INFO(
"Failed to open container to check POOL collection - trying.");
513 if (collectionType ==
"RootCollection" &&
515 ATH_MSG_INFO(
"Writing ExplicitROOT Collection - do not pass session pointer");
521 std::string tree_error, rntuple_error;
525 tree_error =
e.what();
528 collDes.
setType(
"RNTCollection");
532 std::unique_ptr<pool::IDatabase> dbH =
getDbHandle(contextId, connection);
533 if (dbH !=
nullptr) {
534 if (!dbH->
fid().empty()) {
539 rntuple_error =
e.what();
541 if( !collPtr )
throw pool::Exception(
"Failed to open APR Collection as RootCollection or RNTCollection: "
542 + tree_error +
" | " + rntuple_error,
543 "PoolSvc::createCollection",
"PoolSvc" );
546 std::unique_ptr<pool::IDatabase> dbH =
getDbHandle(contextId, connection);
547 if (dbH ==
nullptr) {
549 }
else if (dbH->
fid().empty()) {
550 ATH_MSG_INFO(
"Cannot retrieve the FID of an existing POOL database: '"
551 << connection <<
"' - FileCatalog will NOT be updated.");
558 if (
m_useROOTMaxTree && Gaudi::Concurrency::ConcurrencyFlags::numConcurrentEvents() > 1) {
570 std::string fid = dbH.
fid();
576 const std::string& collection,
577 const unsigned long ientry)
const {
580 if (dbH ==
nullptr) {
587 if (contH ==
nullptr) {
592 for (
unsigned long ipos = 0; ipos < ientry; ipos++) {
593 delete thisToken; thisToken = tokenIter->
next();
595 delete tokenIter; tokenIter =
nullptr;
602 ATH_MSG_WARNING(
"connect: Using default output Stream instead of id = " << contextId);
607 ATH_MSG_WARNING(
"connect: Using default input Stream instead of id = " << contextId);
610 ATH_MSG_INFO(
"Connecting to InputStream for: " << contextId);
615 return(StatusCode::FAILURE);
617 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
621 return(StatusCode::SUCCESS);
625 return(StatusCode::FAILURE);
628 return(StatusCode::SUCCESS);
633 return(StatusCode::FAILURE);
635 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
640 return(StatusCode::FAILURE);
646 return(StatusCode::SUCCESS);
651 return(StatusCode::FAILURE);
653 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
658 return(StatusCode::FAILURE);
661 return(StatusCode::SUCCESS);
665 ATH_MSG_DEBUG(
"Disconnect request for contextId=" << contextId);
667 return(StatusCode::SUCCESS);
669 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
672 if (!
commit(contextId).isSuccess()) {
674 return(StatusCode::FAILURE);
679 ATH_MSG_ERROR(
"disconnect failed to diconnect PersistencySvc");
680 return(StatusCode::FAILURE);
683 return(StatusCode::SUCCESS);
688 return(StatusCode::SUCCESS);
690 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
691 std::unique_ptr<pool::IDatabase> dbH =
getDbHandle(contextId, connection);
692 if (dbH ==
nullptr) {
694 return(StatusCode::FAILURE);
696 std::map<unsigned int, unsigned int>::const_iterator maxFileIter =
m_contextMaxFile.find(contextId);
698 m_guidLists[contextId].remove(
Guid(dbH->
fid()));
701 return(StatusCode::SUCCESS);
705 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
707 if (dbH ==
nullptr) {
708 ATH_MSG_DEBUG(
"getFileSize: Failed to get Session/DatabaseHandle to get POOL FileSize property.");
725 unsigned int contextId)
const {
727 ATH_MSG_WARNING(
"getAttribute: Using default input Stream instead of id = " << contextId);
730 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
732 std::ostringstream oss;
733 if (
data ==
"DbLonglong") {
735 }
else if (
data ==
"double") {
742 return(StatusCode::SUCCESS);
748 const std::string&
dbName,
749 const std::string& contName,
750 unsigned int contextId)
const {
751 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
753 if (dbH ==
nullptr) {
754 ATH_MSG_DEBUG(
"getAttribute: Failed to get Session/DatabaseHandle to get POOL property.");
755 return(StatusCode::FAILURE);
765 std::ostringstream oss;
766 if (contName.empty()) {
767 if (
data ==
"DbLonglong") {
769 }
else if (
data ==
"double") {
771 }
else if (
data ==
"string") {
776 ATH_MSG_INFO(
"Database (" << dbH->
pfn() <<
") attribute [" << optName <<
"]" <<
": " << oss.str());
779 if (contH ==
nullptr) {
780 ATH_MSG_DEBUG(
"Failed to get ContainerHandle to get POOL property.");
781 return(StatusCode::FAILURE);
783 if (
data ==
"DbLonglong") {
785 }
else if (
data ==
"double") {
790 ATH_MSG_INFO(
"Container attribute [" << contName <<
"." << optName <<
"]: " << oss.str());
793 return(StatusCode::SUCCESS);
797 const std::string&
data,
799 unsigned int contextId)
const {
801 ATH_MSG_WARNING(
"setAttribute: Using default output Stream instead of id = " << contextId);
804 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
809 return(StatusCode::FAILURE);
814 return(StatusCode::FAILURE);
817 return(StatusCode::SUCCESS);
821 const std::string&
data,
823 const std::string&
dbName,
824 const std::string& contName,
825 unsigned int contextId)
const {
827 ATH_MSG_WARNING(
"setAttribute: Using default output Stream instead of id = " << contextId);
830 std::lock_guard<CallMutex> lock(*
m_pers_mut[contextId]);
832 if (dbH ==
nullptr) {
833 ATH_MSG_DEBUG(
"Failed to get Session/DatabaseHandle to set POOL property.");
834 return(StatusCode::FAILURE);
844 bool retError =
false;
846 bool hasTTreeName = (contName.length() > 6 && contName.compare(0, 6,
"TTree=") == 0);
848 objName = hasTTreeName ? contName.substr(6) : contName;
851 }
else if(
data[
data.size() - 1] ==
'L' ) {
858 return(StatusCode::FAILURE);
862 if (contH ==
nullptr) {
863 ATH_MSG_DEBUG(
"Failed to get ContainerHandle to set POOL property.");
864 return(StatusCode::FAILURE);
866 if (
auto p = contName.find(
'(');
p != std::string::npos) {
867 objName = contName.substr(
p + 1);
868 objName.erase(objName.find(
')'));
869 }
else if (
auto p = contName.find(
"::");
p != std::string::npos) {
870 objName = contName.substr(
p + 2);
871 }
else if (
auto p = contName.find(
'_');
p != std::string::npos) {
872 objName = contName.substr(
p + 1);
873 objName.erase(objName.find(
'/'));
875 std::string::size_type off = 0;
876 while ((off = objName.find_first_of(
"<>/")) != std::string::npos) {
885 ATH_MSG_DEBUG(
"Failed to set POOL container property, " << optName <<
" for " << contName <<
" : " << objName <<
" to " <<
data);
886 return(StatusCode::FAILURE);
889 return(StatusCode::SUCCESS);
897 std::vector<std::string> physcons;
898 if (
conn.find(
':') == std::string::npos) {
901 const std::string lookSvcStr(
"CORAL/Services/XMLLookupService");
902 coral::IHandle<coral::ILookupService> lookSvcH =
m_context->query<coral::ILookupService>();
903 if (!lookSvcH.isValid()) {
905 lookSvcH =
m_context->query<coral::ILookupService>();
907 if (!lookSvcH.isValid()) {
909 return(StatusCode::FAILURE);
911 coral::IDatabaseServiceSet* dbset = lookSvcH->lookup(
conn, coral::ReadOnly);
912 if (dbset !=
nullptr) {
913 for (
int irep = 0, nrep = dbset->numberOfReplicas(); irep < nrep; ++irep) {
914 const std::string pcon = dbset->replica(irep).connectionString();
915 if (pcon.compare(0, 9,
"frontier:") == 0) {
916 physcons.push_back(pcon);
919 delete dbset; dbset =
nullptr;
923 }
else if (
conn.compare(0, 9,
"frontier:") == 0) {
924 physcons.push_back(
conn);
927 if (physcons.size() == 0) {
928 return(StatusCode::SUCCESS);
930 coral::ConnectionService conSvcH;
934 coral::IWebCacheControl& webCache = conSvcH.webCacheControl();
935 for (std::vector<std::string>::const_iterator iter = physcons.begin(), last = physcons.end();
936 iter != last; ++iter) {
943 webCache.refreshTable(*iter,
"DUMMYTABLE");
946 webCache.refreshSchemaInfo(*iter);
948 ATH_MSG_DEBUG(
"Cache flag for connection " << *iter <<
" set to " << webCache.webCacheInfo(*iter).isSchemaInfoCached());
950 return(StatusCode::SUCCESS);
958 if (
catalog.compare(0, 8,
"apcfile:") == 0 ||
catalog.compare(0, 7,
"prfile:") == 0) {
959 std::string::size_type cpos =
catalog.find(
':');
974 <<
" in $ATLAS_POOLCOND_PATH and $DATAPATH");
986 ATH_MSG_ERROR(
"setWriteCatalog - caught exception: " <<
e.what());
999 ATH_MSG_WARNING(
"getDbHandle: Using default input Stream instead of id = " << contextId);
1014 if (
dbName.compare(0, 4,
"PFN:") == 0) {
1016 }
else if (
dbName.compare(0, 4,
"LFN:") == 0) {
1018 }
else if (
dbName.compare(0, 4,
"FID:") == 0) {
1023 return(std::unique_ptr<pool::IDatabase>(dbH));
1028 if (dbH ==
nullptr) {
1035 if (contName.find(
"DataHeader") != std::string::npos) {
1036 contH = dbH->
containerHandle(contName.substr(0, contName.find(
"_p")));
1040 return(std::unique_ptr<pool::IContainer>(contH));
1046 const char* cpath =
std::getenv(
"ATLAS_POOLCOND_PATH");
1047 if (cpath && strcmp(cpath,
"") != 0) {
1048 const std::string testpath = std::string(cpath) +
"/" + leaf;
1052 if (FILE*
fp = std::fopen(testpath.c_str(),
"r")) {
virtual StatusCode stop() override
IntegerProperty m_timeOut
ConnectionTimeOut, the time out for CORAL Connection Service: default = 5 seconds.
virtual StatusCode queryInterface(const InterfaceID &riid, void **ppvInterface) override
Required of all Gaudi services: see Gaudi documentation for details.
char data[hepevt_bytes_allocation_ATLAS]
static CollectionFactory * get()
Retrieves the collection factory singleton.
static const Guid & null()
NULL-Guid: static class method.
def finalize(self)
_info( "content of StoreGate..." ) self.sg.dump()
std::pair< int, int > compare(const AmgSymMatrix(N) &m1, const AmgSymMatrix(N) &m2, double precision=1e-9, bool relative=false)
compare two matrices, returns the indices of the first element that fails the condition,...
This class holds all the necessary information to guide the writing of an object in a physical place.
std::map< unsigned int, std::list< Guid > > m_guidLists ATLAS_THREAD_SAFE
This class provides the interface to the LCG POOL persistency software.
void lookupFileByPFN(const std::string &pfn, std::string &fid, std::string &tech) const
Get FID and filetype for a given PFN.
std::unique_ptr< pool::IDatabase > getDbHandle(unsigned int contextId, const std::string &dbName) const
Get Database handle.
IntegerProperty m_retrialTimeOut
ConnectionRetrialTimeOut, the retrial time out for CORAL Connection Service: default = 300 seconds.
const std::string & containerName() const
Access container name.
bool setWriteModeForNonExisting(Mode mode)
Sets the opening mode when a non existing database is opened for writing Acceptable values are RAISE_...
std::string find(const std::string &s)
return a remapped string
static std::string find_file(const std::string &logical_file_name, const std::string &search_path, SearchType search_type=LocalSearch)
StringProperty m_fileOpen
FileOpen, the open mode for the file ("append" or "overwrite").
IntegerProperty m_frontierComp
Frontier proprties, compression level and list of schemas to be refreshed: default = 5.
void registerPFN(const std::string &pfn, const std::string &ftype, std::string &fid)
Register PFN, assign new FID if not given.
std::map< std::string, unsigned int > m_inputContextLabel
virtual StatusCode connect(pool::ITransaction::Type type, unsigned int contextId=IPoolSvc::kInputStream) override
Connect to a logical database unit; PersistencySvc is chosen according to transaction type (accessmod...
virtual StatusCode commit(unsigned int contextId=IPoolSvc::kInputStream) const override
Commit data for a given contextId and flush buffer.
BooleanProperty m_attemptCatalogPatch
AttemptCatalogPatch, option to create catalog: default = false.
virtual const ITechnologySpecificAttributes & technologySpecificAttributes() const =0
Returns the object holding the technology specific attributes for a given technology domain.
virtual void connectForRead()=0
Connects explicitly to the database for read operations.
const std::string & auxString() const
Access auxiliary string.
virtual const pool::IFileCatalog * catalog() const override
void renamePFN(const std::string &pfn, const std::string &newpfn)
Rename PFN.
virtual StatusCode disconnect(unsigned int contextId=IPoolSvc::kInputStream) const override
Disconnect PersistencySvc associated with a contextId.
const Guid & dbID() const
Access database identifier.
StringArrayProperty m_frontierRefresh
virtual bool disconnectAll()=0
Explicitly disconnects all the databases.
virtual const std::string & pfn()=0
Returns the physical file name of this database.
const std::string toString() const
Automatic conversion to string representation.
void commit()
Save catalog to file.
bool setAttribute(const std::string &attributeName, const T &atttibuteValue, const std::string &option="")
Templated method to set an attribute.
virtual ITokenIterator * tokens(const std::string &selection)=0
Starts an iteration over the tokens in the container.
coral::Context * m_context
#define ATH_MSG_VERBOSE(x)
virtual StatusCode setAttribute(const std::string &optName, const std::string &data, long tech, unsigned int contextId=IPoolSvc::kOutputStream) const override
Set POOL attributes - domain.
virtual ITransaction & transaction()=0
Returns the transaction object.
virtual const std::string & fid()=0
Returns the file identifier of this database.
virtual long long int getFileSize(const std::string &dbName, long tech, unsigned int contextId) const override
Get POOL FileSize attribute for database without logging a message.
StringProperty m_writeCatalog
WriteCatalog, the file catalog to be used to register output files (also default input catalog): defa...
virtual OpenMode openMode() const =0
Returns the opening mode. It can be used to check whether the database is connected.
virtual void setObjPtr(void *&obj, const Token *token) override
virtual Token * next()=0
Returns the pointer to next token.
BooleanProperty m_useROOTMaxTree
Increase virtual TTree size to avoid backreads in multithreading, default = false.
Type
Transaction type enumeration.
virtual const ITechnologySpecificAttributes & technologySpecificAttributes() const =0
Returns the object holding the technology specific attributes.
void lookupFileByLFN(const std::string &lfn, std::string &fid) const
Return the status of a LFName.
This class provides a token that identifies in a unique way objects on the persistent storage.
void setLevel(MsgLevel l)
static const InterfaceID & interfaceID()
Retrieve interface ID.
virtual void renamePfn(const std::string &pf, const std::string &newpf) override
std::recursive_mutex CallMutex
Token & fromString(const std::string &from)
Build from the string representation of a token.
std::vector< CallMutex * > m_pers_mut
std::string m_mainOutputLabel
Base exception class for the POOL system.
std::string toString(const Translation3D &translation, int precision=4)
GeoPrimitvesToStringConverter.
virtual const coral::Context * context() const override
virtual unsigned int getOutputContext(const std::string &label) override
This file contains the class definition for the PoolSvc class.
virtual bool commitAndHold()=0
Commits the holds transaction.
virtual void connectForWrite()=0
Connects explicitly to the database for write/update operations.
::StatusCode StatusCode
StatusCode definition for legacy code.
std::unique_ptr< pool::IContainer > getContainerHandle(pool::IDatabase *dbH, const std::string &contName) const
Get Container handle.
virtual const ITechnologySpecificAttributes & technologySpecificAttributes(long technology) const =0
Returns the object holding the technology specific attributes for a given technology domain.
void start()
redirect to init() for Gaudi FC
virtual bool start(Type type=READ)=0
Starts a new transaction. Returns the success of the operation.
bool setWriteModeForExisting(Mode mode)
Sets the opening mode when an existing database is opened for writing.
virtual Token * getToken(const std::string &connection, const std::string &collection, const unsigned long ientry) const override
virtual StatusCode disconnectDb(const std::string &connection, unsigned int contextId=IPoolSvc::kInputStream) const override
Disconnect single Database.
void setWriteCatalog(const std::string &connect)
Access to the (first) writable file catalog.
virtual bool setTechnology(long technology)=0
Sets the technology identifier for this database.
virtual void disconnect()=0
Disconnects from the database.
virtual pool::ICollection * createCollection(const std::string &collectionType, const std::string &connection, const std::string &collectionName, unsigned int contextId=IPoolSvc::kInputStream) const override
virtual StatusCode commitAndHold(unsigned int contextId=IPoolSvc::kInputStream) const override
Commit data for a given contextId and hold buffer.
const std::string & auxString() const
Access auxiliary string.
void removeCatalog(const std::string &connect)
Add new catalog identified by reference to the existing ones.
bool allGood
Loop over the SDOs & Digits.
BooleanProperty m_sortReplicas
Use DBReplicaSvc to sort database connections, default = true.
virtual StatusCode setFrontierCache(const std::string &conn) override
Setup Frontier cache for given logical or physical connection name.
virtual StatusCode getAttribute(const std::string &optName, std::string &data, long tech, unsigned int contextId=IPoolSvc::kInputStream) const override
Get POOL attributes - domain.
pool::IFileCatalog * m_catalog
std::map< unsigned int, unsigned int > m_contextMaxFile
virtual void setType(const std::string &type)
Sets the storage technology type of the collection.
StringArrayProperty m_readCatalog
ReadCatalog, the list of additional POOL input file catalogs to consult: default = empty vector.
IntegerProperty m_dbAgeLimit
MaxFilesOpen, option to have PoolSvc limit the number of open Input Files: default = 0 (No files are ...
virtual const std::string toString() const
Retrieve the string representation of the token.
void patchCatalog(const std::string &pfn, pool::IDatabase &dbH) const
virtual bool commit()=0
Commits the transaction.
virtual void loadComponent(const std::string &compName) override
virtual const std::map< std::string, unsigned int > & getInputContextMap() const override
std::string poolCondPath(const std::string &leaf)
Resolve a file using ATLAS_POOLCOND_PATH.
virtual void lookupBestPfn(const std::string &token, std::string &pfn, std::string &type) const override
virtual Token * registerForWrite(const Placement *placement, const void *obj, const RootType &classDesc) override
virtual IDatabase * databaseHandle(const std::string &dbName, DatabaseSpecification::NameType dbNameType)=0
Returns a pointer to a database object. The user acquires ownership of that object.
virtual StatusCode finalize() override
Required of all Gaudi services:
T attribute(const std::string &attributeName, const std::string &option="")
Templated method to retrieve an attribute.
void getFirstPFN(const std::string &fid, std::string &pfn, std::string &tech) const
Get the first PFN + filetype for the given FID.
virtual void setShareMode(bool shareCat) override
virtual StatusCode start() override
Required of all Gaudi services:
This class provides a encapsulation of a GUID/UUID/CLSID/IID data structure (128 bit number).
std::string getenv(const std::string &variableName)
get an environment variable
#define ATH_MSG_WARNING(x)
virtual StatusCode initialize() override
Required of all Gaudi services:
std::vector< pool::IPersistencySvc * > m_persistencySvcVec
StatusCode setupPersistencySvc()
virtual ISession & session()=0
Returns the underlying global session.
virtual IContainer * containerHandle(const std::string &name)=0
Returns a pointer to a container object. The user acquires ownership of that object.
virtual ~PoolSvc()
Destructor.
IntegerProperty m_retrialPeriod
ConnectionRetrialPeriod, retry period for CORAL Connection Service: default = 30 seconds.
int atoi(std::string_view str)
Helper functions to unpack numbers decoded in string into integers and doubles The strings are requir...
bool isNumber(const std::string &s)
pool::IFileCatalog * createCatalog()
virtual StatusCode io_reinit() override
This file contains the class definition for the Placement class (migrated from POOL).
static std::unique_ptr< IPersistencySvc > create(IFileCatalog &catalog)
Factory for PersistencySvc.
virtual unsigned int getInputContext(const std::string &label, unsigned int maxFile=0) override
This file contains the class definition for the Token class (migrated from POOL).
BooleanProperty m_connClean
ConnectionCleanUp - whether to use CORAL connection management thread: default = false.
void addReadCatalog(const std::string &connect)
Add new catalog identified by name to the existing ones.
virtual Type type() const =0
Returns the transaction type.
virtual StatusCode io_finalize() override
BooleanProperty m_useROOTIMT
Use ROOT Implicit MultiThreading, default = true.
virtual bool isActive() const =0
Checks if the transaction is active.
std::map< std::string, unsigned int > m_outputContextLabel