Skip to content

refactor(iroh): Spawn RemoteStateActor in JoinSet and remove guarded_channel.rs #3681

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 19 commits into
base: feat-multipath
Choose a base branch
from
Draft

refactor(iroh): Spawn RemoteStateActor in JoinSet and remove guarded_channel.rs #3681

Changes from 1 commit
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
db9d18a
fix
Frando Nov 18, 2025
08061e5
make nicer
Frando Nov 18, 2025
3ee7c69
fix: check if local_addrs are connected
Frando Nov 18, 2025
687d1fd
Merge remote-tracking branch 'origin/feat-multipath' into Frando/mp-f…
Frando Nov 18, 2025
9c19639
chore: add log
Frando Nov 18, 2025
ab321af
chore: trace to debug for netsime
Frando Nov 18, 2025
717ac88
fix: log failed addr in transports send
Frando Nov 18, 2025
7c11665
fix: don't break RemoteStateActor if sending datagram fails
Frando Nov 18, 2025
899df00
Simplify the idle timeout logic & don't short-circuit in `handle_msg_…
matheus23 Nov 20, 2025
e98b835
Merge remote-tracking branch 'origin/feat-multipath' into Frando/mp-f…
matheus23 Nov 20, 2025
2eeac07
fix: add error context add call site
Frando Nov 20, 2025
ff20fa3
chore: clippy
Frando Nov 20, 2025
3f8d72a
Stop the `RemoteStateActor` when the direct addr watcher disconnects
matheus23 Nov 20, 2025
52d4382
Rename `local_addrs` to `local_direct_addrs`
matheus23 Nov 20, 2025
64e9e2d
Replace `RemoteStateHandle` with storing a `JoinSet` in `RemoteMap`
matheus23 Nov 19, 2025
969754d
Remove `guarded_channel` and use `tokio::mpsc` instead. Return leftov…
matheus23 Nov 19, 2025
4c4d11d
Send back leftover messages
matheus23 Nov 20, 2025
5cd4dd1
`cargo make format`
matheus23 Nov 20, 2025
6e09bda
Move leftover msg fetching to the end of `run`
matheus23 Nov 20, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
chore: clippy
  • Loading branch information
@Frando
Frando committed Nov 20, 2025
commit ff20fa3aa55792de89dbfd53c27894ef9b53c28c
6 changes: 2 additions & 4 deletions iroh/src/magicsock/remote_map/remote_state.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -386,10 +386,8 @@ impl RemoteStateActor {
&& self.local_addrs.peek().iter().any(|a| a.addr == *sockaddr)
{
trace!(%sockaddr, "not sending datagram to our own address");
} else {
if let Err(err) = self.send_datagram(addr.clone(), transmit.clone()).await {
debug!(?addr, "failed to send datagram: {err:#}");
}
} else if let Err(err) = self.send_datagram(addr.clone(), transmit.clone()).await {
debug!(?addr, "failed to send datagram: {err:#}");
}
}
// This message is received *before* a connection is added. So we do
Expand Down
Loading