luo980/cpp-httplib
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test is_alive alongside is_writable

Browse Source
This commit is contained in:
ochafik 2024-10-04 19:14:01 +01:00
parent 993bee49e6
commit 7ba067b789
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
test/test.cc
View File

@ -165,9 +165,11 @@ TEST(SocketStream, is_writable_UNIX) {
};
asSocketStream(fds[0], [&](Stream &s0) {
EXPECT_EQ(s0.socket(), fds[0]);
EXPECT_TRUE(s0.is_alive());
EXPECT_TRUE(s0.is_writable());
EXPECT_EQ(0, close(fds[1]));
EXPECT_FALSE(s0.is_alive());
EXPECT_FALSE(s0.is_writable());
return true;
@ -209,6 +211,7 @@ TEST(SocketStream, is_writable_INET) {
};
asSocketStream(disconnected_svr_sock, [&](Stream &ss) {
EXPECT_EQ(ss.socket(), disconnected_svr_sock);
EXPECT_FALSE(ss.is_alive());
EXPECT_FALSE(ss.is_writable());
return true;
@ -5456,14 +5459,16 @@ TEST(LongPollingTest, ClientCloseDetection) {
svr.Get("/events", [&](const Request & /*req*/, Response &res) {
res.set_chunked_content_provider(
"text/plain", [](std::size_t const, DataSink &sink) -> bool {
EXPECT_TRUE(sink.is_writable()); // the socket is alive
EXPECT_TRUE(sink.is_alive());
EXPECT_TRUE(sink.is_writable());
sink.os << "hello";
auto count = 10;
while (count > 0 && sink.is_writable()) {
while (count > 0 && sink.is_writable() && sink.is_alive()) {
this_thread::sleep_for(chrono::milliseconds(10));
}
EXPECT_FALSE(sink.is_writable()); // the socket is closed
EXPECT_FALSE(sink.is_alive());
EXPECT_FALSE(sink.is_writable());
return true;
});
});