Ivan Kozlovic c3da392832 Changes to IPQueues ...

Removed the warnings, instead have a sync.Map where they are
registered/unregistered and can be inspected with an undocumented
monitor page.
Added the notion of "in progress" which is the number of messages
that have beend pop()'ed. When recycle() is invoked this count
goes down.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>

2022-03-17 17:53:06 -06:00

9.1 KiB

Raw Blame History

View Raw