Skip to content

tor-proto: Make stream receive queue unbounded

This MR makes the stream receive queue unbounded. The expectation is that the memquota system will clean up streams if under memory pressure. Required for flow control since we don't know exactly how many stream messages are in flight. See #2030.

This uses some #[cfg(feature = "flowctl-cc")] to compile out an argument of the non-public stream_queue() function. I'm not sure how people feel about conditional compilation on non-public function arguments, but I could instead change this to always include the argument and just #[allow(unused)] instead.

/cc @dgoulet

Merge request reports

Loading