treqs::Stager Class Reference

This class should read files from a queue as a new thread. More...

#include <Stager.h>

Inheritance diagram for treqs::Stager:
Inheritance graph
[legend]
Collaboration diagram for treqs::Stager:
Collaboration graph
[legend]

List of all members.

Public Member Functions

 Stager ()
virtual ~Stager ()
QueuegetQueuePtr ()
 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

QueueQueuePtr
 The queue we have to stage.
bool JobDone
 Are we done ?

Static Private Attributes

static LoggerPtr logger

Detailed Description

This class should read files from a queue as a new thread.


Constructor & Destructor Documentation

treqs::Stager::Stager (  ) 

Here is the call graph for this function:

treqs::Stager::~Stager (  )  [virtual]

Member Function Documentation

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.

Parameters:
q pointer to a queue
Returns:
true

Reimplemented from CThread.

Here is the call graph for this function:

void treqs::Stager::setJobDone ( bool  b  ) 
void treqs::Stager::setQueuePtr ( Queue q  ) 

Setter for member.


Member Data Documentation

bool treqs::Stager::JobDone [private]

Are we done ?

LoggerPtr treqs::Stager::logger [static, private]

The queue we have to stage.


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

Generated on 4 Mar 2010 for TReqS by  doxygen 1.6.1