feat: raise backlog warning log threshold from 1/2 to 2/3 (#113)

rvagg · web-flow · commit 61205bec0de3 · 2024-08-02T15:08:42.000+10:00
diff --git a/websocket.go b/websocket.go
@@ -673,7 +673,7 @@ func (c *wsConn) readFrame(ctx context.Context, r io.Reader) {
 	}
 
 	c.frameExecQueue <- buf
-	if len(c.frameExecQueue) > cap(c.frameExecQueue)/2 {
+	if len(c.frameExecQueue) > 2*cap(c.frameExecQueue)/3 { // warn at 2/3 capacity
 		log.Warnw("frame executor queue is backlogged", "queued", len(c.frameExecQueue), "cap", cap(c.frameExecQueue))
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -673,7 +673,7 @@ func (c *wsConn) readFrame(ctx context.Context, r io.Reader) {`
`673`	`673`	`}`
`674`	`674`
`675`	`675`	`c.frameExecQueue <- buf`
`676`		`- if len(c.frameExecQueue) > cap(c.frameExecQueue)/2 {`
	`676`	`+ if len(c.frameExecQueue) > 2*cap(c.frameExecQueue)/3 { // warn at 2/3 capacity`
`677`	`677`	`log.Warnw("frame executor queue is backlogged", "queued", len(c.frameExecQueue), "cap", cap(c.frameExecQueue))`
`678`	`678`	`}`
`679`	`679`