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

Unit tests for poller's move operations

Browse Source
This commit is contained in:
Pawel Kurdybacha 2018-05-09 05:57:44 +01:00
parent 559d373da3
commit 625a0ebb41
1 changed files with 53 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
tests/poller.cpp
View File

@ -361,6 +361,59 @@ TEST(poller, wait_one_return)
ASSERT_EQ(count, result);
}
TEST(poller, wait_on_move_constructed_poller)
{
server_client_setup s;
ASSERT_NO_THROW (s.client.send ("Hi"));
zmq::poller_t a;
zmq::poller_t::handler_t handler;
ASSERT_NO_THROW (a.add (s.server, ZMQ_POLLIN, handler));
ASSERT_EQ(1u, a.size ());
zmq::poller_t b {std::move (a)};
ASSERT_EQ(1u, b.size ());
ASSERT_NO_THROW (b.wait (std::chrono::milliseconds {-1}));
}
TEST(poller, wait_on_move_assign_poller)
{
server_client_setup s;
ASSERT_NO_THROW (s.client.send ("Hi"));
zmq::poller_t a;
zmq::poller_t::handler_t handler;
ASSERT_NO_THROW (a.add (s.server, ZMQ_POLLIN, handler));
ASSERT_EQ(1u, a.size ());
zmq::poller_t b;
ASSERT_EQ(0u, b.size ());
b = {std::move (a)};
ASSERT_EQ(1u, b.size ());
ASSERT_NO_THROW (b.wait (std::chrono::milliseconds {-1}));
}
TEST(poller, received_on_move_construced_poller)
{
// Setup server and client
server_client_setup s;
int count = 0;
// Setup poller a
zmq::poller_t a;
ASSERT_NO_THROW(a.add(s.server, ZMQ_POLLIN, [&count](short) {
++count;
}));
// client sends message
ASSERT_NO_THROW(s.client.send("Hi"));
// wait for message and verify it is received
a.wait(std::chrono::milliseconds{500});
ASSERT_EQ(1u, count);
// Move construct poller b
zmq::poller_t b{std::move(a)};
// client sends message again
ASSERT_NO_THROW(s.client.send("Hi"));
// wait for message and verify it is received
b.wait(std::chrono::milliseconds{500});
ASSERT_EQ(2u, count);
}
TEST(poller, remove_from_handler)
{
constexpr auto ITER_NO = 10;