#include <PerConnectionSynch.h>
Inheritance diagram for OpenDDS::DCPS::PerConnectionSynch:


Public Member Functions | |
| PerConnectionSynch (ThreadSynchResource *synch_resource) | |
| virtual | ~PerConnectionSynch () |
| virtual void | work_available () |
| virtual int | open (void *) |
| virtual int | svc () |
| virtual int | close (u_long) |
Protected Member Functions | |
| virtual int | register_worker_i () |
| virtual void | unregister_worker_i () |
Private Types | |
| typedef ACE_SYNCH_MUTEX | LockType |
| typedef ACE_Guard< LockType > | GuardType |
| typedef ACE_Condition< LockType > | ConditionType |
Private Attributes | |
| LockType | lock_ |
| ConditionType | condition_ |
| int | work_available_ |
| int | shutdown_ |
typedef ACE_Condition<LockType> OpenDDS::DCPS::PerConnectionSynch::ConditionType [private] |
typedef ACE_Guard<LockType> OpenDDS::DCPS::PerConnectionSynch::GuardType [private] |
typedef ACE_SYNCH_MUTEX OpenDDS::DCPS::PerConnectionSynch::LockType [private] |
| ACE_INLINE OpenDDS::DCPS::PerConnectionSynch::PerConnectionSynch | ( | ThreadSynchResource * | synch_resource | ) |
| OpenDDS::DCPS::PerConnectionSynch::~PerConnectionSynch | ( | ) | [virtual] |
| int OpenDDS::DCPS::PerConnectionSynch::close | ( | u_long | ) | [virtual] |
| int OpenDDS::DCPS::PerConnectionSynch::open | ( | void * | ) | [virtual] |
| int OpenDDS::DCPS::PerConnectionSynch::register_worker_i | ( | ) | [protected, virtual] |
The default implementation is to do nothing here. The subclass may override the implementation in order to do something when the worker registers. Returns 0 for success, -1 for failure.
Reimplemented from OpenDDS::DCPS::ThreadSynch.
| int OpenDDS::DCPS::PerConnectionSynch::svc | ( | ) | [virtual] |
| void OpenDDS::DCPS::PerConnectionSynch::unregister_worker_i | ( | ) | [protected, virtual] |
The default implementation is to do nothing here. The subclass may override the implementation in order to do something when the worker unregisters.
Reimplemented from OpenDDS::DCPS::ThreadSynch.
| void OpenDDS::DCPS::PerConnectionSynch::work_available | ( | ) | [virtual] |
The ThreadSynchWorker would like to have its perform_work() called from the appropriate thread once the ThreadSynchResource claims that it is_ready_for_work().
Implements OpenDDS::DCPS::ThreadSynch.
int OpenDDS::DCPS::PerConnectionSynch::shutdown_ [private] |
int OpenDDS::DCPS::PerConnectionSynch::work_available_ [private] |
1.4.7