treqs::Activator Class Reference
Class responsible for activation of the staging queues.
More...
#include <Activator.h>
List of all members.
Detailed Description
Class responsible for activation of the staging queues.
This class runs as a thread and periodically scans the waiting queues to activate them.
Constructor & Destructor Documentation
treqs::Activator::Activator |
( |
|
) |
|
treqs::Activator::~Activator |
( |
|
) |
|
Member Function Documentation
void treqs::Activator::activateQueue |
( |
Queue * |
q |
) |
[private] |
Activate a queue. This function will also trigger the stagers.
- Parameters:
-
int treqs::Activator::cleanWorkers |
( |
|
) |
[private] |
Browse the workers list and erase the finished ones
- Returns:
- number of workers cleaned
int treqs::Activator::countUsedResources |
( |
|
) |
[private] |
Browse the queues and count the activated queues into the corresponding PVR resource
- Returns:
- the number of queues in QS_ACTIVATED state
int treqs::Activator::countWaitingQueues |
( |
unsigned int |
id |
) |
[private] |
Count waiting queues on a given PVR
- Parameters:
-
- Returns:
- number of waiting queues
unsigned int treqs::Activator::getMaxQueueStagers |
( |
|
) |
|
unsigned int treqs::Activator::getMaxStagers |
( |
|
) |
|
int treqs::Activator::getMetadataTimeout |
( |
|
) |
|
bool treqs::Activator::OnTask |
( |
|
) |
[private, virtual] |
Overrides the CThread OnTask function Just browse periodically the list of users and queues to activate the best queue
- Returns:
Reimplemented from CThread.
void treqs::Activator::refreshAllocations |
( |
|
) |
[private] |
Get the allocation information from configuration database Puts data into Allocations list
Queue * treqs::Activator::selectBestQueue |
( |
list< Resource >::iterator |
rit, |
|
|
std::string |
u | |
|
) |
| | [private] |
Choose the best queue candidate for activation for a given user
Also taking the opportunity to unsuspend the suspended queues
- Parameters:
-
| rit | iterator to the concerned resource |
| u | the user candidate |
- Returns:
- a pointer to the best queue
string treqs::Activator::selectBestUser |
( |
list< Resource >::iterator |
iterator |
) |
[private] |
Choose the best user candidate for activation
- Parameters:
-
| iterator | iterator pointing the concerned resource |
- Returns:
- the user's name
void treqs::Activator::setMaxQueueStagers |
( |
unsigned int |
n |
) |
|
void treqs::Activator::setMaxStagers |
( |
unsigned int |
n |
) |
|
void treqs::Activator::setMetadataTimeout |
( |
int |
t |
) |
|
Member Data Documentation
List of drives allocations per PVR.
Max number of stages process per active queue.
Max number of stagers for overall activity.
Maximum age of the resources metadata.
The documentation for this class was generated from the following files:
- /home/gomez/Documents/workspaces/treqs/treqs/src/Activator.h
- /home/gomez/Documents/workspaces/treqs/treqs/src/Activator.cpp