netbird/gvisor
0
0
Fork 0
mirror of https://github.com/netbirdio/gvisor.git synced 2026-05-22 17:12:49 -07:00
Code Issues Packages Projects Releases Wiki Activity

Reduce timeouts when polling

Browse Source 
Fuchsia runs these tests against an in-development stack (Netstack3) that
doesn't yet support the full space of TCP actions. This means we wait for the
full timeout when a test is expected to fail; since these timeouts are 10
seconds, the suite runs for ~20 minutes. Reduce these timeouts to ~2s in hope
that it will be long enough to catch the desired events while reducing runtime
in Fuchsia's CQ.

PiperOrigin-RevId: 498015652
This commit is contained in:
Nick Brown
2022-12-27 12:37:34 -08:00
committed by gVisor bot
parent fdeab8650a
commit d6e67a1b6b
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/syscalls/linux/socket_inet_loopback.cc
+6 -6
View File
@@ -494,7 +494,7 @@ TEST_P(SocketInetLoopbackTest, TCPInfoState) {
.fd = conn_fd.get(),
.events = POLLIN | POLLRDHUP,
};
constexpr int kTimeout = 10000;
constexpr int kTimeout = 2000;
int n = poll(&pfd, 1, kTimeout);
ASSERT_GE(n, 0) << strerror(errno);
ASSERT_EQ(n, 1);
@@ -551,7 +551,7 @@ void TestHangupDuringConnect(const SocketInetTestParam& param,
struct pollfd pfd = {
.fd = client.get(),
};
constexpr int kTimeout = 10000;
constexpr int kTimeout = 2000;
int n = poll(&pfd, 1, kTimeout);
ASSERT_GE(n, 0) << strerror(errno);
ASSERT_EQ(n, 1);
@@ -574,7 +574,7 @@ TEST_P(SocketInetLoopbackTest, TCPListenShutdownDuringConnect) {
void TestListenHangupConnectingRead(const SocketInetTestParam& param,
void (*hangup)(FileDescriptor&)) {
constexpr int kTimeout = 10000;
constexpr int kTimeout = 2000;
TestAddress const& listener = param.listener;
TestAddress const& connector = param.connector;
@@ -943,7 +943,7 @@ TEST_P(SocketInetLoopbackTest, TCPBacklogAcceptAll) {
}
auto accept_connection = [&]() {
constexpr int kTimeout = 10000;
constexpr int kTimeout = 2000;
pollfd pfd = {
.fd = listen_fd.get(),
.events = POLLIN,
@@ -973,7 +973,7 @@ TEST_P(SocketInetLoopbackTest, TCPBacklogAcceptAll) {
// re-send that ACK, to address that case).
for (std::size_t i = 0; i < std::size(waiting_clients); i++) {
SCOPED_TRACE(absl::StrCat("waiting clients i=", i));
constexpr int kTimeout = 10000;
constexpr int kTimeout = 2000;
pollfd pfd = {
.fd = waiting_clients[i].get(),
.events = POLLOUT,
@@ -1170,7 +1170,7 @@ TEST_P(SocketInetLoopbackTest, TCPAcceptAfterReset) {
ASSERT_EQ(addrlen, listener.addr_len);
// Wait for accept_fd to process the RST.
constexpr int kTimeout = 10000;
constexpr int kTimeout = 2000;
pollfd pfd = {
.fd = accept_fd.get(),
.events = POLLIN,