#include <Archiver.h>
Collaboration diagram for SctArchiving::Archiver:
Public Member Functions | |||
void | go (unsigned nWorker) throw (IsException) | ||
The command to start the workers. | |||
const char * | getStatus () const throw () | ||
Get the status information. | |||
virtual char * | status (ArchivingServiceIStatus *status) | ||
As for getStatus, but available over IPC. | |||
virtual ilu_ShortInteger | busy (ArchivingServiceIStatus *_status) | ||
busy method available over IPC | |||
virtual ilu_ShortInteger | queueLength (ArchivingServiceIStatus *_status) | ||
queue method available over IPC | |||
virtual void | suspendCallbacks (ArchivingServiceIStatus *_status, ilu_Boolean doSuspend) | ||
call this to suspend callbacks when retrieving to data servers | |||
IPCServer & | getArchiverServer () throw () | ||
wrap method to get server | |||
virtual void | archiveISName (ArchivingServiceIStatus *status, char *ioNameIS) | ||
Archive a IONameIS. | |||
virtual void | retrieveISName (ArchivingServiceIStatus *status, char *ioNameIS) | ||
Retrieve a IONameIS. | |||
virtual void | retrieveArchName (ArchivingServiceIStatus *status, char *archivingName) | ||
Retrieve a IONameArchiveFile. | |||
virtual void | retrieve (ArchivingServiceIStatus *_status, char *runNumber, char *scanNumber, char *className, char *specifier) | ||
Retrieve objects matching a particular file glob pattern. | |||
virtual ilu_ShortInteger | getCompressionLevel (ArchivingServiceIStatus *_status) | ||
get the gzip compression level | |||
virtual void | setCompressionLevel (ArchivingServiceIStatus *_status, ilu_ShortInteger level) | ||
set the gzip compression level | |||
virtual void | setRetrieveIsServer (ArchivingServiceIStatus *_status, ilu_T_CString serverName) | ||
set the retrieval IS server name | |||
virtual void | addCommand (boost::shared_ptr< ArchivingCommand > command) const | ||
void | incrimentNArchived () throw () | ||
Incriment the number of archivals by 1. | |||
void | incrimentNRetrieved () throw () | ||
Incriment the number of retrievals. | |||
void | incrimentNValidated () throw () | ||
Incriment the number of validations. | |||
void | addISTime (double time) throw () | ||
Called to add to time for reading/writing to IS. | |||
void | addFileTime (double time) throw () | ||
Called to add to time for reading/writing to archive file. | |||
Sct::Archive::IOManagerArchive & | Archiver::getIOManagerArchive () const | ||
get the archive manager | |||
string | getRetrieveIsServer () const throw () | ||
get the IS server name to retrieve data to | |||
Static Public Member Functions | |||
Archiver & | instance () | ||
Gets a reference to the instance of the Archiver. | |||
Archiver & | initialize () throw (ConfigurationException) | ||
Initialize the Archiver instance
| |||
void | archive_callback (ISCallbackInfo *isc) | ||
Static function used as callback to archive data. | |||
Private Member Functions | |||
Archiver () throw (ConfigurationException) | |||
singleton | |||
~Archiver () throw () | |||
private destructor | |||
void | subscribe (const string &servername, const string ®exp, ISCallbackInfo::Callback callback) | ||
subscribe to IS, throwing IsExceptions if there are problems | |||
double | getAverageTime (double time) const throw () | ||
Private Attributes | |||
ArchivingWorkerGroup * | workergroup | ||
pointer to its ArchivingWorkerGroup | |||
std::auto_ptr< ISInfoReceiver > | infoReceiver | ||
pointer to the IS infoReceiver object | |||
long | nArchived | ||
long | nRetrieved | ||
long | nValidated | ||
double | isTimeTaken | ||
double | fileTimeTaken | ||
boost::mutex | counterMutex | ||
used to lock access to counters | |||
Sct::Archive::IOManagerArchive * | m_archive_manager | ||
iomanager to use for achiving | |||
std::string | m_retrieval_is_server | ||
bool | m_suspend_callback | ||
Static Private Attributes | |||
Archiver * | archiver | ||
pointer to singleton used in lazy initialization. |
Definition at line 30 of file Archiver.h.
|
singleton
Definition at line 68 of file Archiver.cpp. References Sct::SctNames::getRetrievedDataName(). Referenced by instance(). |
Here is the call graph for this function:
|
private destructor
Definition at line 83 of file Archiver.cpp. |
|
Called to add to time for reading/writing to archive file.
Definition at line 204 of file Archiver.cpp. |
|
Called to add to time for reading/writing to IS.
Definition at line 199 of file Archiver.cpp. |
|
Static function used as callback to archive data.
Definition at line 104 of file Archiver.cpp. References m_suspend_callback, SctService::WorkerGroup< shared_ptr< ArchivingCommand > >::push(), and workergroup. |
Here is the call graph for this function:
|
Archive a IONameIS.
Definition at line 238 of file Archiver.cpp. References SctService::WorkerGroup< shared_ptr< ArchivingCommand > >::push(), and workergroup. |
Here is the call graph for this function:
|
get the archive manager
|
|
busy method available over IPC
Definition at line 300 of file Archiver.cpp. References SctService::WorkerGroup< shared_ptr< ArchivingCommand > >::busy(), and workergroup. |
Here is the call graph for this function:
|
wrap method to get server
Definition at line 95 of file Archiver.cpp. |
|
get the gzip compression level
Definition at line 310 of file Archiver.cpp. |
|
get the IS server name to retrieve data to
Definition at line 143 of file Archiver.cpp. Referenced by retrieveArchName(). |
|
Get the status information.
Definition at line 209 of file Archiver.cpp. Referenced by status(). |
|
The command to start the workers.
Definition at line 175 of file Archiver.cpp. |
|
Incriment the number of archivals by 1.
Definition at line 184 of file Archiver.cpp. |
|
Incriment the number of retrievals.
Definition at line 189 of file Archiver.cpp. |
|
Incriment the number of validations.
Definition at line 194 of file Archiver.cpp. |
|
Initialize the Archiver instance
|
|
Gets a reference to the instance of the Archiver. If it hasn't been initialized, it calls initialize() first Definition at line 63 of file Archiver.cpp. References Archiver(), and archiver. |
Here is the call graph for this function:
|
queue method available over IPC
Definition at line 305 of file Archiver.cpp. References SctService::WorkerGroup< shared_ptr< ArchivingCommand > >::queueSize(), and workergroup. |
Here is the call graph for this function:
|
Retrieve objects matching a particular file glob pattern.
Definition at line 271 of file Archiver.cpp. References retrieveArchName(). |
Here is the call graph for this function:
|
Retrieve a IONameArchiveFile.
Definition at line 285 of file Archiver.cpp. References getRetrieveIsServer(), SctService::WorkerGroup< shared_ptr< ArchivingCommand > >::push(), and workergroup. Referenced by retrieve(), and retrieveISName(). |
Here is the call graph for this function:
|
Retrieve a IONameIS. need to do this cos IPC dosent guarentee constness Definition at line 259 of file Archiver.cpp. References retrieveArchName(). |
Here is the call graph for this function:
|
set the gzip compression level
Definition at line 315 of file Archiver.cpp. |
|
set the retrieval IS server name
Definition at line 147 of file Archiver.cpp. |
|
As for getStatus, but available over IPC. Makes a new char[] which ipc then deletes.
Definition at line 231 of file Archiver.cpp. References getStatus(). |
Here is the call graph for this function:
|
subscribe to IS, throwing IsExceptions if there are problems
Definition at line 158 of file Archiver.cpp. References infoReceiver. |
|
call this to suspend callbacks when retrieving to data servers
Definition at line 152 of file Archiver.cpp. |
|
pointer to singleton used in lazy initialization.
Definition at line 61 of file Archiver.cpp. Referenced by instance(). |
|
used to lock access to counters
Definition at line 135 of file Archiver.h. |
|
pointer to the IS infoReceiver object
Definition at line 128 of file Archiver.h. Referenced by subscribe(). |
|
iomanager to use for achiving
Definition at line 138 of file Archiver.h. |
|
pointer to its ArchivingWorkerGroup
Definition at line 124 of file Archiver.h. Referenced by archive_callback(), archiveISName(), busy(), queueLength(), and retrieveArchName(). |