Definition at line 62 of file rqsthread.h.
typedef OSB_LIB::Id<OSB_LIB::StatusRequest> RqsThread::SrqId [private] |
typedef OSB_LIB::RequestHandler::Result RqsThread::SrqResult [private] |
typedef std::map<SrqResult, long> RqsThread::Stats |
bool RqsThread::processOnce | ( | ) | [private] |
Process all pending requests.
SrqResult RqsThread::processReq | ( | const OSB_DB::Session & | session, | |
OSB_LIB::RequestHandler & | rh, | |||
OSB_LIB::StatusRequest & | request | |||
) | [private] |
Process one request.
void RqsThread::reset | ( | ) | [private] |
Reset the thread data.
void RqsThread::threadFunction | ( | ) | [private] |
The thread function.
It just calls processOnce() and then sleeps for a few milliseconds.
In case of an exception it signals SIGINT to process.
int RqsThread::deltaReset_ [private] |
int RqsThread::idleSleep_ [private] |
SrqId RqsThread::maxProcessed_ [private] |
OSB_LIB::Period RqsThread::period_ [private] |
OSB_LIB::DateTime RqsThread::resetTime_ [private] |
Stats RqsThread::stats_ [private] |