summaryrefslogtreecommitdiff
path: root/crates
Commit message (Collapse)AuthorAgeFilesLines
...
* | | tor-proto: log warning for SENDME reactor errorSteven Engler2025-06-261-5/+10
| | |
* | | tor-proto: remove unneeded `DataReaderState::ReadingCell` stateSteven Engler2025-06-261-10/+6
| | | | | | | | | | | | | | | Now that we no longer need to store a future, there's no need for this state since we're never pending waiting for a future to complete.
* | | tor-proto: rework `StreamReceiver` into a `futures::Stream`Steven Engler2025-06-264-75/+123
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Having this be a `futures::Stream` makes it nicer to work with. For example we are able to remove a boxed future from `DataReaderState`, which should be better for performance and makes the code simpler. As mentioned in a previous commit when this type was named `StreamReader`, this type is public in the API, but is not actually accessible. As far as I can tell there is no way to construct it or access it.
* | | Make `StreamTarget::send_sendme` non-asyncSteven Engler2025-06-263-33/+24
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | There are some pros/cons to this change: Pros: 1. The only remaining `await` in `StreamReceiver::recv` is for polling the receiver, which means we can turn the `StreamReceiver` into a `Stream` in a future commit. 2. We won't block the user from receiving messages while we wait for the circuit reactor to receive our SENDME message and send it on the outgoing channel. 3. The `StreamReceiver` doesn't really care if it can't send the SENDME. There isn't anything it can do, the circuit hop can go away for external reasons like a DESTROY message, and we still want to return all queued messages to the user anyways. Cons: 1. If the `StreamReceiver` sends a SENDME request to the circuit reactor, and the circuit reactor fails to send the SENDME, there's no good way for the reactor to communicate this back to the `StreamReceiver`.
* | | tor-proto: rename `StreamReader` to `StreamReceiver`Steven Engler2025-06-267-36/+42
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | In rust, the typical nomenclature is to use "receiver" for channels, and "reader" for byte streams. For example `mpsc::Receiver` for something that returns objects and `AsyncRead` for something that reads bytes. Since we also have a `DataReader` for reading bytes, I think renaming this from `StreamReader` to `StreamReceiver` better describes what it is (it's not a "reader" in the typical `Read`/`AsyncRead` sense). This type is public in the API, but is not actually accessible. As far as I can tell there is no way to construct it or access it.
* | | Merge branch 'ticket_2006' into 'main'Alexander Hansen Færøy2025-06-262-6/+8
|\ \ \ | | | | | | | | | | | | | | | | | | | | | | | | Improve descriptions of rejected relays: omit "rejected 0/X" Closes #2006 See merge request tpo/core/arti!3072
| * | | Improve descriptions of rejected relays: omit "rejected 0/X"Nick Mathewson2025-06-252-6/+8
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Now instead of saying "rejected 0/40 as not usable as middle relay; 28/40 as in same family as already selected", we say "rejected 28/40 as in same family as already selected". Closes #2006.
* | | | proto: Remove unused function from ConfluxSetDavid Goulet2025-06-261-5/+0
| | | | | | | | | | | | | | | | Signed-off-by: David Goulet <[email protected]>
* | | | hsservice: Stop using HopNum and use TargetHopDavid Goulet2025-06-266-28/+39
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This requires some changes to the tor-proto crate to handle the inbound TargetHop from the HS subsystem and then resolve it into a HopNum for a single circuit. It is expected that this will change again with Conflux to only use HopLocation internally in a Tunnel and then use HopNum into a Circuit. Signed-off-by: David Goulet <[email protected]>
* | | | proto: Make send_raw_msg() use a TargetHopDavid Goulet2025-06-263-16/+24
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | In order for this to work, a last_target_hop() function is added to ClientCirc in order to return a precise hop location as a TargetHop of the last hop. This is needed because in the HS subsystem, we need such value in order to get a location on the last physical hop before adding the virtual hop. The RDV1 cell is sent to that last target hop while the allow_stream_request() is done on the virtual target hop. Signed-off-by: David Goulet <[email protected]>
* | | | hs: Remove the use of HopNum and instead use TargetHopDavid Goulet2025-06-269-18/+54
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This is in the spirit of making everything going inbound the tor-proto crate to use a TargetHop. This becomes much easier for the HS subsystem as it only uses the last hop for its conversation and setup. Signed-off-by: David Goulet <[email protected]>
* | | | proto: Add From<(UniqId, HopNum)> for TargetHopDavid Goulet2025-06-261-0/+6
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Quick helper as within the tor-proto crate, we sometimes have to quickly get a TargetHop. This will come handy with the message handler used by the Conversation object that the HS subsystem uses. Signed-off-by: David Goulet <[email protected]>
* | | | proto: Add a control command to get the binding keyDavid Goulet2025-06-263-16/+42
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This allows us to use TargetHop instead of HopNum but also to get one step closer to not depend on a mutable state. We prefer resolving a TargetHop within the Reactor object in order to use the circuit list instead of the MutableState path. The HS service subsystem is modified to use this modified function that is now async and uses a TargetHop. Signed-off-by: David Goulet <[email protected]>
* | | | proto: Make TargetHop and HopLocation publicDavid Goulet2025-06-262-7/+5
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This is about to be used outside of tor-proto. It is part of the work to remove the use of HopNum outside tor-proto. The rules are: - Inbound requsest to the tor-proto crate, TargetHop must always be used. - Within tor-proto, TargetHop is resolved into a HopLocation which is more precise and based on the tunnel circuit(s). This is another piece that Conflux will require considering that a Tunnel might have multiple circuits in the future. Signed-off-by: David Goulet <[email protected]>
* | | | proto: Add helper function to resolve TargetHopDavid Goulet2025-06-261-0/+13
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The Reactor has two functions to resolve both TargetHop into a HopLocation and then a HopLocation into a (UniqId, HopNum). This commit simply adds a helper that does both but returns an Option instead of a Result as it will be used by the reactor command handler and more in future conflux commits. Signed-off-by: David Goulet <[email protected]>
* | | | Merge branch 'notify' into 'main'opara2025-06-253-0/+187
|\ \ \ \ | | | | | | | | | | | | | | | | | | | | tor-proto: Add `Notify{Sender,Receiver}` channel See merge request tpo/core/arti!3066
| * | | | tor-proto: add `Notify{Sender,Receiver}` channelSteven Engler2025-06-233-0/+187
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | An async notification channel. This uses `postage::watch::{Sender,Receiver}` internally.
* | | | | Merge branch 'mockable-time' into 'main'David Goulet2025-06-253-7/+20
|\ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | tor-proto: Give Circuit a handle to the DynTimeProvider. See merge request tpo/core/arti!3063
| * | | | | tor-proto: Use mockable runtime in congestion control RTT estimator (fmt).Gabriela Moldovan2025-06-231-1/+2
| | | | | |
| * | | | | tor-proto: Use mockable runtime in congestion control RTT estimator.Gabriela Moldovan2025-06-232-7/+13
| | | | | |
| * | | | | tor-proto: Give Circuit a handle to the DynTimeProvider.Gabriela Moldovan2025-06-232-0/+6
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This will enable us to replace the calls to `Instant::now()` with `DynTimeProvider::now()` throughout the RTT estimator. This gives us the ability to mock the time, and test that conflux leg switching occurs as expected.
* | | | | | proto: Rewrite can_crosscheck_with_current_estimate for clarity.Gabriela Moldovan2025-06-251-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The expanded expression makes it easier to see that `can_crosscheck_with_current_estimate()` can never return `true` if `self.ewma_rtt` is `None`, and that the `expect()` from `is_clock_stalled()` cannot panic.
* | | | | | proto: Make RTT estimates default to None (fmt).Gabriela Moldovan2025-06-251-2/+6
| | | | | |
* | | | | | proto: Make RTT estimates default to None.Gabriela Moldovan2025-06-251-31/+48
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The `RttEstimator` now uses `None` to represent not-yet-measured RTTs. Previously, all the measured RTTs defaulted to 0, in contradiction with the `RttEstimator::{min,ewma}_rtt_usec()` docs, which state that both functions are supposed to return `u32::MAX` if there is no estimate. Closes #2049
* | | | | | Merge branch 'fix-xon-xoff' into 'main'Nick Mathewson2025-06-252-6/+6
|\ \ \ \ \ \ | |_|_|/ / / |/| | | | | | | | | | | | | | | | | tor-cell: Fix incorrect XON/XOFF cell command integers See merge request tpo/core/arti!3061
| * | | | | tor-cell: fix incorrect XON/XOFF cell command integersSteven Engler2025-06-232-6/+6
| | | | | |
* | | | | | tor-proto: Compile-time key length constant equality assertionhashcatHitman2025-06-241-6/+4
| |_|_|/ / |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | - Made an equality assertion between two constants compile-time, resolving a TODO. Signed-off-by: hashcatHitman <[email protected]>
* | | | | Merge branch 'conflux-typos' into 'main'Nick Mathewson2025-06-231-2/+2
|\ \ \ \ \ | |_|_|/ / |/| | | | | | | | | | | | | | tor-proto: Typo fixes in conflux docs and comments See merge request tpo/core/arti!3065
| * | | | tor-proto: Add missing word in conflux docs.Gabriela Moldovan2025-06-231-1/+1
| | | | |
| * | | | tor-proto: Fix typo in comment.Gabriela Moldovan2025-06-231-1/+1
| | |/ / | |/| |
* | | | Merge branch 'log-unexpected-params' into 'main'Jim Newsome2025-06-231-2/+75
|\ \ \ \ | |/ / / |/| | | | | | | | | | | Add logging for possibly-bad net params See merge request tpo/core/arti!3043
| * | | NetParameters::saturating_update: log when a value is out of rangeJim Newsome2025-06-231-1/+71
| | | | | | | | | | | | | | | | | | | | | | | | | | | | On one hand, this can be quite noisy when something *is* out of range. On the other hand, a clamped value shouldn't normally happen, and is likely to result in surprising and otherwise difficult-to-debug behavior.
| * | | Log unrecognized net paramsJim Newsome2025-06-231-1/+4
| | | |
* | | | tor-rtmock: Blocking::blocking_io: add clarificationIan Jackson2025-06-231-0/+3
| | | |
* | | | tor-rtmock: Blocking::spawn_blocking: clarify drop behaviourIan Jackson2025-06-231-0/+6
| |/ / |/| | | | | | | | | | | Explain that you don't need to .await the returned future, and say what happens when you drop it.
* | | Merge branch 'the-dependency-formerly-known-as-once-cell' into 'main'Nick Mathewson2025-06-2339-104/+96
|\ \ \ | | | | | | | | | | | | | | | | various crates: Removed dependency on `once_cell` See merge request tpo/core/arti!3051
| * | | tor-rpcbase: Removed dependency on `once_cell`hashcatHitman2025-06-145-13/+13
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-relay-selection: Removed dependency on `once_cell`hashcatHitman2025-06-142-3/+2
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-netdoc: Removed dependency on `once_cell`hashcatHitman2025-06-1410-41/+41
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-log-ratelim: Removed dependency on `once_cell`hashcatHitman2025-06-143-4/+3
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-llcrypto: Removed dependency on `once_cell`hashcatHitman2025-06-142-3/+2
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-dirmgr: Removed dependency on `once_cell`hashcatHitman2025-06-143-7/+9
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-config-path: Removed dependency on `once_cell`hashcatHitman2025-06-143-9/+8
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-config: Removed dependency on `once_cell`hashcatHitman2025-06-142-3/+2
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-circmgr: Reduced dependency on `once_cell`hashcatHitman2025-06-141-2/+2
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | fs-mistrust: Removed dependency on `once_cell`hashcatHitman2025-06-143-8/+6
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | arti-relay: Removed dependency on `once_cell`hashcatHitman2025-06-143-8/+7
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::sync::Lazy` with `std::sync::LazyLock`. Signed-off-by: hashcatHitman <[email protected]>
| * | | tor-error: Removed dependency on `once_cell`hashcatHitman2025-06-132-3/+1
| | | | | | | | | | | | | | | | | | | | | | | | - Replaced `once_cell::unsync::Lazy` with `std::cell::LazyCell`. Signed-off-by: hashcatHitman <[email protected]>
* | | | arti: keys: Fix arti keys help messagehjrgrn2025-06-232-3/+3
| | | |
* | | | arti console logging: use stderr instead of stdoutJim Newsome2025-06-173-4/+5
| | | | | | | | | | | | | | | | Fixes #2024
generated by cgit v1.2.3 (git 2.46.0) at 2026-08-27 21:44:49 +0000