Function TEST

Utilities/cmcppdap/src/network_test.cpp:48–73

}  // anonymous namespace

TEST(Network, ClientServer) {
  dap::Chan<bool> done;
  auto server = dap::net::Server::create();
  if (!server->start(
          port,
          [&](const std::shared_ptr<dap::ReaderWriter>& rw) {
            ASSERT_EQ(read(rw), "client to server");
            ASSERT_TRUE(write(rw, "server to client"));
            done.put(true);
          },
          [&](const char* err) { FAIL() << "Server error: " << err; })) {
    FAIL() << "Couldn't start server";
    return;
  }

  for (int i = 0; i < 5; i++) {
    auto client = dap::net::connect("localhost", port);
    ASSERT_NE(client, nullptr) << "Failed to connect client " << i;
    ASSERT_TRUE(write(client, "client to server"));
    ASSERT_EQ(read(client), "server to client");
    done.take();
    std::this_thread::sleep_for(std::chrono::seconds(1));
  }

  server.reset();
}

TEST(Network, ServerRepeatStopAndRestart) {
  dap::Chan<bool> done;