This class should read files from a queue as a new thread. More...
#include <Stager.h>
Public Member Functions | |
Stager () | |
virtual | ~Stager () |
Queue * | getQueuePtr () |
Getter for member. | |
void | setQueuePtr (Queue *) |
Setter for member. | |
bool | getJobDone () |
Getter for member. | |
void | setJobDone (bool) |
Private Member Functions | |
bool | OnTask (void *q) |
Do the staging. | |
bool | OnTask () |
Private Attributes | |
Queue * | QueuePtr |
The queue we have to stage. | |
bool | JobDone |
Are we done ? | |
Static Private Attributes | |
static LoggerPtr | logger |
This class should read files from a queue as a new thread.
treqs::Stager::Stager | ( | ) |
treqs::Stager::~Stager | ( | ) | [virtual] |
bool treqs::Stager::getJobDone | ( | ) |
Getter for member.
Queue * treqs::Stager::getQueuePtr | ( | ) |
Getter for member.
bool treqs::Stager::OnTask | ( | ) | [private, virtual] |
OnTask overloaded implementation of OnTask that takes no arguments
Reimplemented from CThread.
bool treqs::Stager::OnTask | ( | void * | q | ) | [private, virtual] |
Do the staging.
This method asks the queue q for the next file to stage, until the queue is completely browsed.
for each Reading object to stage, it calls the Reading->stage() method and catch exceptions.
If the HPSSResourceException is catch, then the queue is suspended for 10 minutes.
q | pointer to a queue |
Reimplemented from CThread.
void treqs::Stager::setJobDone | ( | bool | b | ) |
void treqs::Stager::setQueuePtr | ( | Queue * | q | ) |
Setter for member.
bool treqs::Stager::JobDone [private] |
Are we done ?
LoggerPtr treqs::Stager::logger [static, private] |
Queue* treqs::Stager::QueuePtr [private] |
The queue we have to stage.