mirrors/arti.git/crates/tor-proto/src/stream/flow_control.rs, branch arti-v1.4.6mirror of https://gitlab.torproject.org/tpo/core/arti
http://git.dilluti0n.com/mirrors/arti.git/atom?h=arti-v1.4.62025-07-17T18:01:47Ztor-proto: add the `XonXoffReader` and connect it to the reactor2025-07-17T18:01:47ZSteven Engleropara@torproject.org2025-07-17T05:47:08Zurn:sha1:ac0a34306105bb003573a854c64eedc9cefac51e
The idea here is that the reactor builds an `XonXoffReaderCtrl` for the
new stream, and the `XonXoffReaderCtrl` can receive notifications from
the reactor's `StreamFlowControl`. The `XonXoffReaderCtrl` can be
combined with any `AsyncRead` to build a `XonXoffReader`, essentially
wrapping the `AsyncRead` with a type that handles XON/XOFF flow control.
Essentially, the reactor gives you a type that allows you to add
XON/XOFF flow control support to any `AsyncRead`.
We will add this `XonXoffReader` to the `DataReader` in a future commit.
tor-proto: add plumbing for sending XON2025-07-17T18:01:47ZSteven Engleropara@torproject.org2025-07-16T19:48:06Zurn:sha1:4bcfcc3cae31f901e828369383e4660778eaa8c6
Nothing actually causes an XON to be sent yet. But this adds the code so
that anything holding the `StreamTarget` can request to send an XON.
tor-cell: add `FlowCtrlVersion::V0`2025-07-16T17:36:43ZSteven Engleropara@torproject.org2025-07-16T14:50:18Zurn:sha1:15422178d62506ad61b87a38f59cbc8536c5becdtor-proto: send XOFF messages when the queue grows too large2025-07-16T17:36:43ZSteven Engleropara@torproject.org2025-07-15T04:59:24Zurn:sha1:be5da87e8530a34a88db2a01b42a03431a9df8dbtor-proto: rename `StreamSendFlowControl` and related changes2025-07-15T05:33:24ZSteven Engleropara@torproject.org2025-07-14T18:19:32Zurn:sha1:7e32d68cef82190be965061200736217b5acf17f
The plan is to use `StreamSendFlowControl` (now `StreamFlowControl`) for
both outgoing and incoming directions, so a name change is needed.
This also updates some comments, and renames some related struct fields
that have the word "send" in them.
tor-cell: remove `flowctl-cc` feature and make XON/XOFF cells stable2025-07-15T05:33:18ZSteven Engleropara@torproject.org2025-07-15T05:27:21Zurn:sha1:676dbdb43f2a930b7dc89d2a6275338064fd37bf
I don't see any further changes being needed for these types, and it
simplifies a lot of future code in tor-proto that uses these types.
tor-proto: renamed `get_bytes_per_sec()` to `bytes_per_sec()`2025-07-10T15:11:19ZSteven Engleropara@torproject.org2025-07-10T15:10:53Zurn:sha1:9449449f8d30e531ee65d00f70c0206f558a5727tor-proto: set `XonXoffBased` variant behind "flowctl-cc" feat2025-07-07T17:12:05ZSteven Engleropara@torproject.org2025-06-17T00:33:48Zurn:sha1:93e6336b9192f1240a3744caccfb2925eb7c11eetor-proto: finish support for `StreamSendFlowControl` XON/XOFF2025-07-07T17:12:05ZSteven Engleropara@torproject.org2025-06-16T23:17:59Zurn:sha1:4fb8ad839f6162cfd0e6094d4b90dd2e2a2c162ctor-proto: handle XON/XOFF messages2025-07-07T17:12:05ZSteven Engleropara@torproject.org2025-06-16T23:16:53Zurn:sha1:58a5d3a3b664fdc632ce8a39e6a3481606d63a86