adding debug logs

streamingfast · Mar 11, 2024 · c2a82d8 · c2a82d8
1 parent a8ae829
commit c2a82d8
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/app/tier2.go b/app/tier2.go
@@ -138,6 +138,11 @@ func (a *Tier2App) IsReady(ctx context.Context) bool {
 }
 
 func (a *Tier2App) setReadiness(ready bool) {
+	if a.isReady.Load() && !ready {
+		a.logger.Debug("setting app readiness to false")
+	} else if !a.isReady.Load() && ready {
+		a.logger.Debug("setting app readiness to true")
+	}
 	a.isReady.Store(ready)
 }
 

diff --git a/service/tier2.go b/service/tier2.go
@@ -123,6 +123,7 @@ func NewTier2(
 func (s *Tier2Service) isOverloaded() bool {
 	s.connectionCountMutex.RLock()
 	defer s.connectionCountMutex.RUnlock()
+	s.logger.Debug("checking if service is overloaded", zap.Int64("current_concurrent_requests", s.currentConcurrentRequests), zap.Int64("max_concurrent_requests", s.runtimeConfig.MaxConcurrentRequests))
 	return s.runtimeConfig.MaxConcurrentRequests != 0 && s.currentConcurrentRequests >= s.runtimeConfig.MaxConcurrentRequests
 }