Add logs when buff isn't used properly

lil5 · Dec 15, 2024 · 10575d4 · 10575d4
1 parent 4ec26bf
commit 10575d4
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/grpc/routes.go b/grpc/routes.go
@@ -63,9 +63,13 @@ func NewApp() *App {
 	var tbuf *timedbuf.TimedBuf[TimedPayload]
 	var tbufs []*timedbuf.TimedBuf[TimedPayload]
 	if Config.IsBuffered {
+		bufWarnLog := int(float32(Config.BufferSize) * 0.8)
 		tbufs = make([]*timedbuf.TimedBuf[TimedPayload], Config.BufferCluster)
 		flushFunc := func(payloads []TimedPayload) {
 			transfers := []types.Transfer{}
+			if lenPayloads := len(payloads); lenPayloads < bufWarnLog {
+				slog.Warn("Flushing Buffer", "max buffer", Config.BufferSize, "buffer size collected", lenPayloads)
+			}
 			for _, payload := range payloads {
 				transfers = append(transfers, payload.Transfers...)
 			}