#include <maciORBTask.h>

Public Member Functions | |
| ORBTask (CORBA::ORB_ptr orb, LoggingProxy *logger=0, unsigned int timeToRun=0) | |
Private Member Functions | |
| virtual int | svc (void) |
| Thread entry point (thread worker). | |
Private Attributes | |
| CORBA::ORB_var | m_orb |
| CORBA ORB whose request to handle. | |
| LoggingProxy * | m_logger |
| Logger. | |
| unsigned int | m_timeToRun |
| Time to run CORBA ORB in seconds, 0 means until shutdown/destroy. | |
Implementation of the task (set of thread workers) which will later handle CORBA requests. This implementation uses multithreaded TAO ORB design. Example of usage:
ORBTask worker (orb.in(), m_logger);
// activate worker
if (worker.activate(THR_NEW_LWP | THR_JOINABLE, nthreads) == 0)
// wait until all workers do its work, i.e. until ORB is destroyed
worker.thr_mgr ()->wait ();
else
// report error here
| maci::ORBTask::ORBTask | ( | CORBA::ORB_ptr | orb, | |
| LoggingProxy * | logger = 0, |
|||
| unsigned int | timeToRun = 0 | |||
| ) |
Constructor of the ORBTask class.
| orb | CORBA ORB whose request to handle. | |
| logger | logger to be initialized in each thread. | |
| timeToRun | time in seconds to run CORBA ORB, 0 means until shutdown/destroy. |
| virtual int maci::ORBTask::svc | ( | void | ) | [private, virtual] |
Thread entry point (thread worker).
LoggingProxy* maci::ORBTask::m_logger [private] |
Logger.
CORBA::ORB_var maci::ORBTask::m_orb [private] |
CORBA ORB whose request to handle.
unsigned int maci::ORBTask::m_timeToRun [private] |
Time to run CORBA ORB in seconds, 0 means until shutdown/destroy.
1.7.0