#include <wwwapi.h>
Public Member Functions | |
| void | stop () |
| void | start () |
| QueueManager (WWWapi &api, dbDatabase &db, int nThreads=8, int connectionQueueLen=64) | |
| ~QueueManager () | |
Private Member Functions | |
| void | handle () |
Static Private Member Functions | |
| static void thread_proc | handleThread (void *arg) |
Private Attributes | |
| WWWconnection * | connectionPool |
| WWWconnection * | freeList |
| WWWconnection * | waitList |
| dbMutex | mutex |
| dbLocalSemaphore | go |
| dbLocalEvent | done |
| dbThread * | threads |
| int | nThreads |
| WWWapi * | server |
| dbDatabase & | db |
| QueueManager | ( | WWWapi & | api, | |
| dbDatabase & | db, | |||
| int | nThreads = 8, |
|||
| int | connectionQueueLen = 64 | |||
| ) |
| ~QueueManager | ( | ) |
| void thread_proc handleThread | ( | void * | arg | ) | [static, private] |
| void handle | ( | ) | [private] |
| void stop | ( | ) |
| void start | ( | void | ) |
WWWconnection* connectionPool [private] |
WWWconnection* freeList [private] |
WWWconnection* waitList [private] |
dbLocalSemaphore go [private] |
dbLocalEvent done [private] |
int nThreads [private] |
dbDatabase& db [private] |