deblan-mirror/nextcloud-spreed-signaling
deblan-mirror/nextcloud-spreed-signaling
1
0
Fork 0
mirror of https://github.com/strukturag/nextcloud-spreed-signaling synced 2026-03-14 14:35:44 +01:00
Code Issues Releases Wiki Activity

Merge pull request #988 from strukturag/jitter-reconnect

Browse source 
Add jitter to reconnect intervals.
This commit is contained in:
Joachim Bauch 2025-05-07 11:26:49 +02:00 • committed by GitHub
commit ffa316b5e2
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 12 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
mcu_janus.go
View file

@ -45,7 +45,7 @@ const (
screenPublisherUserId = 2
initialReconnectInterval = 1 * time.Second
maxReconnectInterval = 32 * time.Second
maxReconnectInterval = 16 * time.Second
)
var (

6
mcu_proxy.go
View file

@ -29,6 +29,7 @@ import (
"errors"
"fmt"
"log"
"math/rand/v2"
"net"
"net/http"
"net/url"
@ -749,7 +750,10 @@ func (c *mcuProxyConnection) scheduleReconnect() {
}
interval := c.reconnectInterval.Load()
c.reconnectTimer.Reset(time.Duration(interval))
// Prevent all servers from reconnecting at the same time in case of an
// interrupted connection to the proxy or a restart.
jitter := rand.Int64N(interval) - (interval / 2)
c.reconnectTimer.Reset(time.Duration(interval + jitter))
interval = interval * 2
if interval > int64(maxReconnectInterval) {

8
proxy/proxy_remote.go
View file

@ -28,6 +28,7 @@ import (
"encoding/json"
"errors"
"log"
"math/rand/v2"
"net"
"net/http"
"net/url"
@ -44,7 +45,7 @@ import (
const (
initialReconnectInterval = 1 * time.Second
maxReconnectInterval = 32 * time.Second
maxReconnectInterval = 16 * time.Second
// Time allowed to write a message to the peer.
writeWait = 10 * time.Second
@ -170,7 +171,10 @@ func (c *RemoteConnection) scheduleReconnect() {
c.close()
interval := c.reconnectInterval.Load()
c.reconnectTimer.Reset(time.Duration(interval))
// Prevent all servers from reconnecting at the same time in case of an
// interrupted connection to the proxy or a restart.
jitter := rand.Int64N(interval) - (interval / 2)
c.reconnectTimer.Reset(time.Duration(interval + jitter))
interval = interval * 2
if interval > int64(maxReconnectInterval) {