Class tester

cpp/src/reconnect_test.cpp:183–219

};

class tester : public tester_base, public waiter {
  public:
    tester() : waiter(3), 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));
        // Server that fails on first message
        s2.reset(new server_connection_handler(c, 1, *this));
        // server that doesn't fail in this test
        s3.reset(new server_connection_handler(c, 100, *this));
    }

    // waiter::ready is called when all 3 listeners are ready.
    void ready() override {
        container_.connect(s1->url(), proton::connection_options().failover_urls({s2->url(), s3->url()}));
    }

    void run() {
        container_.run();
        ASSERT_EQUAL(1, start_count);
        ASSERT_EQUAL(3, open_count);
        // Could be > 3, unpredictable number reconnects while listener comes up.
        ASSERT(2 < transport_error_count);
        // Last reconnect fails before opening links
        ASSERT(1 < link_open_count);
        // One final transport close, not an error
        ASSERT_EQUAL(1, transport_close_count);
        ASSERT_EQUAL(0, connection_error_count);
    }

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

int test_failover_simple() {
    tester().run();