@@ -85,8 +85,8 @@ Error poll(Ref<StreamPeerTCP> p_client) {
85
85
const uint64_t time = OS::get_singleton ()->get_ticks_usec ();
86
86
Error err = p_client->poll ();
87
87
while (err != Error::OK && (OS::get_singleton ()->get_ticks_usec () - time ) < MAX_WAIT_USEC) {
88
- err = p_client->poll ();
89
88
OS::get_singleton ()->delay_usec (SLEEP_DURATION);
89
+ err = p_client->poll ();
90
90
}
91
91
return err;
92
92
}
@@ -183,8 +183,8 @@ TEST_CASE("[TCPServer] When stopped shouldn't accept new connections") {
183
183
time = OS::get_singleton ()->get_ticks_usec ();
184
184
Error err = new_client->poll ();
185
185
while (err != Error::OK && err != Error::ERR_CONNECTION_ERROR && (OS::get_singleton ()->get_ticks_usec () - time ) < MAX_WAIT_USEC) {
186
- err = new_client->poll ();
187
186
OS::get_singleton ()->delay_usec (SLEEP_DURATION);
187
+ err = new_client->poll ();
188
188
}
189
189
REQUIRE ((err == Error::OK || err == Error::ERR_CONNECTION_ERROR));
190
190
StreamPeerTCP::Status status = new_client->get_status ();
@@ -210,7 +210,10 @@ TEST_CASE("[TCPServer] Should disconnect client") {
210
210
server->stop ();
211
211
CHECK_FALSE (server->is_listening ());
212
212
213
- client->put_string (hello_world);
213
+ // Reading for a closed connection will print an error.
214
+ ERR_PRINT_OFF;
215
+ CHECK_EQ (client->get_string (), String ());
216
+ ERR_PRINT_ON;
214
217
REQUIRE_EQ (poll (client), Error::OK);
215
218
CHECK_EQ (client->get_status (), StreamPeerTCP::STATUS_NONE);
216
219
}
0 commit comments