Changeset 398 in code for trunk/downstream.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/downstream.go (modified) (1 diff)

trunk/downstream.go

@@ -103 +103 @@
         remoteAddr := ic.RemoteAddr().String()
         logger := &prefixLogger{srv.Logger, fmt.Sprintf("downstream %q: ", remoteAddr)}
+        options := connOptions{Logger: logger}
         dc := &downstreamConn{
-                conn:          *newConn(srv, ic, logger),
+                conn:          *newConn(srv, ic, &options),
                 id:            id,
                 supportedCaps: make(map[string]string),