| 40 | } |
| 41 | |
| 42 | static AwaitTask probeServer(AwaitEventLoop& await, const SocketDescriptor& serverSocket, SocketDescriptor& accepted) |
| 43 | { |
| 44 | char requestBuffer[32] = {}; |
| 45 | AwaitSocketReceiveResult request; |
| 46 | const char response[] = "PONG"; |
| 47 | |
| 48 | SC_CO_TRY(co_await await.accept(serverSocket, accepted)); |
| 49 | SC_CO_TRY(co_await await.receive(accepted, {requestBuffer, sizeof(requestBuffer)}, request)); |
| 50 | SC_CO_TRY(co_await await.sendAll(accepted, {response, sizeof(response) - 1})); |
| 51 | |
| 52 | co_return Result(true); |
| 53 | } |
| 54 | |
| 55 | static AwaitTask probeClient(AwaitEventLoop& await, const SocketDescriptor& client, SocketIPAddress address, |
| 56 | Span<char> replyBuffer, AwaitSocketReceiveResult& reply) |
no test coverage detected