Relax message bridge disconnected timeouts
When things are struggling or a large message is being transfered,
they are a bit tight.
Change-Id: I2334c3972339dec3eccc475793cdbc691c8fc2a6
Signed-off-by: Austin Schuh <austin.linux@gmail.com>
diff --git a/aos/network/message_bridge_client_lib.h b/aos/network/message_bridge_client_lib.h
index 0552f79..23c982d 100644
--- a/aos/network/message_bridge_client_lib.h
+++ b/aos/network/message_bridge_client_lib.h
@@ -31,6 +31,7 @@
// transmit messages.
class SctpClientConnection {
public:
+ static constexpr std::chrono::seconds kReconnectTimeout{3};
SctpClientConnection(aos::ShmEventLoop *const event_loop,
std::string_view remote_name, const Node *my_node,
std::string_view local_host,
@@ -58,7 +59,7 @@
// from the server for a while we'll try sending it again.
void ScheduleConnectTimeout() {
connect_timer_->Setup(event_loop_->context().monotonic_event_time +
- std::chrono::seconds(1));
+ kReconnectTimeout);
}
// Event loop to register the server on.
diff --git a/aos/network/message_bridge_server_status.h b/aos/network/message_bridge_server_status.h
index 04b30de..e9a3322 100644
--- a/aos/network/message_bridge_server_status.h
+++ b/aos/network/message_bridge_server_status.h
@@ -22,7 +22,7 @@
// the filter.
static constexpr std::chrono::seconds kClientStatisticsStaleTimeout{1};
// Time after which we consider the timestamp stale, and reset the filter.
- static constexpr std::chrono::milliseconds kTimestampStaleTimeout{250};
+ static constexpr std::chrono::milliseconds kTimestampStaleTimeout{1000};
MessageBridgeServerStatus(aos::EventLoop *event_loop,
std::function<void(const Context &)> send_data =
diff --git a/aos/network/message_bridge_test.cc b/aos/network/message_bridge_test.cc
index 74d22c2..2a43170 100644
--- a/aos/network/message_bridge_test.cc
+++ b/aos/network/message_bridge_test.cc
@@ -773,7 +773,8 @@
StopPi2Client();
}
- std::this_thread::sleep_for(std::chrono::seconds(2));
+ std::this_thread::sleep_for(SctpClientConnection::kReconnectTimeout +
+ std::chrono::seconds(1));
{
// Now confirm we are un-synchronized.