mirrors/arti.git/crates/tor-proto/src/stream/data.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:02:07Ztor-proto: replace `DataReader`2025-07-17T18:02:07ZSteven Engleropara@torproject.org2025-07-17T07:19:38Zurn:sha1:66eec4843d37547c2e32e8f2e66fdadd999d8bff
`DataReader` -> `DataReaderInner`
`DataReaderNew` -> `DataReader`
This means that the `DataReader` now supports XON/XOFF flow control
using the `XonXoffReader`.
This means that it can receive requests for a new drain rate from the
reactor, and can send the new drain rate to the reactor once there is no
more stream data queued.
tor-proto: add `DataReaderNew`2025-07-17T18:02:07ZSteven Engleropara@torproject.org2025-07-17T06:59:32Zurn:sha1:14d95aee7878ce28cb7f8af539b2bca287e785fc
This will later become `DataReader`.
tor-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 dedicated types for the incoming stream queue2025-07-16T17:36:43ZSteven Engleropara@torproject.org2025-07-15T03:38:23Zurn:sha1:9067118cff859a40772462c20fd0bc44a5e8bedc
XON/XOFF flow control will want to know how many data bytes are queued
on a stream, so the new types track that.
Merge branch 'flow-ctrl' into 'main'2025-07-10T18:01:06Zoparaopara@torproject.org2025-07-10T18:01:06Zurn:sha1:aed51f8d8f6a5e2fde677c65441d10027dc6bf31
tor-proto: Handle incoming XON/XOFF messages
See merge request tpo/core/arti!3054tor-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: establish channel for rate limit updates2025-07-07T17:12:05ZSteven Engleropara@torproject.org2025-06-16T22:28:16Zurn:sha1:dce923d2010f66127a5a68b127778366ef517624tor-proto: code movement2025-07-07T17:12:05ZSteven Engleropara@torproject.org2025-06-16T22:16:34Zurn:sha1:7d76c67597d1dc883dc3f352aa9c0219c9e9ef83
Moves the `DataWriter` impl to immediately after the definition.
tor-proto: small `DataWriter` refactoring2025-07-07T17:12:05ZSteven Engleropara@torproject.org2025-06-16T22:04:18Zurn:sha1:336f5efbb4286d4dbe4f7673a335c260cb04e979tor-proto: fix 0-len buffer bug in `DataReader::poll_read`2025-06-27T03:16:01ZSteven Engleropara@torproject.org2025-06-27T03:15:21Zurn:sha1:128f1899deab582edf637b9f1664f509991de76e