diff --git a/pkg/target/host.go b/pkg/target/host.go index 2b23e246..820fdb3c 100644 --- a/pkg/target/host.go +++ b/pkg/target/host.go @@ -250,6 +250,7 @@ func (h *Host) tryToFlushIfNecessary() { } h.Conn.LastConnUse = time.Now() } + h.hostQueueSize.Set(float64(len(h.Ch))) } // Requires h.Conn.Mutex lock.