Add some debug logging around the publish requests logic

locka99 · Nov 5, 2024 · 59f6b8c · 59f6b8c
1 parent fcc89d8
commit 59f6b8c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/src/client/session/services/subscriptions/event_loop.rs b/lib/src/client/session/services/subscriptions/event_loop.rs
@@ -105,6 +105,8 @@ impl SubscriptionEventLoop {
                             if futures.len() < slf.max_inflight_publish {
                                 debug!("Sending publish due to internal tick");
                                 futures.push(slf.static_publish());
+                            } else {
+                                debug!("Skipping publish due to too many inflight requests");
                             }
                             next = slf.session.next_publish_time(true);
                         }
@@ -129,6 +131,8 @@ impl SubscriptionEventLoop {
                                             session_debug!(slf.session, "Publish request timed out, sending another");
                                             if futures.len() < slf.max_inflight_publish {
                                                 futures.push(slf.static_publish());
+                                            } else {
+                                                session_debug!(slf.session, "Too many inflight publish requests, skipping");
                                             }
                                         }
                                         StatusCode::BadTooManyPublishRequests => {