#include <MessageServer.h>
Collaboration diagram for MessageServer:
Public Member Functions | |
MessageServer (const ACE_INET_Addr &addrServer, const ACE_INET_Addr &localAddr=ACE_INET_Addr()) | |
MessageServer (AddressClient *addrClient, bool takeOwnership=false, const ACE_INET_Addr &localAddr=ACE_INET_Addr()) | |
~MessageServer (void) | |
int | RegisterWithReactor (ACE_Reactor &theReactor) |
int | RemoveFromReactor (ACE_Reactor &theReactor, bool immediate=false) |
AddressClient * | GetAddressClient () |
virtual int | handle_input (ACE_HANDLE fd) |
virtual ACE_HANDLE | get_handle (void) const |
int | SendMessage (u_int originator, const void *msg, size_t len, u_int dest) |
Protected Types | |
typedef MessageServer::MsgHdr | MsgHdr_t |
typedef std::multimap< u_int, MessageClient * > | ClientMap_t |
typedef ClientMap_t::value_type | ClientValue_t |
typedef AddressClient::AddrList_t | AddrList_t |
Protected Member Functions | |
int | RegisterClient (u_int id, MessageClient *client) |
int | RemoveClient (u_int id, MessageClient *client) |
ClientMap_t::iterator | RemoveClient_i (ClientMap_t::iterator it) |
Protected Attributes | |
ACE_Thread_Mutex | m_clientMutex |
ClientMap_t | m_clients |
AddressClient * | m_pAddrClient |
bool | m_addrClientOwned |
ACE_INET_Addr | m_localAddr |
Private Attributes | |
ACE_SOCK_Dgram | m_socket |
char | m_buf [BUFSIZ] |
Friends | |
class | MessageClient |
|
Definition at line 182 of file MessageServer.h. Referenced by SendMessage(). |
|
Definition at line 147 of file MessageServer.h. |
|
Definition at line 150 of file MessageServer.h. Referenced by RegisterClient(). |
|
Referenced by handle_input(), and SendMessage(). |
|
Definition at line 15 of file MessageServer.cpp. References m_localAddr, and m_socket. |
|
Definition at line 29 of file MessageServer.cpp. References m_localAddr, and m_socket. |
|
Definition at line 46 of file MessageServer.cpp. References m_socket. |
|
Definition at line 195 of file MessageServer.cpp. References AddressClient::get_handle(), and m_socket. |
|
Definition at line 92 of file MessageServer.h. Referenced by PropertyBasedCommFactory::Open(). |
|
Definition at line 202 of file MessageServer.cpp. References m_buf, m_clientMutex, m_clients, MessageServer::MsgHdr::m_destination, MessageServer::MsgHdr::m_magicNumber, MessageServer::MsgHdr::m_msgLength, m_socket, MsgHdr_t, and RemoveClient_i(). |
|
Definition at line 101 of file MessageServer.cpp. References AddressClient::AddBinding(), ClientValue_t, m_clients, m_localAddr, m_pAddrClient, and MessageClient::m_pServer. Referenced by MessageClient::Register(). |
|
Definition at line 58 of file MessageServer.cpp. References m_pAddrClient, and AddressClient::RegisterWithReactor(). Referenced by PropertyBasedCommFactory::Open(). |
|
Definition at line 142 of file MessageServer.cpp. References m_clientMutex, m_clients, and RemoveClient_i(). Referenced by MessageClient::Deregister(). |
|
Definition at line 166 of file MessageServer.cpp. References m_clients, m_localAddr, m_pAddrClient, and AddressClient::RemoveBinding(). Referenced by handle_input(), and RemoveClient(). |
|
Definition at line 82 of file MessageServer.cpp. References m_pAddrClient, and AddressClient::RemoveFromReactor(). Referenced by PropertyBasedCommFactory::Close(). |
|
Definition at line 313 of file MessageServer.cpp. References AddrList_t, AddressClient::GetBindings(), MessageServer::MsgHdr::m_destination, MessageServer::MsgHdr::m_msgLength, m_pAddrClient, m_socket, and MsgHdr_t. |
|
Definition at line 32 of file MessageServer.h. |
|
Definition at line 188 of file MessageServer.h. |
|
Definition at line 194 of file MessageServer.h. Referenced by handle_input(). |
|
Definition at line 184 of file MessageServer.h. Referenced by handle_input(), and RemoveClient(). |
|
Definition at line 185 of file MessageServer.h. Referenced by handle_input(), RegisterClient(), RemoveClient(), and RemoveClient_i(). |
|
Definition at line 190 of file MessageServer.h. Referenced by MessageServer(), RegisterClient(), and RemoveClient_i(). |
|
Definition at line 187 of file MessageServer.h. Referenced by RegisterClient(), RegisterWithReactor(), RemoveClient_i(), RemoveFromReactor(), and SendMessage(). |
|
Definition at line 193 of file MessageServer.h. Referenced by get_handle(), handle_input(), MessageServer(), SendMessage(), and ~MessageServer(). |