#include <StorageSvc/DbContainerImp.h>

Inheritance diagram for pool::DbContainerImp:

Collaboration diagram for pool::DbContainerImp:

Classes
struct	DbAction
	List of actions to execute at commit. More...

Public Member Functions
	DbContainerImp (const std::string &name)

virtual void	release () override
	Release instance (Abstract interfaces do not expose destructor!) More...

virtual uint64_t	size () override
	Size of the container. More...

virtual std::string	name () const override
	Get container name. More...

virtual uint64_t	nextRecordId () override
	Number of next record in the container (=size if no delete is allowed) More...

virtual void	useNextRecordId (uint64_t) override
	Suggest next Record ID for tbe next object written - used only with synced indexes. More...

virtual DbStatus	close () override
	Close the container and deallocate resources. More...

virtual DbStatus	getOption (DbOption &opt) override
	Access options. More...

virtual DbStatus	setOption (const DbOption &opt) override
	Set options. More...

virtual DbStatus	transAct (Transaction::Action) override
	Execute Transaction Action. More...

virtual DbStatus	store (const void *object, DbContainer &cntH, ShapeH shape) override
	Store object in location. More...

virtual DbStatus	allocate (DbContainer &cntH, const void *object, ShapeH shape, Token::OID_t &oid) override
	In place allocation of object location. More...

virtual DbStatus	fetch (DbSelect &sel) override
	Fetch next object address of the selection to set token. More...

virtual DbStatus	load (void **ptr, ShapeH shape, const Token::OID_t &lnkH, Token::OID_t &oid, bool any_next) override
	Find object within the container and load it into memory. More...

virtual DbStatus	clearStack ()
	Clear Transaction stack containing transaction requests. More...

virtual DbStatus	fetch (const Token::OID_t &linkH, Token::OID_t &stmt)
	Fetch refined object address. Default implementation returns identity. More...

virtual DbStatus	loadObject (void **ptr, ShapeH shape, Token::OID_t &oid)=0
	Find object by object identifier and load it into memory. More...

virtual DbStatus	open (DbDatabase &dbH, const std::string &nam, const DbTypeInfo *info, DbAccessMode mode)=0
	Open the container. More...

virtual DbStatus	checkAccess (DbDatabase &dbH, const std::string &nam) const =0
	Check if we can access the container for reading with the given type. More...

virtual DbStatus	select (DbSelect &sel)=0
	Define selection. More...

bool	msgLvl (const MSG::Level lvl) const
	Test the output level. More...

MsgStream &	msg () const
	The standard message stream. More...

MsgStream &	msg (const MSG::Level lvl) const
	The standard message stream. More...

void	setLevel (MSG::Level lvl)
	Change the current logging level. More...

Protected Types
typedef std::vector< DbAction >	ActionList

Protected Member Functions
virtual	~DbContainerImp ()
	Standard destructor. More...

int	stackType () const
	Access accumulated stack entry types. More...

size_t	stackSize () const
	Access stack size. More...

ActionList::value_type *	stackEntry (size_t which)
	Internal: get access to stack entry. More...

virtual DbStatus	writeObject (ActionList::value_type &)
	Commit single entry to container. More...

virtual DbStatus	commitTransaction ()
	Execute object modification requests during a transaction. More...

Protected Attributes
std::string	m_name
	Container name. More...

bool	m_canUpdate
	Flag to indicate if object updates are supported. More...

bool	m_canDestroy
	Flag to indicate if object removals are supported. More...

Private Member Functions
void	initMessaging () const
	Initialize our message level and MessageSvc. More...

Private Attributes
ActionList	m_stack
	Transaction fifo storage for writing. More...

size_t	m_size
	Current size of the transaction stack. More...

size_t	m_writeSize
	Number of objects to be written out during open transaction. More...

int	m_stackType
	Accumulated stack entry types. More...

std::string	m_nm
	Message source name. More...

boost::thread_specific_ptr< MsgStream >	m_msg_tls
	MsgStream instance (a std::cout like with print-out levels) More...

std::atomic< IMessageSvc * >	m_imsg { nullptr }
	MessageSvc pointer. More...

std::atomic< MSG::Level >	m_lvl { MSG::NIL }
	Current logging level. More...

std::atomic_flag m_initialized	ATLAS_THREAD_SAFE = ATOMIC_FLAG_INIT
	Messaging initialized (initMessaging) More...

Detailed Description

"Generic" Container implementation

Description: Generic helper class to implement stuff common to all existing Database containers. The base implementations can allways be overwritten.

Author: M.Frank

Version: 1.0

Definition at line 44 of file DbContainerImp.h.

Member Typedef Documentation

◆ ActionList

typedef std::vector< DbAction > pool::DbContainerImp::ActionList

protected

Definition at line 64 of file DbContainerImp.h.

Constructor & Destructor Documentation

◆ ~DbContainerImp()

virtual pool::DbContainerImp::~DbContainerImp ( )

protectedvirtual

Standard destructor.

◆ DbContainerImp()

pool::DbContainerImp::DbContainerImp ( const std::string & name )

explicit

Member Function Documentation

◆ allocate()

virtual DbStatus pool::DbContainerImp::allocate	(	DbContainer &	cntH,
		const void *	object,
		ShapeH	shape,
		Token::OID_t &	oid
	)

overridevirtual

In place allocation of object location.

Implements pool::IDbContainer.

◆ checkAccess()

virtual DbStatus pool::IDbContainer::checkAccess	(	DbDatabase &	dbH,
		const std::string &	nam
	)		const

pure virtualinherited

Check if we can access the container for reading with the given type.

Implemented in RNTupleContainer, pool::RootTreeContainer, and pool::RootKeyContainer.

◆ clearStack()

virtual DbStatus pool::DbContainerImp::clearStack ( )

virtual

Clear Transaction stack containing transaction requests.

◆ close()

virtual DbStatus pool::DbContainerImp::close ( )

overridevirtual

Close the container and deallocate resources.

Implements pool::IDbContainer.

Reimplemented in RNTupleContainer, pool::RootTreeContainer, and pool::RootKeyContainer.

◆ commitTransaction()

virtual DbStatus pool::DbContainerImp::commitTransaction ( )

protectedvirtual

Execute object modification requests during a transaction.

◆ fetch() [1/2]

virtual DbStatus pool::DbContainerImp::fetch	(	const Token::OID_t &	linkH,
		Token::OID_t &	stmt
	)

virtual

Fetch refined object address. Default implementation returns identity.

Reimplemented in pool::RootTreeContainer, and pool::RootKeyContainer.

◆ fetch() [2/2]

virtual DbStatus pool::DbContainerImp::fetch ( DbSelect & sel )

overridevirtual

Fetch next object address of the selection to set token.

Implements pool::IDbContainer.

Reimplemented in RNTupleContainer, pool::RootTreeContainer, and pool::RootKeyContainer.

◆ getOption()

virtual DbStatus pool::DbContainerImp::getOption ( DbOption & opt )

overridevirtual

Access options.

Parameters

opt	[IN] Reference to option object.

Returns: DbStatus code indicating success or failure.

Implements pool::IDbContainer.

Reimplemented in RNTupleContainer, pool::RootTreeContainer, and pool::RootKeyContainer.

◆ initMessaging()

void AthMessaging::initMessaging ( ) const

privateinherited

Initialize our message level and MessageSvc.

This method should only be called once.

Definition at line 39 of file AthMessaging.cxx.

 {
   m_imsg = Athena::getMessageSvc();
   // If user did not set an explicit level, set a default
   if (m_lvl == MSG::NIL) {
     m_lvl = m_imsg ?
       static_cast<MSG::Level>( m_imsg.load()->outputLevel(m_nm) ) :
       MSG::INFO;
   }
 }

◆ load()

virtual DbStatus pool::DbContainerImp::load	(	void **	ptr,
		ShapeH	shape,
		const Token::OID_t &	lnkH,
		Token::OID_t &	oid,
		bool	any_next
	)

overridevirtual

Find object within the container and load it into memory.

Parameters

ptr	[IN/OUT] ROOT-style address of the pointer to object
shape	[IN] Object type
linkH	[IN] Preferred object OID
oid	[OUT] Actual object OID
any_next	[IN] On selection, objects may be skipped. If objects are skipped, the actual oid will differ from the preferred oid.

Returns: Status code indicating success or failure.

Implements pool::IDbContainer.

Reimplemented in pool::RootKeyContainer.

◆ loadObject()

virtual DbStatus pool::DbContainerImp::loadObject	(	void **	ptr,
		ShapeH	shape,
		Token::OID_t &	oid
	)

pure virtual

Find object by object identifier and load it into memory.

Parameters

ptr	[IN/OUT] ROOT-style address of the pointer to object
shape	[IN] Object type
oid	[OUT] Object OID

Returns: Status code indicating success or failure.

Implemented in pool::RootTreeContainer, pool::RootKeyContainer, pool::RootTreeIndexContainer, and RNTupleContainer.

◆ msg() [1/2]

MsgStream & AthMessaging::msg ( ) const

inlineinherited

The standard message stream.

Returns a reference to the default message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 163 of file AthMessaging.h.

 {
   MsgStream* ms = m_msg_tls.get();
   if (!ms) {
     if (!m_initialized.test_and_set()) initMessaging();
     ms = new MsgStream(m_imsg,m_nm);
     m_msg_tls.reset( ms );
   }
  
   ms->setLevel (m_lvl);
   return *ms;
 }

◆ msg() [2/2]

MsgStream & AthMessaging::msg ( const MSG::Level lvl ) const

inlineinherited

The standard message stream.

Returns a reference to the default message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 178 of file AthMessaging.h.

179 { return msg() << lvl; }

◆ msgLvl()

bool AthMessaging::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Test the output level.

Parameters

lvl	The message level to test against

Returns: boolean Indicating if messages at given level will be printed

Return values

true	Messages at level "lvl" will be printed

Definition at line 151 of file AthMessaging.h.

 {
   if (m_lvl <= lvl) {
     msg() << lvl;
     return true;
   } else {
     return false;
   }
 }

◆ name()

virtual std::string pool::DbContainerImp::name ( ) const

inlineoverridevirtual

Get container name.

Implements pool::IDbContainer.

Definition at line 107 of file DbContainerImp.h.

108 { return m_name; }

◆ nextRecordId()

virtual uint64_t pool::DbContainerImp::nextRecordId ( )

overridevirtual

Number of next record in the container (=size if no delete is allowed)

Implements pool::IDbContainer.

Reimplemented in RNTupleContainer, pool::RootTreeIndexContainer, and pool::RootKeyContainer.

◆ open()

virtual DbStatus pool::IDbContainer::open	(	DbDatabase &	dbH,
		const std::string &	nam,
		const DbTypeInfo *	info,
		DbAccessMode	mode
	)

pure virtualinherited

Open the container.

Implemented in RNTupleContainer, pool::RootTreeContainer, pool::RootKeyContainer, and pool::RootTreeIndexContainer.

◆ release()

virtual void pool::DbContainerImp::release ( )

inlineoverridevirtual

Release instance (Abstract interfaces do not expose destructor!)

Implements pool::IDbContainer.

Definition at line 103 of file DbContainerImp.h.

103 { delete this; }

◆ select()

virtual DbStatus pool::IDbContainer::select ( DbSelect & sel )

pure virtualinherited

Define selection.

Implemented in RNTupleContainer, pool::RootTreeContainer, and pool::RootKeyContainer.

◆ setLevel()

void AthMessaging::setLevel ( MSG::Level lvl )

inherited

Change the current logging level.

Use this rather than msg().setLevel() for proper operation with MT.

Definition at line 28 of file AthMessaging.cxx.

 {
   m_lvl = lvl;
 }

◆ setOption()

virtual DbStatus pool::DbContainerImp::setOption ( const DbOption & opt )

overridevirtual

Set options.

Parameters

opt	[IN] Reference to option object.

Returns: DbStatus code indicating success or failure.

Implements pool::IDbContainer.

Reimplemented in RNTupleContainer, pool::RootTreeContainer, and pool::RootKeyContainer.

◆ size()

virtual uint64_t pool::DbContainerImp::size ( )

overridevirtual

Size of the container.

Implements pool::IDbContainer.

Reimplemented in RNTupleContainer, pool::RootTreeContainer, and pool::RootKeyContainer.

◆ stackEntry()

ActionList::value_type* pool::DbContainerImp::stackEntry ( size_t which )

inlineprotected

Internal: get access to stack entry.

Definition at line 92 of file DbContainerImp.h.

93 { return (which <= m_size) ? &(*(m_stack.begin()+which)) : 0; }

◆ stackSize()

size_t pool::DbContainerImp::stackSize ( ) const

inlineprotected

Access stack size.

Definition at line 89 of file DbContainerImp.h.

90 { return m_size; }

◆ stackType()

int pool::DbContainerImp::stackType ( ) const

inlineprotected

Access accumulated stack entry types.

Definition at line 86 of file DbContainerImp.h.

87 { return m_stackType; }

◆ store()

virtual DbStatus pool::DbContainerImp::store	(	const void *	object,
		DbContainer &	cntH,
		ShapeH	shape
	)

overridevirtual

Store object in location.

Implements pool::IDbContainer.

Reimplemented in RNTupleContainer.

◆ transAct()

virtual DbStatus pool::DbContainerImp::transAct ( Transaction::Action )

overridevirtual

Execute Transaction Action.

Implements pool::IDbContainer.

Reimplemented in pool::RootTreeContainer, pool::RootKeyContainer, and RNTupleContainer.

◆ useNextRecordId()

virtual void pool::DbContainerImp::useNextRecordId ( uint64_t )

inlineoverridevirtual

Suggest next Record ID for tbe next object written - used only with synced indexes.

Implements pool::IDbContainer.

Reimplemented in pool::RootTreeIndexContainer, and RNTupleContainer.

Definition at line 112 of file DbContainerImp.h.

112 {};

◆ writeObject()

virtual DbStatus pool::DbContainerImp::writeObject ( ActionList::value_type & )

inlineprotectedvirtual

Commit single entry to container.

Reimplemented in RNTupleContainer, pool::RootTreeContainer, pool::RootKeyContainer, and pool::RootTreeIndexContainer.

Definition at line 95 of file DbContainerImp.h.

96 { return Error; }

Member Data Documentation

◆ ATLAS_THREAD_SAFE

std::atomic_flag m_initialized AthMessaging::ATLAS_THREAD_SAFE = ATOMIC_FLAG_INIT

mutableprivateinherited

Messaging initialized (initMessaging)

Definition at line 141 of file AthMessaging.h.

◆ m_canDestroy

bool pool::DbContainerImp::m_canDestroy

protected

Flag to indicate if object removals are supported.

Definition at line 81 of file DbContainerImp.h.

◆ m_canUpdate

bool pool::DbContainerImp::m_canUpdate

protected

Flag to indicate if object updates are supported.

Definition at line 79 of file DbContainerImp.h.

◆ m_imsg

std::atomic<IMessageSvc*> AthMessaging::m_imsg { nullptr }

mutableprivateinherited

MessageSvc pointer.

Definition at line 135 of file AthMessaging.h.

◆ m_lvl

std::atomic<MSG::Level> AthMessaging::m_lvl { MSG::NIL }

mutableprivateinherited

Current logging level.

Definition at line 138 of file AthMessaging.h.

◆ m_msg_tls

boost::thread_specific_ptr<MsgStream> AthMessaging::m_msg_tls

mutableprivateinherited

MsgStream instance (a std::cout like with print-out levels)

Definition at line 132 of file AthMessaging.h.

◆ m_name

std::string pool::DbContainerImp::m_name

protected

Container name.

Definition at line 77 of file DbContainerImp.h.

◆ m_nm

std::string AthMessaging::m_nm

privateinherited

Message source name.

Definition at line 129 of file AthMessaging.h.

◆ m_size

size_t pool::DbContainerImp::m_size

private

Current size of the transaction stack.

Definition at line 70 of file DbContainerImp.h.

◆ m_stack

ActionList pool::DbContainerImp::m_stack

private

Transaction fifo storage for writing.

Definition at line 68 of file DbContainerImp.h.

◆ m_stackType

int pool::DbContainerImp::m_stackType

private

Accumulated stack entry types.

Definition at line 74 of file DbContainerImp.h.

◆ m_writeSize

size_t pool::DbContainerImp::m_writeSize

private

Number of objects to be written out during open transaction.

Definition at line 72 of file DbContainerImp.h.

The documentation for this class was generated from the following file:

DbContainerImp.h

Classes

Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ ActionList

Constructor & Destructor Documentation

◆ ~DbContainerImp()

◆ DbContainerImp()

Member Function Documentation

◆ allocate()

◆ checkAccess()

◆ clearStack()

◆ close()

◆ commitTransaction()

◆ fetch() [1/2]

◆ fetch() [2/2]

◆ getOption()

◆ initMessaging()

◆ load()

◆ loadObject()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ name()

◆ nextRecordId()

◆ open()

◆ release()

◆ select()

◆ setLevel()

◆ setOption()

◆ size()

◆ stackEntry()

◆ stackSize()

◆ stackType()

◆ store()

◆ transAct()

◆ useNextRecordId()

◆ writeObject()

Member Data Documentation

◆ ATLAS_THREAD_SAFE

◆ m_canDestroy

◆ m_canUpdate

◆ m_imsg

◆ m_lvl

◆ m_msg_tls

◆ m_name

◆ m_nm

◆ m_size

◆ m_stack

◆ m_stackType

◆ m_writeSize