apps/pg
1
0
Fork 0
mirror of https://github.com/sigcn/pg.git synced 2026-04-23 00:37:30 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

disco/ws: fix reconnecting too quickly

Browse Source
This commit is contained in:
rkonfj
2024-12-12 19:47:42 +08:00
parent 65ed305c66
commit 8d543681d8
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
disco/ws/ws.go
+3 -2
View File
@@ -348,7 +348,8 @@ func (c *WSConn) runEventsReadLoop() {
slog.Error("[WS] ReadLoopExited", "details", err.Error())
}
c.RestartListener()
retryWaitDuration := 200 * time.Millisecond
retryInitDuration := 200 * time.Millisecond
retryWaitDuration := retryInitDuration
retryMaxDuration := 5 * time.Second
retryRate := 2
for {
@@ -360,7 +361,7 @@ func (c *WSConn) runEventsReadLoop() {
time.Sleep(min(retryWaitDuration, retryMaxDuration))
if err := c.dial(context.Background(), ""); err != nil {
slog.Error("[WS] Connect", "err", err)
retryWaitDuration = retryWaitDuration * time.Duration(retryRate)
retryWaitDuration = max(retryWaitDuration*time.Duration(retryRate), retryInitDuration)
continue
}
break