debug logs

dydxprotocol · Aug 9, 2024 · 7abe7ed · 7abe7ed
1 parent 32db698
commit 7abe7ed
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/protocol/streaming/full_node_streaming_manager.go b/protocol/streaming/full_node_streaming_manager.go
@@ -206,6 +206,9 @@ func (sm *FullNodeStreamingManagerImpl) Subscribe(
 func (sm *FullNodeStreamingManagerImpl) removeSubscription(
 	subscriptionIdToRemove uint32,
 ) {
+	sm.logger.Info(
+		fmt.Sprintf("starting to remove subscription %+v", subscriptionIdToRemove),
+	)
 	subscription := sm.orderbookSubscriptions[subscriptionIdToRemove]
 	if subscription == nil {
 		return
@@ -486,6 +489,9 @@ func (sm *FullNodeStreamingManagerImpl) FlushStreamUpdatesWithLock() {
 			subscriptionUpdates[id] = append(subscriptionUpdates[id], update)
 		}
 	}
+	sm.logger.Info(
+		fmt.Sprintf("flushing updates of length %+v", len(sm.streamUpdateCache)),
+	)
 
 	// Non-blocking send updates through subscriber's buffered channel.
 	// If the buffer is full, drop the subscription.
@@ -497,7 +503,9 @@ func (sm *FullNodeStreamingManagerImpl) FlushStreamUpdatesWithLock() {
 			)
 			select {
 			case subscription.updatesChannel <- updates:
+				sm.logger.Info(fmt.Sprintf("emitting update through channel now len %+v", len(subscription.updatesChannel)))
 			default:
+				sm.logger.Info(fmt.Sprintf("buffer full removing id %+v", id))
 				idsToRemove = append(idsToRemove, id)
 			}
 		}