#include <ThreadSynchWorker.h>
Inheritance diagram for OpenDDS::DCPS::ThreadSynchWorker:
Public Types | |
WORK_OUTCOME_MORE_TO_DO | |
WORK_OUTCOME_NO_MORE_TO_DO | |
WORK_OUTCOME_CLOGGED_RESOURCE | |
WORK_OUTCOME_BROKEN_RESOURCE | |
enum | WorkOutcome { WORK_OUTCOME_MORE_TO_DO, WORK_OUTCOME_NO_MORE_TO_DO, WORK_OUTCOME_CLOGGED_RESOURCE, WORK_OUTCOME_BROKEN_RESOURCE } |
Public Member Functions | |
virtual | ~ThreadSynchWorker () |
virtual WorkOutcome | perform_work ()=0 |
virtual void | schedule_output () |
Indicate that queued data is available to be sent. | |
std::size_t | id () const |
DataLink reference value for diagnostics. | |
Protected Member Functions | |
ThreadSynchWorker (std::size_t id=0) | |
Private Attributes | |
std::size_t | id_ |
Definition at line 18 of file ThreadSynchWorker.h.
WORK_OUTCOME_MORE_TO_DO | |
WORK_OUTCOME_NO_MORE_TO_DO | |
WORK_OUTCOME_CLOGGED_RESOURCE | |
WORK_OUTCOME_BROKEN_RESOURCE |
Definition at line 23 of file ThreadSynchWorker.h.
00023 { 00024 WORK_OUTCOME_MORE_TO_DO, 00025 WORK_OUTCOME_NO_MORE_TO_DO, 00026 WORK_OUTCOME_CLOGGED_RESOURCE, 00027 WORK_OUTCOME_BROKEN_RESOURCE 00028 };
OpenDDS::DCPS::ThreadSynchWorker::~ThreadSynchWorker | ( | ) | [virtual] |
Definition at line 15 of file ThreadSynchWorker.cpp.
References DBG_ENTRY_LVL.
00016 { 00017 DBG_ENTRY_LVL("ThreadSynchWorker","~ThreadSynchWorker",6); 00018 }
ACE_INLINE OpenDDS::DCPS::ThreadSynchWorker::ThreadSynchWorker | ( | std::size_t | id = 0 |
) | [protected] |
Definition at line 11 of file ThreadSynchWorker.inl.
References DBG_ENTRY_LVL.
00012 : id_(id) 00013 { 00014 DBG_ENTRY_LVL("ThreadSynchWorker","ThreadSynchWorker",6); 00015 }
ACE_INLINE std::size_t OpenDDS::DCPS::ThreadSynchWorker::id | ( | ) | const |
DataLink reference value for diagnostics.
Definition at line 19 of file ThreadSynchWorker.inl.
References DBG_ENTRY_LVL, and id_.
Referenced by OpenDDS::DCPS::ScheduleOutputHandler::handle_exception(), OpenDDS::DCPS::ReactorSynch::ReactorSynch(), and OpenDDS::DCPS::ReactorSynch::~ReactorSynch().
00020 { 00021 DBG_ENTRY_LVL("ThreadSynchWorker","id",6); 00022 00023 return id_; 00024 }
virtual WorkOutcome OpenDDS::DCPS::ThreadSynchWorker::perform_work | ( | ) | [pure virtual] |
Implemented in OpenDDS::DCPS::TransportSendStrategy.
Referenced by OpenDDS::DCPS::ThreadSynch::perform_work().
ACE_INLINE void OpenDDS::DCPS::ThreadSynchWorker::schedule_output | ( | ) | [virtual] |
Indicate that queued data is available to be sent.
Reimplemented in OpenDDS::DCPS::TcpSendStrategy.
Definition at line 28 of file ThreadSynchWorker.inl.
References DBG_ENTRY_LVL.
00029 { 00030 DBG_ENTRY_LVL("ThreadSynchWorker","schedule_output",6); 00031 }
std::size_t OpenDDS::DCPS::ThreadSynchWorker::id_ [private] |