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

allow generic sequence of poller events

Browse Source
This commit is contained in:
hfarooq 2023-10-26 22:03:37 +00:00
parent 160ac8ec61
commit 3f6fe441e4
2 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/poller.cpp
View File

@ -192,6 +192,21 @@ TEST_CASE("poller poll basic", "[poller]")
CHECK(&i == events[0].user_data);
}
TEST_CASE("poller poll basic static array", "[poller]")
{
common_server_client_setup s;
CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none));
zmq::poller_t<int> poller;
std::array<zmq::poller_event<int>, 1> events;
int i = 0;
CHECK_NOTHROW(poller.add(s.server, zmq::event_flags::pollin, &i));
CHECK(1 == poller.wait_all(events, std::chrono::milliseconds{-1}));
CHECK(s.server == events[0].socket);
CHECK(&i == events[0].user_data);
}
TEST_CASE("poller add invalid socket throws", "[poller]")
{
zmq::context_t context;

6
zmq.hpp
View File

@ -108,6 +108,7 @@
#include <cassert>
#include <cstring>
#include <type_traits>
#include <algorithm>
#include <exception>
#include <iomanip>
@ -2714,9 +2715,12 @@ template<typename T = no_user_data> class poller_t
}
}
size_t wait_all(std::vector<event_type> &poller_events,
template <typename Sequence>
size_t wait_all(Sequence &poller_events,
const std::chrono::milliseconds timeout)
{
static_assert(std::is_same<typename Sequence::value_type, event_type>::value,
"Sequence::value_type must be of poller_t::event_type");
int rc = zmq_poller_wait_all(
poller_ptr.get(),
reinterpret_cast<zmq_poller_event_t *>(poller_events.data()),