Skip to content

Commit

Permalink
Merge pull request #576 from gummif/gfa/monitor-test-flaky
Browse files Browse the repository at this point in the history
Problem: Intermittent monitor test failures
  • Loading branch information
gummif committed Oct 9, 2022
2 parents 381f699 + 918be1d commit c25f595
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 11 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/ci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ jobs:
libzmqbuild: false
brewinstall: "zeromq"
# windows
- os: "windows-2016"
- os: "windows-2019"
cppstd: "14"
cc: "msbuild"
cxx: "msbuild"
Expand Down
12 changes: 2 additions & 10 deletions tests/monitor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,6 @@
class mock_monitor_t : public zmq::monitor_t
{
public:
void on_event_connect_delayed(const zmq_event_t &, const char *) ZMQ_OVERRIDE
{
++connect_delayed;
++total;
}

void on_event_connected(const zmq_event_t &, const char *) ZMQ_OVERRIDE
{
Expand All @@ -22,7 +17,6 @@ class mock_monitor_t : public zmq::monitor_t
}

int total{0};
int connect_delayed{0};
int connected{0};
};

Expand Down Expand Up @@ -79,15 +73,14 @@ TEST_CASE("monitor init event count", "[monitor]")
common_server_client_setup s{false};
mock_monitor_t monitor;

const int expected_event_count = 2;
const int expected_event_count = 1;
monitor.init(s.client, "inproc://foo");

CHECK_FALSE(monitor.check_event(0));
s.init();

while (monitor.check_event(100) && monitor.total < expected_event_count) {
while (monitor.check_event(1000) && monitor.total < expected_event_count) {
}
CHECK(monitor.connect_delayed == 1);
CHECK(monitor.connected == 1);
CHECK(monitor.total == expected_event_count);
}
Expand Down Expand Up @@ -137,7 +130,6 @@ TEST_CASE("monitor init abort", "[monitor]")
CHECK(cond_var.wait_for(lock, std::chrono::seconds(1),
[&done] { return done; }));
}
CHECK(monitor.connect_delayed == 1);
CHECK(monitor.connected == 1);
monitor.abort();
thread.join();
Expand Down

0 comments on commit c25f595

Please sign in to comment.