mirrors/arti.git/crates/tor-proto/src/client/reactor.rs, branch arti-v2.0.0mirror of https://gitlab.torproject.org/tpo/core/arti
http://git.dilluti0n.com/mirrors/arti.git/atom?h=arti-v2.0.02026-01-29T16:33:21Zproto: Factor ReactorResultChannel into the shared reactor module2026-01-29T16:33:21ZGabriela Moldovangabi@torproject.org2026-01-21T14:16:16Zurn:sha1:5bc82538b484986c031a56766797a8a573c09641
This is not just for clients!
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).
proto: Dedupe IncomingStreamRequestHandler2026-01-12T19:10:54ZGabriela Moldovangabi@torproject.org2026-01-12T18:50:26Zurn:sha1:271603e38f5be23ae3ff756a18fb87406a933e9dproto: Add an immediate order for client CircuitEvent ordering2025-12-10T16:04:26ZDavid Gouletdgoulet@torproject.org2025-12-10T15:25:01Zurn:sha1:a448ab20270f8637d3f34b2af363453fefd621f5
With a protocol violation, we have to immediately deal with such event
before emitting anything on the wire.
Signed-off-by: David Goulet <dgoulet@torproject.org>
proto: Rename CircuitAction and cie to CircuitEvent2025-12-10T16:04:26ZDavid Gouletdgoulet@torproject.org2025-12-10T15:20:41Zurn:sha1:7e69f0b2d31acfad14c3d046e89f8633626785f8
This mirrors also the relay reactor. We've introduced the ProtoViolation
into a previous commit which is not an action but rather an "event" that
happened on a circuit.
And so, better semantic. No behavior change.
Signed-off-by: David Goulet <dgoulet@torproject.org>
proto: Rename Circuit{Action/Event}::Shutdown to ProtoViolation2025-12-10T16:04:26ZDavid Gouletdgoulet@torproject.org2025-12-10T14:24:59Zurn:sha1:1c97ec8836f227209e8dbc19253afcbe1f9e2610
Signed-off-by: David Goulet <dgoulet@torproject.org>
proto: Client circuit reactor now handles AnyChanMsg2025-12-10T16:03:12ZDavid Gouletdgoulet@torproject.org2025-12-08T19:16:33Zurn:sha1:d5ad6142db84d917f0035060f92678da3ba98ee1
This commit removes the CircuitRx* based solely on the client circuit
message and moves it into the top level of the crate so all reactors can
use them.
The client reactor then upon receiving the message, it converts the
AnyChanMsg into a ClientCircChanMsg. On error, this leads to a shutdown
of the entire reactor due to a fatal error.
In order to pull this off, we added a CircuitAction::Shutdown that is
handled as a priority.
Signed-off-by: David Goulet <dgoulet@torproject.org>
proto: Move ClientCircChanMsg into client module2025-12-10T16:03:11ZDavid Gouletdgoulet@torproject.org2025-12-08T18:15:03Zurn:sha1:f3b6759079b571a6c3052adb9d1079df875bdf50
Next commit will also move the Relay specific set into the relay module.
These two sets are becoming specific to the reactor as the circuit
reactor communication channel will use AnyChanMsg instead.
Signed-off-by: David Goulet <dgoulet@torproject.org>
Merge branch 'relay-streams2' into 'main'2025-12-02T20:08:50ZDavid Gouletdgoulet@torproject.org2025-12-02T20:08:50Zurn:sha1:88f06d6a4464bc4d9c129a7e15f847aa004e9403
proto: Start handling incoming streams in the relay reactor
See merge request tpo/core/arti!3487proto: Remove crate-level STREAM_READER_BUFFER reexport2025-11-24T17:03:48ZGabriela Moldovangabi@torproject.org2025-11-19T19:04:32Zurn:sha1:659ff401fe89d5b0474a0b0f478a6c190facb299
All this indirection is making me dizzy.