| 93 | } |
| 94 | } |
| 95 | void ConnectivityTest::TestShutdownWithDeadline() { |
| 96 | std::unique_ptr<FlightServerBase> server = TestFlightServer::Make(); |
| 97 | |
| 98 | ASSERT_OK_AND_ASSIGN(auto location, Location::ForScheme(transport(), "127.0.0.1", 0)); |
| 99 | FlightServerOptions options(location); |
| 100 | ASSERT_OK(server->Init(options)); |
| 101 | ASSERT_GT(server->port(), 0); |
| 102 | |
| 103 | auto deadline = std::chrono::system_clock::now() + std::chrono::microseconds(10); |
| 104 | |
| 105 | ASSERT_OK(server->Shutdown(&deadline)); |
| 106 | ASSERT_OK(server->Wait()); |
| 107 | } |
| 108 | void ConnectivityTest::TestBrokenConnection() { |
| 109 | std::unique_ptr<FlightServerBase> server = TestFlightServer::Make(); |
| 110 | ASSERT_OK_AND_ASSIGN(auto location, Location::ForScheme(transport(), "127.0.0.1", 0)); |