#include <AddressClient.h>
Collaboration diagram for AddressClient:
Public Types | |
typedef std::vector< ACE_INET_Addr > | AddrList_t |
Public Member Functions | |
AddressClient (const ACE_INET_Addr &addrServer) | |
~AddressClient (void) | |
int | RegisterWithReactor (ACE_Reactor &theReactor) |
int | RemoveFromReactor (ACE_Reactor &theReactor, bool immediate=false) |
void | SetTimeout (const ACE_Time_Value &tv) |
int | PingServer () |
int | RegisterServerCallback () |
int | RemoveServerCallback () |
int | ClearServerCallbacks () |
int | GetBindings (u_int dest, AddrList_t &theList) |
int | AddBinding (u_int id, const char *binding) |
int | RemoveBinding (u_int id, const char *binding) |
int | ClearBindings () |
virtual int | handle_input (ACE_HANDLE fd) |
virtual ACE_HANDLE | get_handle (void) const |
Protected Types | |
typedef std::map< u_int, AddrList_t > | BindMap_t |
typedef BindMap_t::value_type | BindValue_t |
typedef ReplyQueue< std::string, ACE_SYNCH > | ReplyQueue_t |
Protected Member Functions | |
int | SendCommand (const char *str, std::string &reply) |
Private Attributes | |
ACE_INET_Addr | m_addrServer |
char | m_buf [BUFSIZ] |
ACE_SOCK_Dgram | m_socket |
ACE_Thread_Mutex | m_bindingMutex |
BindMap_t | m_bindings |
ACE_Thread_Mutex | m_pendingReplyMutex |
ReplyQueue_t | m_pendingReplyQueue |
long | m_notificationID |
ACE_Thread_Mutex | m_pingMutex |
ACE_Thread_Condition< ACE_Thread_Mutex > | m_pingCondition |
ACE_Time_Value | m_timeout |
|
Definition at line 50 of file AddressClient.h. Referenced by GetBindings(). |
|
Definition at line 180 of file AddressClient.h. |
|
Definition at line 183 of file AddressClient.h. Referenced by GetBindings(). |
|
Definition at line 188 of file AddressClient.h. |
|
Definition at line 12 of file AddressClient.cpp. References m_socket. |
|
Definition at line 28 of file AddressClient.cpp. References m_socket. |
|
Definition at line 312 of file AddressClient.cpp. References SendCommand(). Referenced by MessageServer::RegisterClient(). |
|
Definition at line 358 of file AddressClient.cpp. References SendCommand(). |
|
Definition at line 206 of file AddressClient.cpp. References m_notificationID, and SendCommand(). |
|
Definition at line 379 of file AddressClient.cpp. References m_socket. Referenced by MessageServer::get_handle(). |
|
Definition at line 224 of file AddressClient.cpp. References AddrList_t, BindValue_t, m_bindingMutex, m_bindings, and SendCommand(). Referenced by MessageServer::SendMessage(). |
|
Definition at line 386 of file AddressClient.cpp. References ReplyQueue< T, >::GetMutex(), ReplyQueue< T, >::IsEmpty_i(), m_bindingMutex, m_bindings, m_buf, m_pendingReplyQueue, m_pingCondition, m_pingMutex, m_socket, and ReplyQueue< T, >::SetReply_i(). |
|
Definition at line 73 of file AddressClient.cpp. References m_addrServer, m_pingCondition, m_pingMutex, and m_socket. Referenced by PropertyBasedCommFactory::Open(), RegisterServerCallback(), and RemoveServerCallback(). |
|
Definition at line 106 of file AddressClient.cpp. References m_notificationID, PingServer(), and SendCommand(). Referenced by PropertyBasedCommFactory::Open(). |
|
Definition at line 34 of file AddressClient.cpp. Referenced by PropertyBasedCommFactory::Open(), and MessageServer::RegisterWithReactor(). |
|
Definition at line 335 of file AddressClient.cpp. References SendCommand(). Referenced by MessageServer::RemoveClient_i(). |
|
Definition at line 48 of file AddressClient.cpp. References RemoveServerCallback(). Referenced by PropertyBasedCommFactory::Close(), and MessageServer::RemoveFromReactor(). |
|
Definition at line 154 of file AddressClient.cpp. References m_notificationID, PingServer(), and SendCommand(). Referenced by RemoveFromReactor(). |
|
Definition at line 471 of file AddressClient.cpp. References ReplyQueue< T, >::GetMutex(), ReplyQueue< T, >::GetReply_i(), m_addrServer, m_pendingReplyQueue, m_socket, and m_timeout. Referenced by AddBinding(), ClearBindings(), ClearServerCallbacks(), GetBindings(), RegisterServerCallback(), RemoveBinding(), and RemoveServerCallback(). |
|
Definition at line 66 of file AddressClient.cpp. References m_timeout. Referenced by PropertyBasedCommFactory::Open(). |
|
Definition at line 200 of file AddressClient.h. Referenced by PingServer(), and SendCommand(). |
|
Definition at line 205 of file AddressClient.h. Referenced by GetBindings(), and handle_input(). |
|
Definition at line 206 of file AddressClient.h. Referenced by GetBindings(), and handle_input(). |
|
Definition at line 202 of file AddressClient.h. Referenced by handle_input(). |
|
Definition at line 211 of file AddressClient.h. Referenced by ClearServerCallbacks(), RegisterServerCallback(), and RemoveServerCallback(). |
|
Definition at line 208 of file AddressClient.h. |
|
Definition at line 209 of file AddressClient.h. Referenced by handle_input(), and SendCommand(). |
|
Definition at line 214 of file AddressClient.h. Referenced by handle_input(), and PingServer(). |
|
Definition at line 213 of file AddressClient.h. Referenced by handle_input(), and PingServer(). |
|
Definition at line 203 of file AddressClient.h. Referenced by AddressClient(), get_handle(), handle_input(), PingServer(), SendCommand(), and ~AddressClient(). |
|
Definition at line 216 of file AddressClient.h. Referenced by SendCommand(), and SetTimeout(). |