Skip to content

Commit f2301a8

Browse files
committed
split check_event
made monitor_socket protected
1 parent 945d60c commit f2301a8

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

zmq.hpp

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2362,8 +2362,6 @@ class monitor_t
23622362
{
23632363
assert(_monitor_socket);
23642364

2365-
zmq::message_t eventMsg;
2366-
23672365
zmq::pollitem_t items[] = {
23682366
{_monitor_socket.handle(), 0, ZMQ_POLLIN, 0},
23692367
};
@@ -2374,7 +2372,14 @@ class monitor_t
23742372
zmq::poll(&items[0], 1, timeout);
23752373
#endif
23762374

2377-
if (items[0].revents & ZMQ_POLLIN) {
2375+
return process_event(items[0].revents);
2376+
}
2377+
2378+
bool process_event(short events)
2379+
{
2380+
zmq::message_t eventMsg;
2381+
2382+
if (events & ZMQ_POLLIN) {
23782383
int rc = zmq_msg_recv(eventMsg.handle(), _monitor_socket.handle(), 0);
23792384
if (rc == -1 && zmq_errno() == ETERM)
23802385
return false;

0 commit comments

Comments
 (0)