Class empty_failover_tester

cpp/src/reconnect_test.cpp:226–254

}

class empty_failover_tester : public tester_base, public waiter {
  public:
     empty_failover_tester() : waiter(1), container_(*this, "reconnect_client") {}

    void on_container_start(proton::container &c) override {
        // Server that fails upon connection
        s1.reset(new server_connection_handler(c, 0, *this));
    }

    // waiter::ready is called when a listener is ready.
    void ready() override {
        container_.connect(s1->url(), proton::connection_options().failover_urls({}));
    }

    void run() {
        container_.run();
        ASSERT_EQUAL(1, start_count);
        ASSERT_EQUAL(1, open_count);
        // Could be >=0, unpredictable number reconnects while listener comes up.
        ASSERT(0 <= transport_error_count);
        ASSERT(0 <= link_open_count);
        ASSERT_EQUAL(1, transport_close_count);
        ASSERT_EQUAL(1, connection_error_count);
    }

  private:
    std::unique_ptr<server_connection_handler> s1;
    proton::container container_;
};

int test_empty_failover() {
    empty_failover_tester().run();