generic-library/cppzmq
1
0
Fork 0
mirror of https://github.com/zeromq/cppzmq.git synced 2025-05-02 15:41:40 +02:00
Code Issues Projects Releases Wiki Activity

Parse event structure as data for event handlers.

Browse Source
This commit is contained in:
Richard Newton 2013-06-28 14:07:27 +01:00
parent 61a21bb082
commit dfea887ecb
1 changed files with 23 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
zmq.hpp
View File

@ -432,7 +432,7 @@ namespace zmq
public: public:
virtual ~monitor_t() {} virtual ~monitor_t() {}
void monitor(socket_t& socket, const char *addr_, int events = ZMQ_EVENT_ALL) void monitor(socket_t &socket, const char *addr_, int events = ZMQ_EVENT_ALL)
{ {
int rc = zmq_socket_monitor(socket.ptr, addr_, events); int rc = zmq_socket_monitor(socket.ptr, addr_, events);
if (rc != 0) if (rc != 0)
@ -455,37 +455,37 @@ namespace zmq
switch (event->event) { switch (event->event) {
case ZMQ_EVENT_CONNECTED: case ZMQ_EVENT_CONNECTED:
on_event_connected(event->data.connected.addr); on_event_connected(*event);
break; break;
case ZMQ_EVENT_CONNECT_DELAYED: case ZMQ_EVENT_CONNECT_DELAYED:
on_event_connect_delayed(event->data.connect_delayed.addr); on_event_connect_delayed(*event);
break; break;
case ZMQ_EVENT_CONNECT_RETRIED: case ZMQ_EVENT_CONNECT_RETRIED:
on_event_connect_retried(event->data.connect_retried.addr); on_event_connect_retried(*event);
break; break;
case ZMQ_EVENT_LISTENING: case ZMQ_EVENT_LISTENING:
on_event_listening(event->data.listening.addr); on_event_listening(*event);
break; break;
case ZMQ_EVENT_BIND_FAILED: case ZMQ_EVENT_BIND_FAILED:
on_event_bind_failed(event->data.bind_failed.addr); on_event_bind_failed(*event);
break; break;
case ZMQ_EVENT_ACCEPTED: case ZMQ_EVENT_ACCEPTED:
on_event_accepted(event->data.accepted.addr); on_event_accepted(*event);
break; break;
case ZMQ_EVENT_ACCEPT_FAILED: case ZMQ_EVENT_ACCEPT_FAILED:
on_event_accept_failed(event->data.accept_failed.addr); on_event_accept_failed(*event);
break; break;
case ZMQ_EVENT_CLOSED: case ZMQ_EVENT_CLOSED:
on_event_closed(event->data.closed.addr); on_event_closed(*event);
break; break;
case ZMQ_EVENT_CLOSE_FAILED: case ZMQ_EVENT_CLOSE_FAILED:
on_event_close_failed(event->data.close_failed.addr); on_event_close_failed(*event);
break; break;
case ZMQ_EVENT_DISCONNECTED: case ZMQ_EVENT_DISCONNECTED:
on_event_disconnected(event->data.disconnected.addr); on_event_disconnected(*event);
break; break;
default: default:
on_event_unknown(event->event); on_event_unknown(*event);
break; break;
} }
zmq_msg_close (&msg); zmq_msg_close (&msg);
@ -493,17 +493,17 @@ namespace zmq
zmq_close (s); zmq_close (s);
} }
virtual void on_event_connected(const char *addr_) {} virtual void on_event_connected(const zmq_event_t &event_) {}
virtual void on_event_connect_delayed(const char *addr_) {} virtual void on_event_connect_delayed(const zmq_event_t &event_) {}
virtual void on_event_connect_retried(const char *addr_) {} virtual void on_event_connect_retried(const zmq_event_t &event_) {}
virtual void on_event_listening(const char *addr_) {} virtual void on_event_listening(const zmq_event_t &event_) {}
virtual void on_event_bind_failed(const char *addr_) {} virtual void on_event_bind_failed(const zmq_event_t &event_) {}
virtual void on_event_accepted(const char *addr_) {} virtual void on_event_accepted(const zmq_event_t &event_) {}
virtual void on_event_accept_failed(const char *addr_) {} virtual void on_event_accept_failed(const zmq_event_t &event_) {}
virtual void on_event_closed(const char *addr_) {} virtual void on_event_closed(const zmq_event_t &event_) {}
virtual void on_event_close_failed(const char *addr_) {} virtual void on_event_close_failed(const zmq_event_t &event_) {}
virtual void on_event_disconnected(const char *addr_) {} virtual void on_event_disconnected(const zmq_event_t &event_) {}
virtual void on_event_unknown(int event) {} virtual void on_event_unknown(const zmq_event_t &event_) {}
}; };
} }