drop consumers if their out buffer fills up

bluesky-social · Nov 3, 2023 · 6b31ee0 · 6b31ee0
1 parent 7be9693
commit 6b31ee0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/events/events.go b/events/events.go
@@ -77,7 +77,10 @@ func (em *EventManager) broadcastEvent(evt *XRPCStreamEvent) {
 					em.rmSubscriber(torem)
 				}(s)
 			default:
-				log.Warnf("event overflow (%d)", len(s.outgoing))
+				log.Warnw("event overflow", "bufferSize", len(s.outgoing), "ident", s.ident)
+				go func(torem *Subscriber) {
+					em.rmSubscriber(torem)
+				}(s)
 			}
 			s.broadcastCounter.Inc()
 		}