Changeset 398 in code for trunk/user.go

Timestamp:

Aug 19, 2020, 5:42:33 PM (5 years ago)

Author:

contact

Message:

Implement rate limiting for upstream messages

Allow up to 10 outgoing messages in a burst, then throttle to 1 message
each 2 seconds.

Closes: ​https://todo.sr.ht/~emersion/soju/87

File:

• trunk/user.go (modified) (1 diff)

trunk/user.go

@@ -121 +121 @@
                 }
 
-                if dur := time.Now().Sub(lastTry); dur < retryConnectMinDelay {
-                        delay := retryConnectMinDelay - dur
+                if dur := time.Now().Sub(lastTry); dur < retryConnectDelay {
+                        delay := retryConnectDelay - dur
                         net.user.srv.Logger.Printf("waiting %v before trying to reconnect to %q", delay.Truncate(time.Second), net.Addr)
                         time.Sleep(delay)