RqsThread Class Reference

Inheritance diagram for RqsThread:

[legend]Collaboration diagram for RqsThread:

[legend]List of all members.

---

Detailed Description

Back-end thread to process all pending status requests.

Todo:

Remember the requests that failed and print the resulting errors only every n times.

Definition at line 62 of file rqsthread.h.

Public Types

• typedef std::map< SrqResult,
  long > Stats

  Count # of requests vs. processing result.
  

Private Types

• typedef OSB_LIB::RequestHandler::Result SrqResult

  Just a short-cut.
  

• typedef OSB_LIB::Id< OSB_LIB::StatusRequest > SrqId

  Just a short-cut.
  

Private Member Functions

• void threadFunction ()

  The thread function.
  

• bool processOnce ()

  Process all pending requests.
  

• SrqResult processReq (const OSB_DB::Session &session, OSB_LIB::RequestHandler &rh, OSB_LIB::StatusRequest &request)

  Process one request.
  

• void reset ()

  Reset the thread data.
  

Private Attributes

• OSB_LIB::Period period_

  Time period being processed.
  

• SrqId maxProcessed_

  The max. object id of the processed requests.
  

• Stats stats_

  Processing statistics: result vs # of requests.
  

• OSB_LIB::DateTime resetTime_

  Time when the thread should next reset its data.
  

• int idleSleep_

  Configuration: msec sleep time if no request processes.
  

• int deltaReset_

  Configuration: interval (minutes) to reset the data.
  

---

Member Typedef Documentation

typedef OSB_LIB::Id<OSB_LIB::StatusRequest> RqsThread::SrqId [private]

Just a short-cut.

Definition at line 66 of file rqsthread.h.

typedef OSB_LIB::RequestHandler::Result RqsThread::SrqResult [private]

Just a short-cut.

Definition at line 64 of file rqsthread.h.

typedef std::map<SrqResult, long> RqsThread::Stats

Count # of requests vs. processing result.

Definition at line 69 of file rqsthread.h.

---

Member Function Documentation

bool RqsThread::processOnce

(

)

[private]

Process all pending requests.

Returns:

true if pending requests were found, else false.

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.

---

Member Data Documentation

int RqsThread::deltaReset_ [private]

Configuration: interval (minutes) to reset the data.

Definition at line 114 of file rqsthread.h.

int RqsThread::idleSleep_ [private]

Configuration: msec sleep time if no request processes.

Definition at line 112 of file rqsthread.h.

SrqId RqsThread::maxProcessed_ [private]

The max. object id of the processed requests.

Definition at line 104 of file rqsthread.h.

OSB_LIB::Period RqsThread::period_ [private]

Time period being processed.

Definition at line 102 of file rqsthread.h.

OSB_LIB::DateTime RqsThread::resetTime_ [private]

Time when the thread should next reset its data.

Definition at line 109 of file rqsthread.h.

Stats RqsThread::stats_ [private]

Processing statistics: result vs # of requests.

Definition at line 107 of file rqsthread.h.

---

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

• rqsthread.h

---