Add logging to the session refresh (#3083)

livepeer · Jun 21, 2024 · 3dcdf3d · 3dcdf3d
1 parent 20e81fb
commit 3dcdf3d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/server/broadcast.go b/server/broadcast.go
@@ -288,7 +288,9 @@ func (sp *SessionPool) selectSessions(ctx context.Context, sessionsNum int) []*B
 
 	checkSessions := func(m *SessionPool) bool {
 		numSess := m.sel.Size()
-		if numSess < int(math.Min(maxRefreshSessionsThreshold, math.Ceil(float64(m.numOrchs)/2.0))) {
+		refreshThreshold := int(math.Min(maxRefreshSessionsThreshold, math.Ceil(float64(m.numOrchs)/2.0)))
+		clog.Infof(ctx, "Checking if the session refresh is needed, numSess=%v, refreshThreshold=%v", numSess, refreshThreshold)
+		if numSess < refreshThreshold {
 			go m.refreshSessions(ctx)
 		}
 		return (numSess > 0 || len(sp.lastSess) > 0)