diff options
| author | Felix Fietkau | 2025-06-21 15:12:05 +0000 |
|---|---|---|
| committer | Felix Fietkau | 2025-06-21 15:12:46 +0000 |
| commit | 91a50b27bc78ab77dbce898791afa08b98ebe1f3 (patch) | |
| tree | 0fec4e59206b03d1041ec0a7f6153c368f508512 | |
| parent | dd57c070e94e43a4beda8d351fa66fbf4e431346 (diff) | |
| download | openwrt-91a50b27bc78ab77dbce898791afa08b98ebe1f3.tar.gz | |
unetmsg: make remote connection TCP timeout more aggressive
It is meant for reliable network connections, so requests should fail
early if a node goes down.
Signed-off-by: Felix Fietkau <nbd@nbd.name>
| -rw-r--r-- | package/network/services/unetmsg/files/usr/share/ucode/unetmsg/unetmsgd-remote.uc | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/package/network/services/unetmsg/files/usr/share/ucode/unetmsg/unetmsgd-remote.uc b/package/network/services/unetmsg/files/usr/share/ucode/unetmsg/unetmsgd-remote.uc index b6bf33b399..5dda32c13c 100644 --- a/package/network/services/unetmsg/files/usr/share/ucode/unetmsg/unetmsgd-remote.uc +++ b/package/network/services/unetmsg/files/usr/share/ucode/unetmsg/unetmsgd-remote.uc @@ -15,6 +15,7 @@ let ev_listener, sub; let networks = {}; const USYNC_PORT = 51818; +const TCP_TIMEOUT = 5 * 1000; const pubsub_proto = { get_channel: function() { @@ -300,7 +301,7 @@ function network_open_channel(net, name, peer) return; core.dbg(`Try to connect to ${name}\n`); - sock.setopt(socket.SOL_TCP, socket.TCP_USER_TIMEOUT, 30 * 1000); + sock.setopt(socket.SOL_TCP, socket.TCP_USER_TIMEOUT, TCP_TIMEOUT); sock.connect(addr); let auth_data_cb = (msg) => { if (!network_auth_valid(sock_data.name, sock_data.id, msg.token)) @@ -409,7 +410,7 @@ function network_open(name, info) net.rx_channels = {}; net.tx_channels = {}; - net.socket.setopt(socket.SOL_TCP, socket.TCP_USER_TIMEOUT, 30 * 1000); + net.socket.setopt(socket.SOL_TCP, socket.TCP_USER_TIMEOUT, TCP_TIMEOUT); let cb = () => { let addr = {}; |