summaryrefslogtreecommitdiff
path: root/crates
Commit message (Collapse)AuthorAgeFilesLines
...
| * | | | Bump MSRV from 1.85.1 to 1.86Clara Engler2025-10-2161-61/+61
| |/ / /
* | | | Merge branch 'p2-blanket-arc' into 'main'David Goulet2025-10-212-7/+30
|\ \ \ \ | | | | | | | | | | | | | | | | | | | | tor-netdoc: blanket impl parse2 traits for Arc See merge request tpo/core/arti!3381
| * | | | tor-netdoc: blanket impl parse2 traits for ArcIan Jackson2025-10-212-7/+30
| |/ / / | | | | | | | | | | | | This replaces one ad-hoc impl and will avoid having to have any more.
* | | | Merge branch 'relay-reactor-fun-2' into 'main'gabi-2502025-10-2120-499/+1472
|\ \ \ \ | |_|/ / |/| | | | | | | | | | | proto: Add the initial implementation of the relay reactor(s) See merge request tpo/core/arti!3369
| * | | proto: Fix broken doc linksGabriela Moldovan2025-10-211-2/+3
| | | |
| * | | proto: Prioritize shutdown over everything elseGabriela Moldovan2025-10-211-8/+8
| | | |
| * | | proto: Ensure RelayReactor shuts down the other reactorsGabriela Moldovan2025-10-213-21/+48
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The `RelayReactor` now holds the sending end of the shutdown broadcast channel, so if `RelayReactor` exits, both the forward and the backward relay reactor will notice and shut down too. Similarly, if the forward or backward reactor exits, the `RelayReactor` will notice (because it select!s between the two), and will shut down
| * | | proto: Add TODO about moving control message handling to RelayReactorGabriela Moldovan2025-10-211-0/+3
| | | |
| * | | proto: Use select not joinGabriela Moldovan2025-10-211-4/+5
| | | | | | | | | | | | | | | | | | | | I used `futures::join` by mistake: the intention here is to have `RelayReactor` exit when either one of the fwd/bwd reactors exits.
| * | | proto: Emphasize that we think 2 reactors are better for perfGabriela Moldovan2025-10-211-4/+8
| | | |
| * | | proto: Add a TODO about splitting out fields out of BackwardReactorGabriela Moldovan2025-10-211-0/+9
| | | |
| * | | proto: Move StreamMap split closer to cell_tx docsGabriela Moldovan2025-10-211-3/+5
| | | | | | | | | | | | | | | | This also clarifies why we reroute cells to `BackwardReactor`.
| * | | proto: s/inbound_rx/input for consistency with other reactorsGabriela Moldovan2025-10-211-2/+2
| | | | | | | | | | | | | | | | | | | | Things will get very confusing if every reactor uses different variable names for this, so I am renaming it back to input.
| * | | proto: Move channel provider to ForwardReactorGabriela Moldovan2025-10-213-18/+18
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The channel provider is used to request outgoing channels from the `ChanMgr` in response to `EXTEND`/`EXTEND2` cells, so it belongs in the `ForwardReactor`. (This was leftover from the old circ reactor architecture)
| * | | proto: Remove no longer needed MutexGabriela Moldovan2025-10-211-7/+5
| | | |
| * | | proto: Remove stray words from docsGabriela Moldovan2025-10-211-1/+1
| | | |
| * | | proto: Disambiguate "channel" and "stream"Gabriela Moldovan2025-10-213-52/+52
| | | |
| * | | proto: Say why there are two reactors instead of just oneGabriela Moldovan2025-10-211-0/+23
| | | |
| * | | proto: Clarify why we may need to forward cells to BackwardReactorGabriela Moldovan2025-10-211-2/+3
| | | |
| * | | proto: Fix docs post-renamingGabriela Moldovan2025-10-211-3/+3
| | | |
| * | | proto: Avoid calling BackwardReactor "primary"Gabriela Moldovan2025-10-211-5/+1
| | | |
| * | | proto: Replace select_biased! with PollAllGabriela Moldovan2025-10-211-32/+124
| | | | | | | | | | | | | | | | | | | | This is the first step towards parallelizing stream reads and writes.
| * | | proto: Replace placeholder () with stream id and msgGabriela Moldovan2025-10-213-8/+16
| | | | | | | | | | | | | | | | | | | | This makes it a bit clearer that `cell_rx` is for moving stream data between `ForwardReactor` and `BackwardReactor`.
| * | | proto: Replace inbound/outbound terminologyGabriela Moldovan2025-10-212-42/+42
| | | | | | | | | | | | | | | | The forward/backward terminology is clearer.
| * | | proto: Write a debug log when the reactor startsGabriela Moldovan2025-10-211-2/+12
| | | |
| * | | proto: Restrict the visibility of BackwardReactorGabriela Moldovan2025-10-211-3/+3
| | | | | | | | | | | | | | | | | | | | BackwardReactor is not meant to be used directly (the channel reactor is supposed to use the `RelayReactor` wrapper instead).
| * | | proto: Move BackwardReactor to its own moduleGabriela Moldovan2025-10-212-443/+466
| | | | | | | | | | | | | | | | | | | | `BackwardReactor` now exists alongside `ForwardReactor`, to make it clearer that they are siblings.
| * | | proto: Add a constructor for BackwardReactorGabriela Moldovan2025-10-211-16/+54
| | | | | | | | | | | | | | | | | | | | We are about to need this, because BackwardReactor will be moved to another module, and we want to keep its internals private.
| * | | proto: Remove no-longer needed Runtime argumentGabriela Moldovan2025-10-211-13/+5
| | | | | | | | | | | | | | | | | | | | | | | | | | | | This is no longer used, and not having it makes the code less generic and easier to read, so I'm removing it for now. If we ever need it again, we can add it back.
| * | | proto: Replace RelayReactor type-alias with structGabriela Moldovan2025-10-211-23/+32
| | | | | | | | | | | | | | | | | | | | | | | | This is the first step towards making `ForwardReactor` and `BackwardReactor` be siblings (rather than being in a primary-subordinate relationship).
| * | | proto: Add spaces in docs to satisfy clippyGabriela Moldovan2025-10-211-3/+3
| | | |
| * | | proto: Fix doc links post-refactoringGabriela Moldovan2025-10-212-3/+7
| | | |
| * | | proto: Add a basic implementation for the relay reactor(s)Gabriela Moldovan2025-10-212-37/+695
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This sketches out the "dual" relay reactor implementation, which has: * a `ForwardReactor`, which forwards cells from the client to the exit * a `BackwardReactor`, which deals with streams, control messages, and forwarding cells from the exit to the client The `BackwardReactor` is actually the "primary" reactor. It's the interface we expose to the channel reactor (via the `RelayReactor` type-alias), and it is in charge of spawning the "secondary" `ForwardReactor` task (via its `run()` function). See the module-level docs from `tor_proto::relay::reactor` for more details on the inner workings of the two reactors. This commit also adds the incomplete skeleton of the circuit extension logic. Once #1599 is implemented, we'll be able to uncomment the commented code, or replace it, depending on what the corresponding channel reactor APIs look like.
| * | | proto: Remove explicit returns to appease clippyGabriela Moldovan2025-10-211-6/+5
| | | |
| * | | proto: Boilerplate for control command handlingGabriela Moldovan2025-10-211-7/+29
| | | | | | | | | | | | | | | | | | | | We only have one command right now (`Shutdown`), so this is mostly just boilerplate.
| * | | proto: s/channel_id/circ_idGabriela Moldovan2025-10-211-1/+1
| | | |
| * | | proto: Replace DynTimeProvider with RuntimeGabriela Moldovan2025-10-211-7/+9
| | | | | | | | | | | | | | | | | | | | We will need a handle to the runtime to spawn the "secondary" reactor from the main one.
| * | | proto: Require that chan_provider is SendGabriela Moldovan2025-10-211-2/+2
| | | |
| * | | proto: Use a broadcast channel for the shutdown handleGabriela Moldovan2025-10-211-5/+6
| | | | | | | | | | | | | | | | | | | | | | | | There will soon be multiple systems that need to be notified of reactor shut down, so it's time to change this to a channel type with a cloneable receiver.
| * | | proto: Move StreamMpsc{Sender,Receiver} to stream module (fmt)Gabriela Moldovan2025-10-215-5/+5
| | | |
| * | | proto: Move StreamMpsc{Sender,Receiver} to stream moduleGabriela Moldovan2025-10-218-11/+18
| | | | | | | | | | | | | | | | These will be shared with the relay code.
| * | | proto: remove extraneous blank lineGabriela Moldovan2025-10-211-1/+0
| | | |
| * | | proto: Remove silly TODO about outgoing chan mgmtGabriela Moldovan2025-10-211-3/+1
| | | | | | | | | | | | | | | | | | | | | | | | The TODO is silly, because there will be no "outgoing channel map". There will be at most *one* outgoing channel, and that is represented by `Option<Outbound>`.
| * | | proto: Move hop settings into a shared moduleGabriela Moldovan2025-10-217-306/+328
| | | |
| * | | proto: Move streammap out of the client module (fmt)Gabriela Moldovan2025-10-213-5/+3
| | | |
| * | | proto: Add TODO about future code motionGabriela Moldovan2025-10-211-0/+4
| | | |
| * | | proto: Move halfstream under streammapGabriela Moldovan2025-10-213-3/+4
| | | | | | | | | | | | | | | | | | | | | | | | That way we don't need to make halfstream `pub(crate)` (we only really use it in streammap, and in the client reactor, because of the `handle_msg()` kludge).
| * | | proto: Move streammap out of the client moduleGabriela Moldovan2025-10-2110-13/+15
| | | |
| * | | proto: Move dumb pipes to top-lvl stream module (fmt)Gabriela Moldovan2025-10-217-7/+7
| | | |
| * | | proto: Move dumb pipes to top-lvl stream moduleGabriela Moldovan2025-10-2110-9/+10
| | | |