mirrors/arti.git/crates/tor-proto/src/util.rs, branch arti-v2.1.0mirror of https://gitlab.torproject.org/tpo/core/arti
http://git.dilluti0n.com/mirrors/arti.git/atom?h=arti-v2.1.02026-02-12T16:35:14ZRevert "proto: Add a new ToRelayMsg util"2026-02-12T16:35:14ZGabriela Moldovangabi@torproject.org2026-02-11T14:02:06Zurn:sha1:ac562cbef392108c1a9a723f4fb336a6831eb809
This reverts commit 04ab3cd848d7977baf58dd64ebfcad6aa54ecb17.
Reverted because we no longer need to "peek" into the opaque
`CircChanMsg` of a circuit reactor: now the implementation-dependent
part of the reactor is in charge of handling the channel messages,
and extracting `Relay` objects out of RELAY/RELAY_EARLY cells,
which then get processed in the base reactor.
proto: Add a new ToRelayMsg util2026-01-29T16:33:21ZGabriela Moldovangabi@torproject.org2026-01-20T18:34:12Zurn:sha1:04ab3cd848d7977baf58dd64ebfcad6aa54ecb17
This will be used in a future commit, inside the new generic circuit
reactor.
We need it because RELAY cells are handled very similarly, so we need
some way of finding out if a given generic chancell is actually a RELAY
cell that we can handle in an implementation-agnostic way.
proto: Move TimeoutEstimator to util2026-01-29T16:33:21ZGabriela Moldovangabi@torproject.org2026-01-12T10:44:05Zurn:sha1:5c5bf40652f00fff3205fc5a2ff44ad48e96b8de
This will be used in the stream reactor too (and the stream reactor will
eventually replace the corresponding client impl).
tor-proto: Track information on when tunnels were last used2025-11-12T15:00:55ZNick Mathewsonnickm@torproject.org2025-10-29T17:39:56Zurn:sha1:82bee9cb79db4ca7b7c5ecaac68b6f5e1b398fa1
This is part of an implementation for proposal 368.
proto: Add PollAll helper for driving futures in lockstep.2025-09-25T13:37:41ZGabriela Moldovangabi@torproject.org2025-09-18T16:58:14Zurn:sha1:563e8965f9df29735b010eac9a7588fbf0941789proto: Use the CBT to compute half-stream timeouts.2025-09-16T16:43:04ZGabriela Moldovangabi@torproject.org2025-09-16T13:58:58Zurn:sha1:63c833d679aefc13bf4f64703fc56c639f5b6ad3proto: Define a new composable SinkBlocker type.2025-09-04T15:59:39ZNick Mathewsonnickm@torproject.org2025-09-03T17:44:27Zurn:sha1:539e3761c5f09c9cbc3f4891ab4a4314d1a5a952
This type wraps a futures::Sink, and allows it to be temporarily blocked
and unblocked.
I'm going to use this to implement padding-based circuit blocking,
according to the designs in !3225.
tor-proto: add `Notify{Sender,Receiver}` channel2025-06-23T20:36:57ZSteven Engleropara@torproject.org2025-06-23T20:34:15Zurn:sha1:a3eb63512c7efd373b513aa2eabae6a2ec0ad0bf
An async notification channel.
This uses `postage::watch::{Sender,Receiver}` internally.
tor-proto: add a `TokenBucket`2025-06-05T15:14:50ZSteven Engleropara@torproject.org2025-05-27T03:04:50Zurn:sha1:80834f9c356e883651f6ef98fddea7bace0c9e72tor-proto: add 'oneshot_broadcast' util module2024-12-10T19:15:16ZSteven Engleropara@torproject.org2024-11-26T01:50:07Zurn:sha1:2fb804296217a2948e61611d80baed120385f2bc