generic-library/cppzmq
1
0
Fork 0
mirror of https://github.com/zeromq/cppzmq.git synced 2024-12-13 10:52:57 +01:00
Code Issues Projects Releases Wiki Activity

split check_event

Browse Source 
made monitor_socket protected
This commit is contained in:
Stefan Dietel 2023-08-25 14:18:32 +02:00
parent 945d60c36b
commit f2301a8769
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
zmq.hpp
View File

@ -2362,8 +2362,6 @@ class monitor_t
{ {
assert(_monitor_socket); assert(_monitor_socket);
zmq::message_t eventMsg;
zmq::pollitem_t items[] = { zmq::pollitem_t items[] = {
{_monitor_socket.handle(), 0, ZMQ_POLLIN, 0}, {_monitor_socket.handle(), 0, ZMQ_POLLIN, 0},
}; };
@ -2374,7 +2372,14 @@ class monitor_t
zmq::poll(&items[0], 1, timeout); zmq::poll(&items[0], 1, timeout);
#endif #endif
if (items[0].revents & ZMQ_POLLIN) { return process_event(items[0].revents);
}
bool process_event(short events)
{
zmq::message_t eventMsg;
if (events & ZMQ_POLLIN) {
int rc = zmq_msg_recv(eventMsg.handle(), _monitor_socket.handle(), 0); int rc = zmq_msg_recv(eventMsg.handle(), _monitor_socket.handle(), 0);
if (rc == -1 && zmq_errno() == ETERM) if (rc == -1 && zmq_errno() == ETERM)
return false; return false;