Skip to content

Conversation

@pablorfb-meta
Copy link
Contributor

Summary:
Changes the signature of ChannelAddr::serve and ChannelAddr::dial to include a label.

Label is marked as a required argument, hence the changes in so many files, but main change is in net.rs and channel.rs

Logs sample:

[1] listen host-frontend-unix:CIP0z4kzu05gPBSlpQ2dxh3D: new connection from unix:(unnamed)
[0] listen bootstrap-spawn-unix:AE7MIE3IMaJGgpOIFkpFGcdw: new connection from unix:(unnamed)
[0] stopping server: [bootstrap-spawn]unix:AE7MIE3IMaJGgpOIFkpFGcdw; reason: NetRx dropped; channel address: unix:AE7MIE3IMaJGgpOIFkpFGcdw
[0] serve unix:AE7MIE3IMaJGgpOIFkpFGcdw-bootstrap-spawn: received parent token cancellation
[0]: session unix:AE7MIE3IMaJGgpOIFkpFGcdw[bootstrap-spawn].12230889822276986604<-unix:(unnamed): NetRx::process exited its loop with states: initial Next was (seq: 0, ack: 0); final Next is (seq: 1, ack: 0); since acked: 0sec; rcv raw frame count is 1; final result: Ok(())
[0]: session [proc-callback]unix:AE7MIE3IMaJGgpOIFkpFGcdw.12230889822276986604: NetTx exited its loop with state: Running(deliveries: (outbox: (next_seq: 1, deque: []), unacked: (deque: [], largest_acked: (seq=0, since_acked=0sec))), reason: NetTx is dropped)

Differential Revision: D85192987

Summary:
Changes the signature of `ChannelAddr::serve` and `ChannelAddr::dial` to include a label.

Label is marked as a required argument, hence the changes in so many files, but main change is in `net.rs` and `channel.rs`

Logs sample:

```
[1] listen host-frontend-unix:CIP0z4kzu05gPBSlpQ2dxh3D: new connection from unix:(unnamed)
[0] listen bootstrap-spawn-unix:AE7MIE3IMaJGgpOIFkpFGcdw: new connection from unix:(unnamed)
[0] stopping server: [bootstrap-spawn]unix:AE7MIE3IMaJGgpOIFkpFGcdw; reason: NetRx dropped; channel address: unix:AE7MIE3IMaJGgpOIFkpFGcdw
[0] serve unix:AE7MIE3IMaJGgpOIFkpFGcdw-bootstrap-spawn: received parent token cancellation
[0]: session unix:AE7MIE3IMaJGgpOIFkpFGcdw[bootstrap-spawn].12230889822276986604<-unix:(unnamed): NetRx::process exited its loop with states: initial Next was (seq: 0, ack: 0); final Next is (seq: 1, ack: 0); since acked: 0sec; rcv raw frame count is 1; final result: Ok(())
[0]: session [proc-callback]unix:AE7MIE3IMaJGgpOIFkpFGcdw.12230889822276986604: NetTx exited its loop with state: Running(deliveries: (outbox: (next_seq: 1, deque: []), unacked: (deque: [], largest_acked: (seq=0, since_acked=0sec))), reason: NetTx is dropped)
```

Differential Revision: D85192987
@meta-codesync
Copy link

meta-codesync bot commented Oct 22, 2025

@pablorfb-meta has exported this pull request. If you are a Meta employee, you can view the originating Diff in D85192987.

@meta-cla meta-cla bot added the CLA Signed This label is managed by the Meta Open Source bot. label Oct 22, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

CLA Signed This label is managed by the Meta Open Source bot. fb-exported meta-exported

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant