The Gaudi Framework  master (cc9a61f4)
Loading...
Searching...
No Matches
FileMgrTest Class Reference

an algorithm to test the FileMgr More...

#include </builds/gaudi/Gaudi/GaudiTestSuite/src/FileMgr/FileMgrTest.h>

Inheritance diagram for FileMgrTest:
Collaboration diagram for FileMgrTest:

Public Member Functions

 FileMgrTest (const std::string &name, ISvcLocator *pSvcLocator)
StatusCode initialize () override
StatusCode execute () override
StatusCode finalize () override
Public Member Functions inherited from Algorithm
 LegacyAlgorithmAdapter (std::string name, ISvcLocator *svcloc, std::string version=PACKAGE_VERSION)
Public Member Functions inherited from Gaudi::details::LegacyAlgorithmAdapter
 LegacyAlgorithmAdapter (std::string name, ISvcLocator *svcloc, std::string version=PACKAGE_VERSION)
const EventContextgetContext () const
bool isExecuted () const
 Has this algorithm been executed since the last reset?
void setExecuted (bool state) const
 Set the executed flag to the specified state.
bool filterPassed () const
 Did this algorithm pass or fail its filter criterion for the last event?
void setFilterPassed (bool state) const
 Set the filter passed flag to the specified state.
Public Member Functions inherited from Gaudi::Algorithm
 Algorithm (std::string name, ISvcLocator *svcloc, std::string version=PACKAGE_VERSION)
 Constructor.
StatusCode sysStart () override
 Reinitialization method invoked by the framework.
StatusCode sysInitialize () override
 Initialization method invoked by the framework.
StatusCode sysReinitialize () override
 Reinitialization method invoked by the framework.
StatusCode sysRestart () override
 Restart method invoked by the framework.
StatusCode sysExecute (const EventContext &ctx) override
 The actions to be performed by the algorithm on an event.
StatusCode sysStop () override
 System stop.
StatusCode sysFinalize () override
 System finalization.
const std::string & name () const override
 The identifying name of the algorithm object.
const Gaudi::StringKeynameKey () const override
const std::string & type () const override
 The type of the algorithm object.
void setType (std::string type) override
const std::string & version () const override
unsigned int index () const override
StatusCode configure () override
 Dummy implementation of IStateful::configure() method.
StatusCode terminate () override
 Dummy implementation of IStateful::terminate() method.
StatusCode initialize () override
 the default (empty) implementation of IStateful::initialize() method
StatusCode start () override
 the default (empty) implementation of IStateful::start() method
StatusCode stop () override
 the default (empty) implementation of IStateful::stop() method
StatusCode finalize () override
 the default (empty) implementation of IStateful::finalize() method
StatusCode reinitialize () override
 the default (empty) implementation of IStateful::reinitialize() method
StatusCode restart () override
 the default (empty) implementation of IStateful::restart() method
Gaudi::StateMachine::State FSMState () const override
 returns the current state of the algorithm
Gaudi::StateMachine::State targetFSMState () const override
 returns the state the algorithm will be in after the ongoing transition
bool isEnabled () const override
 Is this algorithm enabled or disabled?
bool isSequence () const override
 Are we a Sequence?
unsigned int errorCount () const
 Get the number of failures of the algorithm.
SmartIF< IServiceservice (std::string_view name, const bool createIf=true, const bool quiet=false) const
 Return a pointer to the service identified by name (or "type/name").
template<class T>
SmartIF< T > service (std::string_view name, bool createIf=true, bool quiet=false) const
SmartIF< IAuditorSvc > & auditorSvc () const
 The standard auditor service.May not be invoked before sysInitialize() has been invoked.
SmartIF< IChronoStatSvc > & chronoSvc () const
 The standard Chrono & Stat service, Return a pointer to the service if present.
SmartIF< IDataProviderSvc > & detSvc () const
 The standard detector data service.
SmartIF< IConversionSvc > & detCnvSvc () const
 The standard detector data persistency conversion service.
SmartIF< IDataProviderSvc > & eventSvc () const
 The standard event data service.
SmartIF< IDataProviderSvc > & evtSvc () const
 shortcut for method eventSvc
SmartIF< IConversionSvc > & eventCnvSvc () const
 The standard event data persistency conversion service.
SmartIF< IHistogramSvc > & histoSvc () const
 The standard histogram service.
SmartIF< INTupleSvc > & ntupleSvc () const
 The standard N tuple service.
SmartIF< IRndmGenSvc > & randSvc () const
 The standard RandomGen service, Return a pointer to the service if present.
SmartIF< IToolSvc > & toolSvc () const
 The standard ToolSvc service, Return a pointer to the service if present.
SmartIF< IExceptionSvc > & exceptionSvc () const
 Get the exception Service.
SmartIF< IAlgContextSvc > & contextSvc () const
 get Algorithm Context Service
SmartIF< ITimelineSvc > & timelineSvc () const
SmartIF< ISvcLocator > & serviceLocator () const override
 The standard service locator.
SmartIF< ISvcLocator > & svcLoc () const
 shortcut for method serviceLocator
SmartIF< IHiveWhiteBoard > & whiteboard () const
SmartIF< IAlgExecStateSvc > & algExecStateSvc () const
bool registerContext () const
 register for Algorithm Context Service?
template<class T>
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, ToolHandle< T > &hndl, const std::string &doc="none")
template<class T>
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, ToolHandleArray< T > &hndlArr, const std::string &doc="none")
SmartIF< IMonitorSvc > & monitorSvc () const
 Access the monitor service.
template<class T>
void declareInfo (const std::string &name, const T &var, const std::string &desc) const
 Declare monitoring information.
void declareInfo (const std::string &name, const std::string &format, const void *var, int size, const std::string &desc) const
 Declare monitoring information (special case).
void acceptDHVisitor (IDataHandleVisitor *) const override
void registerTool (IAlgTool *tool) const
void deregisterTool (IAlgTool *tool) const
template<class T>
StatusCode declareTool (ToolHandle< T > &handle, bool createIf=true)
template<class T>
StatusCode declareTool (ToolHandle< T > &handle, const std::string &toolTypeAndName, bool createIf=true)
template<class T>
void addToolsArray (ToolHandleArray< T > &hndlArr)
const std::vector< IAlgTool * > & tools () const
bool isAsynchronous () const
void setAsynchronous (bool value)
unsigned int cardinality () const override
 Return the cardinality.
const AlgResources_t & neededResources () const override
AlgExecStateRef execState (const EventContext &ctx) const override
 get the AlgExecStateRef of current algorithm Actually a small wrapper around it, thus the plain object return type
std::ostream & toControlFlowExpression (std::ostream &os) const override
 Produce string represention of the control flow expression.
Public Member Functions inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > > >
std::vector< Gaudi::DataHandle * > inputHandles () const override
std::vector< Gaudi::DataHandle * > outputHandles () const override
virtual const DataObjIDCollextraInputDeps () const override
virtual const DataObjIDCollextraOutputDeps () const override
void declare (Gaudi::DataHandle &handle) override
void renounce (Gaudi::DataHandle &handle) override
bool renounceInput (const DataObjID &id) override
const DataObjIDCollinputDataObjs () const override
const DataObjIDColloutputDataObjs () const override
void addDependency (const DataObjID &id, const Gaudi::DataHandle::Mode &mode) override
Public Member Functions inherited from extends< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >, IDataHandleHolder >
void const * i_cast (const InterfaceID &tid) const override
 Implementation of IInterface::i_cast.
StatusCode queryInterface (const InterfaceID &ti, void **pp) override
 Implementation of IInterface::queryInterface.
std::vector< std::string > getInterfaceNames () const override
 Implementation of IInterface::getInterfaceNames.
Public Member Functions inherited from PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >
StatusCode setProperty (const Gaudi::Details::PropertyBase &p)
 Set the property from a property.
StatusCode setProperty (const std::string &name, const char *v)
 Special case for string literals.
StatusCode setProperty (const std::string &name, const std::string &v)
 Special case for std::string.
StatusCode setProperty (const std::string &name, const TYPE &value)
 set the property form the value
 PropertyHolder ()=default
Gaudi::Details::PropertyBasedeclareProperty (Gaudi::Details::PropertyBase &prop)
 Declare a property.
Gaudi::Details::PropertyBasedeclareRemoteProperty (const std::string &name, IProperty *rsvc, const std::string &rname="")
 Declare a remote property.
StatusCode setPropertyRepr (const std::string &n, const std::string &r) override
 set the property from name and value string representation
StatusCode getProperty (Gaudi::Details::PropertyBase *p) const override
 get the property
const std::vector< Gaudi::Details::PropertyBase * > & getProperties () const override
 get all properties
bool hasProperty (std::string_view name) const override
 Return true if we have a property with the given name.
Gaudi::Details::PropertyBaseproperty (std::string_view name) const
 \fixme property and bindPropertiesTo should be protected
void bindPropertiesTo (Gaudi::Interfaces::IOptionsSvc &optsSvc)
PropertyHolderoperator= (const PropertyHolder &)=delete
Public Member Functions inherited from CommonMessagingBase
virtual ~CommonMessagingBase ()=default
 Virtual destructor.
const SmartIF< IMessageSvc > & msgSvc () const
 The standard message service.
MsgStreammsgStream () const
 Return an uninitialized MsgStream.
MsgStreammsgStream (const MSG::Level level) const
 Predefined configurable message stream for the efficient printouts.
MsgStreamalways () const
 shortcut for the method msgStream(MSG::ALWAYS)
MsgStreamfatal () const
 shortcut for the method msgStream(MSG::FATAL)
MsgStreamerr () const
 shortcut for the method msgStream(MSG::ERROR)
MsgStreamerror () const
 shortcut for the method msgStream(MSG::ERROR)
MsgStreamwarning () const
 shortcut for the method msgStream(MSG::WARNING)
MsgStreaminfo () const
 shortcut for the method msgStream(MSG::INFO)
MsgStreamdebug () const
 shortcut for the method msgStream(MSG::DEBUG)
MsgStreamverbose () const
 shortcut for the method msgStream(MSG::VERBOSE)
MsgStreammsg () const
 shortcut for the method msgStream(MSG::INFO)
MSG::Level msgLevel () const
 get the cached level (originally extracted from the embedded MsgStream)
bool msgLevel (MSG::Level lvl) const
 get the output level from the embedded MsgStream

Private Member Functions

StatusCode PosixOpenAction (FILEMGR_CALLBACK_ARGS)
StatusCode allCloseAction (FILEMGR_CALLBACK_ARGS)

Private Attributes

Io::Fd fd_1 { -1 }
Io::Fd fd_2 { -1 }
Io::Fd fd_3 { -1 }
Io::Fd fd_4 { -1 }
FILE * fp_1 { nullptr }
FILE * fp_2 { nullptr }
FILE * fp_3 { nullptr }
FILE * fp_4 { nullptr }
TFile * fp_r1 { nullptr }
TFile * fp_r2 { nullptr }
TFile * fp_r3 { nullptr }
std::string m_f1
std::string m_f2
std::string m_f3
std::string m_f4
std::string m_fr1
std::string m_fr2
std::string m_fr3
ServiceHandle< IFileMgrp_fileMgr { this, "FileMgr", "FileMGr" }

Additional Inherited Members

Public Types inherited from Gaudi::Algorithm
typedef Gaudi::PluginService::Factory< IAlgorithm *(const std::string &, ISvcLocator *)> Factory
Public Types inherited from extends< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >, IDataHandleHolder >
using base_class
 Typedef to this class.
using extend_interfaces_base
 Typedef to the base of this class.
Public Types inherited from PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > >
using PropertyHolderImpl
 Typedef used to refer to this class from derived classes, as in.
Public Types inherited from CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > >
using base_class
Public Types inherited from extend_interfaces< Interfaces... >
using ext_iids
 take union of the ext_iids of all Interfaces...
Public Attributes inherited from Gaudi::Algorithm
friend AlgorithmManager
Protected Member Functions inherited from Gaudi::details::LegacyAlgorithmAdapter
bool isReEntrant () const override
Protected Member Functions inherited from Gaudi::Algorithm
std::vector< IAlgTool * > & tools ()
bool isInitialized () const override
 Has the Algorithm already been initialized?
bool isFinalized () const override
 Has the Algorithm already been finalized?
void setIndex (const unsigned int &idx) override
 set instantiation index of Alg
bool isReEntrant () const override
Protected Member Functions inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > > >
void initDataHandleHolder ()
 initializes all handles - called by the sysInitialize method of any descendant of this
Protected Member Functions inherited from CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > >
MSG::Level setUpMessaging () const override final
 Set up local caches.
MSG::Level resetMessaging ()
 Reinitialize internal states.
void updateMsgStreamOutputLevel (int level)
 Update the output level of the cached MsgStream.
Protected Attributes inherited from Gaudi::Algorithm
std::unique_ptr< IDataHandleVisitorm_updateDataHandles
 Hook for for derived classes to provide a custom visitor for data handles.
Protected Attributes inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgorithm, IDataHandleHolder, IProperty, IStateful > > > >
DataObjIDColl m_inputDataObjs
DataObjIDColl m_outputDataObjs

Detailed Description

an algorithm to test the FileMgr

Definition at line 28 of file FileMgrTest.h.

Constructor & Destructor Documentation

◆ FileMgrTest()

FileMgrTest::FileMgrTest ( const std::string & name,
ISvcLocator * pSvcLocator )

Definition at line 29 of file FileMgrTest.cpp.

29: Algorithm( name, pSvcLocator ) {}
Algorithm(std::string name, ISvcLocator *svcloc, std::string version=PACKAGE_VERSION)
Constructor.
Definition Algorithm.h:98
const std::string & name() const override
The identifying name of the algorithm object.

Member Function Documentation

◆ allCloseAction()

StatusCode FileMgrTest::allCloseAction ( FILEMGR_CALLBACK_ARGS )
private

Definition at line 302 of file FileMgrTest.cpp.

302 {
303
304 info() << "AllCloseAction called by " << c << " for tech " << fa->tech() << " on " << fa << endmsg;
305
306 return StatusCode::SUCCESS;
307}
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition MsgStream.h:198
MsgStream & info() const
shortcut for the method msgStream(MSG::INFO)
constexpr static const auto SUCCESS
Definition StatusCode.h:99

◆ execute()

StatusCode FileMgrTest::execute ( )
overridevirtual

Implements Algorithm.

Definition at line 176 of file FileMgrTest.cpp.

176 {
177
178#ifndef __APPLE__
179 info() << "writing to " << p_fileMgr->fname( (void*)fp_2 ) << endmsg;
180
181 std::ofstream ofs;
182 __gnu_cxx::stdio_filebuf<char> fb( fp_2, std::ios::out );
183
184 ofs.std::ios::rdbuf( &fb );
185 ofs << "Hello World!" << std::endl;
186
187 info() << "appending to " << p_fileMgr->fname( (void*)fp_3 ) << endmsg;
188
189 std::ofstream ofs2;
190 __gnu_cxx::stdio_filebuf<char> fb2( fp_3, std::ios::out );
191
192 ofs2.std::ios::rdbuf( &fb2 );
193 ofs2 << "Hello World!" << std::endl;
194#endif // not __APPLE__
195
196 return StatusCode::SUCCESS;
197}
ServiceHandle< IFileMgr > p_fileMgr
Definition FileMgrTest.h:42
FILE * fp_2
Definition FileMgrTest.h:38
FILE * fp_3
Definition FileMgrTest.h:38

◆ finalize()

StatusCode FileMgrTest::finalize ( )
override

Definition at line 201 of file FileMgrTest.cpp.

201 {
202
203 std::vector<std::string> v;
204 std::vector<std::string>::const_iterator itr;
205 int i = p_fileMgr->getFiles( v );
206
207 auto& log = info();
208 log << "listing all open files [" << i << "]" << std::endl;
209 for ( itr = v.begin(); itr != v.end(); ++itr ) { log << " " << *itr << std::endl; }
210 log << endmsg;
211
212 i = p_fileMgr->getFiles( v, false );
213 log << "listing ALL files [" << i << "]" << std::endl;
214 for ( itr = v.begin(); itr != v.end(); ++itr ) { log << " " << *itr << std::endl; }
215 log << endmsg;
216
217 std::vector<const Io::FileAttr*> v2;
218 std::vector<const Io::FileAttr*>::const_iterator it2;
219 i = p_fileMgr->getFiles( Io::POSIX, v2, false );
220 log << "listing all POSIX files ever opened [" << i << "]" << std::endl;
221 for ( it2 = v2.begin(); it2 != v2.end(); ++it2 ) { log << " " << ( *it2 )->name() << std::endl; }
222 log << endmsg;
223
224 int r;
225
226 r = p_fileMgr->close( fd_1, name() );
227 if ( r != 0 ) {
228 error() << "unable to close " << m_f1 << " with FD " << fd_1 << endmsg;
229 } else {
230 info() << "closed " << m_f1 << endmsg;
231 }
232
233 r = p_fileMgr->close( fd_2, name() );
234 if ( r != 0 ) {
235 error() << "unable to close " << m_f2 << " with FD " << fd_2 << endmsg;
236 } else {
237 info() << "closed " << m_f2 << endmsg;
238 }
239
240 r = p_fileMgr->close( fd_3, name() );
241 if ( r != 0 ) {
242 error() << "unable to close " << m_f3 << " with FD " << fd_3 << endmsg;
243 } else {
244 info() << "closed " << m_f3 << endmsg;
245 }
246
247 r = p_fileMgr->close( fd_4, name() );
248 if ( r != 0 ) {
249 error() << "unable to close " << m_f1 << " with FD " << fd_4 << endmsg;
250 } else {
251 info() << "closed " << m_f1 << endmsg;
252 }
253
254 r = p_fileMgr->close( fp_r1, name() );
255 if ( r != 0 ) {
256 error() << "unable to close " << m_fr1 << " with ptr " << fp_r1 << endmsg;
257 } else {
258 info() << "closed " << m_fr1 << endmsg;
259 }
260
261 r = p_fileMgr->close( fp_r2, name() );
262 if ( r != 0 ) {
263 error() << "unable to close " << m_fr2 << " with ptr " << fp_r2 << endmsg;
264 } else {
265 info() << "closed " << m_fr2 << endmsg;
266 }
267
268 // r = p_fileMgr->close(fp_r3,name());
269 // if (r != 0) {
270 // error() << "unable to close " << m_fr3 << " with ptr " << fp_r3
271 // << endmsg;
272 // } else {
273 // info() << "closed " << m_fr3 << endmsg;
274 // }
275
276 return StatusCode::SUCCESS;
277}
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
std::string m_f2
Definition FileMgrTest.h:40
TFile * fp_r1
Definition FileMgrTest.h:39
Io::Fd fd_3
Definition FileMgrTest.h:37
std::string m_fr2
Definition FileMgrTest.h:40
Io::Fd fd_4
Definition FileMgrTest.h:37
Io::Fd fd_2
Definition FileMgrTest.h:37
std::string m_fr1
Definition FileMgrTest.h:40
TFile * fp_r2
Definition FileMgrTest.h:39
std::string m_f1
Definition FileMgrTest.h:40
std::string m_f3
Definition FileMgrTest.h:40
Io::Fd fd_1
Definition FileMgrTest.h:37
@ POSIX
Definition IFileMgr.h:147

◆ initialize()

StatusCode FileMgrTest::initialize ( )
override

Definition at line 33 of file FileMgrTest.cpp.

33 {
34
35 StatusCode st( StatusCode::SUCCESS );
36
37 m_f1 = "/etc/redhat-release";
38 m_f2 = "t2.txt";
39 m_f3 = "t3.txt";
40 m_f4 = "t4.txt";
41
42 m_fr1 = "tuple1.rt";
43 m_fr2 = "http://annwm.lbl.gov/~leggett/tuple2.rt";
44 m_fr3 = "https://t-dpm.grid.sinica.edu.tw/dpm/grid.sinica.edu.tw/home/atlas/atlasppsscratchdisk/mc10_7TeV/AOD/"
45 "e574_s1110_s1100_r1655_r1700/"
46 "mc10_7TeV.105805.filtered_minbias6.merge.AOD.e574_s1110_s1100_r1655_r1700_tid261524_00/"
47 "AOD.261524._032551.pool.root.1";
48
49 if ( p_fileMgr.retrieve().isFailure() ) {
50 error() << "unable to get the FileMgr" << endmsg;
52 } else {
53 debug() << "got the FileMgr" << endmsg;
54 }
55
57 std::bind( &FileMgrTest::PosixOpenAction, this, std::placeholders::_1, std::placeholders::_2 );
58 if ( p_fileMgr->regAction( boa, Io::OPEN, Io::POSIX, "FileMgrTest::POSIXOpenAction" ).isFailure() ) {
59 error() << "unable to register POSIX file open action with FileMgr" << endmsg;
60 }
61
62 if ( p_fileMgr->regAction( boa, Io::OPEN_ERR, Io::POSIX, "FileMgrTest::PosixOpenAction" ).isFailure() ) {
63 error() << "unable to register POSIX file open ERR action with FileMgr" << endmsg;
64 }
65
66 Io::bfcn_action_t bob = std::bind( &FileMgrTest::allCloseAction, this, std::placeholders::_1, std::placeholders::_2 );
67 if ( p_fileMgr->regAction( bob, Io::CLOSE ).isFailure() ) {
68 // "FileMgrTest::allCloseAction").isFailure()) {
69 error() << "unable to register all Close action with FileMgr" << endmsg;
70 }
71
72 int r;
73
74 r = p_fileMgr->open( Io::POSIX, name(), m_f1, Io::READ, fd_1, "ASCII" );
75 if ( r != 0 ) {
76 error() << "unable to open " << m_f1 << " for reading" << endmsg;
77 } else {
78 // fp_1 = fdopen(fd_1, "r");
79 fp_1 = (FILE*)p_fileMgr->fptr( fd_1 );
80 info() << "opened " << m_f1 << " for reading with FD: " << fd_1 << " FILE* " << fp_1 << endmsg;
81 }
82
83 r = p_fileMgr->open( Io::POSIX, name(), m_f2, Io::WRITE | Io::CREATE, fd_2, "ASCII" );
84 if ( r != 0 ) {
85 error() << "unable to open " << m_f2 << " for writing" << endmsg;
86 } else {
87 // fp_2 = fdopen(fd_2,"w");
88 fp_2 = (FILE*)p_fileMgr->fptr( fd_2 );
89 info() << "opened " << m_f2 << " for writing with FD: " << fd_2 << " FILE* " << fp_2 << endmsg;
90 }
91
92 // make sure we have something in m_f3 to append to;
93 std::ofstream ofs{ m_f3 };
94 ofs << "initial line" << std::endl;
95 ofs.close();
96
97 r = p_fileMgr->open( Io::POSIX, name(), m_f3, Io::WRITE | Io::APPEND, fd_3, "ASCII" );
98 if ( r != 0 ) {
99 error() << "unable to open " << m_f3 << " for write|append" << endmsg;
100 } else {
101 // fp_3 = fdopen(fd_3,"a");
102 fp_3 = (FILE*)p_fileMgr->fptr( fd_3 );
103 info() << "opened " << m_f3 << " for reading with FD: " << fd_3 << " FILE* " << fp_3 << endmsg;
104 }
105
106 Io::Fd fd;
107
108 error() << "the following error is expected" << endmsg;
109 r = p_fileMgr->open( Io::POSIX, name(), m_f2, Io::WRITE | Io::CREATE | Io::EXCL, fd, "ASCII" );
110 if ( r != 0 ) {
111 info() << "unable to open " << m_f2 << " for WRITE|CREATE|EXCL - expected as file already exists" << endmsg;
112 } else {
113 error() << "opened " << m_f2 << " for reading with FD: " << fd << " This should not occur!" << endmsg;
114 }
115
116 r = p_fileMgr->open( Io::POSIX, name(), m_f1, Io::READ, fd_4, "ASCII" );
117 if ( r != 0 ) {
118 error() << "unable to open " << m_f1 << " again for reading" << endmsg;
119 } else {
120 fp_4 = (FILE*)p_fileMgr->fptr( fd_4 );
121 info() << "opened " << m_f1 << " again for reading with FD: " << fd_4 << " FILE* " << fp_4 << endmsg;
122 }
123
124 void* vp( 0 );
125 r = p_fileMgr->open( Io::ROOT, name(), m_fr1, Io::READ, vp, "HIST" );
126 if ( r != 0 ) {
127 error() << "unable to open " << m_fr1 << " again for reading" << endmsg;
128 } else {
129 fp_r1 = (TFile*)vp;
130 info() << "opened " << m_fr1 << " for reading with ptr: " << fp_r1 << endmsg;
131 }
132
133 r = p_fileMgr->open( Io::ROOT, name(), m_fr2, Io::READ, vp, "HIST" );
134 if ( r != 0 ) {
135 error() << "unable to open " << m_fr2 << " for reading" << endmsg;
136 } else {
137 fp_r2 = (TFile*)vp;
138 info() << "opened " << m_fr2 << " for reading with ptr: " << fp_r2 << " size: " << fp_r2->GetSize() << endmsg;
139 }
140
141 // std::string cafile, capath,ucert,ukey;
142 // cafile = "/tmp/x509up_u6919";
143 // capath = "/afs/cern.ch/project/gd/LCG-share2/certificates";
144 // ucert = cafile;
145 // ukey = cafile;
146
147 // TSSLSocket::SetUpSSL(cafile.c_str(), capath.c_str(), ucert.c_str(), ukey.c_str());
148 r = p_fileMgr->open( Io::ROOT, name(), m_fr3, Io::READ, vp, "HIST" );
149 if ( r != 0 ) {
150 error() << "unable to open " << m_fr3 << " for reading" << endmsg;
151 } else {
152 fp_r3 = (TFile*)vp;
153 info() << "opened " << m_fr3 << " for reading with ptr: " << fp_r3 << " size: " << fp_r3->GetSize() << endmsg;
154 }
155
156 for ( int j = 0; j < 2; ++j ) {
157 r = p_fileMgr->open( Io::POSIX, name(), "t6.txt", Io::WRITE | Io::CREATE, fd, "ASCII" );
158 if ( r != 0 ) {
159 error() << "unable to open t6.txt for writing" << endmsg;
160 } else {
161 info() << "opened t6.txt for writing, fd: " << fd << " will now close" << endmsg;
162 r = p_fileMgr->close( fd, name() );
163 if ( r != 0 ) {
164 error() << "unable to close " << m_f1 << " with FD " << fd_1 << endmsg;
165 } else {
166 info() << "closed " << name() << endmsg;
167 }
168 }
169 }
170
171 return st;
172}
MsgStream & debug() const
shortcut for the method msgStream(MSG::DEBUG)
TFile * fp_r3
Definition FileMgrTest.h:39
std::string m_f4
Definition FileMgrTest.h:40
StatusCode allCloseAction(FILEMGR_CALLBACK_ARGS)
FILE * fp_4
Definition FileMgrTest.h:38
StatusCode PosixOpenAction(FILEMGR_CALLBACK_ARGS)
FILE * fp_1
Definition FileMgrTest.h:38
std::string m_fr3
Definition FileMgrTest.h:40
constexpr static const auto FAILURE
Definition StatusCode.h:100
@ OPEN
Definition IFileMgr.h:263
@ CLOSE
Definition IFileMgr.h:263
@ OPEN_ERR
Definition IFileMgr.h:263
std::function< StatusCode(FILEMGR_CALLBACK_ARGS)> bfcn_action_t
Definition IFileMgr.h:273
@ ROOT
Definition IFileMgr.h:147
@ READ
Definition IFileMgr.h:30
@ CREATE
Definition IFileMgr.h:34
@ WRITE
Definition IFileMgr.h:31
@ EXCL
Definition IFileMgr.h:35
@ APPEND
Definition IFileMgr.h:38
int Fd
Definition IFileMgr.h:158

◆ PosixOpenAction()

StatusCode FileMgrTest::PosixOpenAction ( FILEMGR_CALLBACK_ARGS )
private

Definition at line 281 of file FileMgrTest.cpp.

281 {
282
283 info() << "PosixOpenAction called by " << c << " for tech " << fa->tech() << " on " << fa << endmsg;
284
285 // if (fa.tech() != Io::POSIX) {
286
287 // // error() << "PosixOpenAction called for incorrect tech: "
288 // // << fa.tech() << " on " << fa
289 // // << endmsg;
290
291 // return StatusCode::SUCCESS;
292 // }
293
294 // info() << "PosixOpenAction for " << fa
295 // << endmsg;
296
297 return StatusCode::SUCCESS;
298}

Member Data Documentation

◆ fd_1

Io::Fd FileMgrTest::fd_1 { -1 }
private

Definition at line 37 of file FileMgrTest.h.

37{ -1 }, fd_2{ -1 }, fd_3{ -1 }, fd_4{ -1 };

◆ fd_2

Io::Fd FileMgrTest::fd_2 { -1 }
private

Definition at line 37 of file FileMgrTest.h.

37{ -1 }, fd_2{ -1 }, fd_3{ -1 }, fd_4{ -1 };

◆ fd_3

Io::Fd FileMgrTest::fd_3 { -1 }
private

Definition at line 37 of file FileMgrTest.h.

37{ -1 }, fd_2{ -1 }, fd_3{ -1 }, fd_4{ -1 };

◆ fd_4

Io::Fd FileMgrTest::fd_4 { -1 }
private

Definition at line 37 of file FileMgrTest.h.

37{ -1 }, fd_2{ -1 }, fd_3{ -1 }, fd_4{ -1 };

◆ fp_1

FILE* FileMgrTest::fp_1 { nullptr }
private

Definition at line 38 of file FileMgrTest.h.

38{ nullptr }, *fp_2{ nullptr }, *fp_3{ nullptr }, *fp_4{ nullptr };

◆ fp_2

FILE * FileMgrTest::fp_2 { nullptr }
private

Definition at line 38 of file FileMgrTest.h.

38{ nullptr }, *fp_2{ nullptr }, *fp_3{ nullptr }, *fp_4{ nullptr };

◆ fp_3

FILE * FileMgrTest::fp_3 { nullptr }
private

Definition at line 38 of file FileMgrTest.h.

38{ nullptr }, *fp_2{ nullptr }, *fp_3{ nullptr }, *fp_4{ nullptr };

◆ fp_4

FILE * FileMgrTest::fp_4 { nullptr }
private

Definition at line 38 of file FileMgrTest.h.

38{ nullptr }, *fp_2{ nullptr }, *fp_3{ nullptr }, *fp_4{ nullptr };

◆ fp_r1

TFile* FileMgrTest::fp_r1 { nullptr }
private

Definition at line 39 of file FileMgrTest.h.

39{ nullptr }, *fp_r2{ nullptr }, *fp_r3{ nullptr };

◆ fp_r2

TFile * FileMgrTest::fp_r2 { nullptr }
private

Definition at line 39 of file FileMgrTest.h.

39{ nullptr }, *fp_r2{ nullptr }, *fp_r3{ nullptr };

◆ fp_r3

TFile * FileMgrTest::fp_r3 { nullptr }
private

Definition at line 39 of file FileMgrTest.h.

39{ nullptr }, *fp_r2{ nullptr }, *fp_r3{ nullptr };

◆ m_f1

std::string FileMgrTest::m_f1
private

Definition at line 40 of file FileMgrTest.h.

◆ m_f2

std::string FileMgrTest::m_f2
private

Definition at line 40 of file FileMgrTest.h.

◆ m_f3

std::string FileMgrTest::m_f3
private

Definition at line 40 of file FileMgrTest.h.

◆ m_f4

std::string FileMgrTest::m_f4
private

Definition at line 40 of file FileMgrTest.h.

◆ m_fr1

std::string FileMgrTest::m_fr1
private

Definition at line 40 of file FileMgrTest.h.

◆ m_fr2

std::string FileMgrTest::m_fr2
private

Definition at line 40 of file FileMgrTest.h.

◆ m_fr3

std::string FileMgrTest::m_fr3
private

Definition at line 40 of file FileMgrTest.h.

◆ p_fileMgr

ServiceHandle<IFileMgr> FileMgrTest::p_fileMgr { this, "FileMgr", "FileMGr" }
private

Definition at line 42 of file FileMgrTest.h.

42{ this, "FileMgr", "FileMGr" };

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