generic-library/cppzmq
1
0
Fork 0
mirror of https://github.com/zeromq/cppzmq.git synced 2025-01-19 08:46:45 +01:00
Code Issues Projects Releases Wiki Activity

fixing monitoring stuff bindings.

Browse Source
This commit is contained in:
montoyaedu 2013-06-28 10:23:18 +02:00
parent c36e3065d2
commit cd0d62e90e
1 changed files with 64 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

86
zmq.hpp
View File

@ -287,18 +287,60 @@ namespace zmq
class monitor_t class monitor_t
{ {
public: public:
virtual void on_event_connected(const char *addr_) = 0;
virtual void on_event_connect_delayed(const char *addr_) = 0; inline monitor_t()
virtual void on_event_connect_retried(const char *addr_) = 0; {
virtual void on_event_listening(const char *addr_) = 0; }
virtual void on_event_bind_failed(const char *addr_) = 0;
virtual void on_event_accepted(const char *addr_) = 0; virtual ~monitor_t()
virtual void on_event_accept_failed(const char *addr_) = 0; {
virtual void on_event_closed(const char *addr_) = 0; }
virtual void on_event_close_failed(const char *addr_) = 0;
virtual void on_event_disconnected(const char *addr_) = 0; // Override on_event_* methods as needed.
virtual void on_event_unknown(int event) = 0; virtual void on_event_connected(int32_t)
{
}
virtual void on_event_connect_delayed(int32_t)
{
}
virtual void on_event_connect_retried(int32_t)
{
}
virtual void on_event_listening(int32_t)
{
}
virtual void on_event_bind_failed(int32_t)
{
}
virtual void on_event_accepted(int32_t)
{
}
virtual void on_event_accept_failed(int32_t)
{
}
virtual void on_event_closed(int32_t)
{
}
virtual void on_event_close_failed(int32_t)
{
}
virtual void on_event_disconnected(int32_t)
{
}
virtual void on_event_unknown(uint16_t)
{
}
}; };
class socket_t class socket_t
@ -424,34 +466,34 @@ namespace zmq
switch (event.event) { switch (event.event) {
case ZMQ_EVENT_CONNECTED: case ZMQ_EVENT_CONNECTED:
mon->on_event_connected(event.data.connected.addr); mon->on_event_connected(event.value);
break; break;
case ZMQ_EVENT_CONNECT_DELAYED: case ZMQ_EVENT_CONNECT_DELAYED:
mon->on_event_connect_delayed(event.data.connect_delayed.addr); mon->on_event_connect_delayed(event.value);
break; break;
case ZMQ_EVENT_CONNECT_RETRIED: case ZMQ_EVENT_CONNECT_RETRIED:
mon->on_event_connect_retried(event.data.connect_retried.addr); mon->on_event_connect_retried(event.value);
break; break;
case ZMQ_EVENT_LISTENING: case ZMQ_EVENT_LISTENING:
mon->on_event_listening(event.data.listening.addr); mon->on_event_listening(event.value);
break; break;
case ZMQ_EVENT_BIND_FAILED: case ZMQ_EVENT_BIND_FAILED:
mon->on_event_bind_failed(event.data.bind_failed.addr); mon->on_event_bind_failed(event.value);
break; break;
case ZMQ_EVENT_ACCEPTED: case ZMQ_EVENT_ACCEPTED:
mon->on_event_accepted(event.data.accepted.addr); mon->on_event_accepted(event.value);
break; break;
case ZMQ_EVENT_ACCEPT_FAILED: case ZMQ_EVENT_ACCEPT_FAILED:
mon->on_event_accept_failed(event.data.accept_failed.addr); mon->on_event_accept_failed(event.value);
break; break;
case ZMQ_EVENT_CLOSED: case ZMQ_EVENT_CLOSED:
mon->on_event_closed(event.data.closed.addr); mon->on_event_closed(event.value);
break; break;
case ZMQ_EVENT_CLOSE_FAILED: case ZMQ_EVENT_CLOSE_FAILED:
mon->on_event_close_failed(event.data.close_failed.addr); mon->on_event_close_failed(event.value);
break; break;
case ZMQ_EVENT_DISCONNECTED: case ZMQ_EVENT_DISCONNECTED:
mon->on_event_disconnected(event.data.disconnected.addr); mon->on_event_disconnected(event.value);
break; break;
default: default:
mon->on_event_unknown(event.event); mon->on_event_unknown(event.event);