tendermint

9386 Commits

183 Branches

291 MiB

Tree: e7afc57a6a

Commit Graph

Author	SHA1	Message	Date
M. J. Fromberger	d32913c889	pubsub: Use a dynamic queue for buffered subscriptions (#7177 ) Updates #7156, and a follow-up to #7070. Event subscriptions in Tendermint currently use a fixed-length Go channel as a queue. When the channel fills up, the publisher immediately terminates the subscription. This prevents slow subscribers from creating memory pressure on the node by not servicing their queue fast enough. Replace the buffered channel used to deliver events to buffered subscribers with an explicit queue. The queue provides a soft quota and burst credit mechanism: Clients that usually keep up can survive occasional bursts, without allowing truly slow clients to hog resources indefinitely.	3 years ago

Author

SHA1

Message

Date

M. J. Fromberger

d32913c889

pubsub: Use a dynamic queue for buffered subscriptions (#7177 )

Updates #7156, and a follow-up to #7070.

Event subscriptions in Tendermint currently use a fixed-length Go
channel as a queue. When the channel fills up, the publisher
immediately terminates the subscription. This prevents slow
subscribers from creating memory pressure on the node by not
servicing their queue fast enough.

Replace the buffered channel used to deliver events to buffered
subscribers with an explicit queue. The queue provides a soft
quota and burst credit mechanism: Clients that usually keep up
can survive occasional bursts, without allowing truly slow
clients to hog resources indefinitely.

3 years ago

1 Commits (e7afc57a6a613290666d5e4deed79f180b0a8ba4)