#include <Sedp.h>
Public Member Functions | |
WaitForAcks () | |
void | ack () |
void | wait_for_acks (unsigned int num_acks) |
void | reset () |
Private Attributes | |
ACE_Thread_Mutex | lock_ |
ACE_Condition_Thread_Mutex | cond_ |
unsigned int | acks_ |
Definition at line 379 of file Sedp.h.
OpenDDS::RTPS::WaitForAcks::WaitForAcks | ( | ) |
void OpenDDS::RTPS::WaitForAcks::ack | ( | ) |
Definition at line 2192 of file Sedp.cpp.
References acks_, cond_, and lock_.
Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::handle_exception(), and OpenDDS::RTPS::Sedp::Task::svc().
02193 { 02194 { 02195 ACE_GUARD(ACE_Thread_Mutex, g, lock_); 02196 ++acks_; 02197 } 02198 cond_.signal(); 02199 }
void OpenDDS::RTPS::WaitForAcks::reset | ( | ) |
Definition at line 2211 of file Sedp.cpp.
Referenced by OpenDDS::RTPS::Spdp::fini_bit().
02212 { 02213 ACE_GUARD(ACE_Thread_Mutex, g, lock_); 02214 acks_ = 0; 02215 // no need to signal, going back to zero won't ever 02216 // cause wait_for_acks() to exit it's loop 02217 }
void OpenDDS::RTPS::WaitForAcks::wait_for_acks | ( | unsigned int | num_acks | ) |
unsigned int OpenDDS::RTPS::WaitForAcks::acks_ [private] |
ACE_Condition_Thread_Mutex OpenDDS::RTPS::WaitForAcks::cond_ [private] |
ACE_Thread_Mutex OpenDDS::RTPS::WaitForAcks::lock_ [private] |