Skip to content

feat(pubsub): intra-process delivery hands the subscriber an Arc<T> #340

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

Open
YuanYuYuan wants to merge 37 commits into
base: main
Choose a base branch
from
Open

feat(pubsub): intra-process delivery hands the subscriber an Arc<T> #340

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
37 commits
Select commit Hold shift + click to select a range
68919a5
feat(pubsub): let a publisher restrict its locality
YuanYuYuan Aug 25, 2026
8b78e1f
feat(pubsub): prototype intra-process Arc<T> delivery without seriali…
YuanYuYuan Aug 25, 2026
827ef32
perf(local_bus): resolve a publisher's channel once, not per message
YuanYuYuan Aug 25, 2026
b240323
feat(zbuf): let a solely owned payload buffer be written in place
YuanYuYuan Aug 26, 2026
40e7df8
chore(deps): point the zenoh-buffers patch at the forge, not GitHub
YuanYuYuan Aug 26, 2026
e4e9302
chore(deps): pin the zenoh-buffers patch to a rev, not a branch
YuanYuYuan Aug 26, 2026
9baef40
fix(pubsub): stop the bus swallowing same-session wire traffic
YuanYuYuan Aug 26, 2026
8a772e7
perf(local_bus): take the locks and the refcounts off the publish path
YuanYuYuan Aug 26, 2026
302d5be
feat(pubsub): ask the graph, and let a sole receiver own the message
YuanYuYuan Aug 27, 2026
a1f87b9
fix(pubsub): let the graph decide, for every publisher
YuanYuYuan Aug 27, 2026
c3c6685
fix(pubsub): three ways a message was silently lost
YuanYuYuan Aug 27, 2026
03284c6
fix(deps): stop requiring an unreleased zenoh-buffers to build
YuanYuYuan Aug 27, 2026
daf5df5
fix(pubsub): the caller asserts the audience; the graph cannot
YuanYuYuan Aug 27, 2026
6867fb8
fix(local_bus): isolate a panicking subscriber, and route user code t…
YuanYuYuan Aug 27, 2026
02a13a1
fix(pubsub): publish_owned lost every remote subscriber, and Publishe…
YuanYuYuan Sep 1, 2026
e336484
fix(local_bus): make Delivery public, as Published now carries it
YuanYuYuan Sep 1, 2026
0f153a3
test: per-path detectors for the three routing defects
YuanYuYuan Sep 1, 2026
a3d8478
test: assert the outcome, not a count
YuanYuYuan Sep 1, 2026
7294c53
fix(pubsub): serve owned subscribers on a Remote publisher
YuanYuYuan Sep 1, 2026
6ccb14c
refactor(pubsub): resolve the route once, and correct the stale docs
YuanYuYuan Sep 1, 2026
4454fc5
docs(pubsub): reattach the shared-callback doc to its own method
YuanYuYuan Sep 1, 2026
953a4a4
style: cargo fmt --all
YuanYuYuan Sep 1, 2026
bdfdf62
docs: fully qualify four intra-doc links
YuanYuYuan Sep 1, 2026
f164b2d
refactor!: drop the pooled-payload feature and its ZBuf accessor
YuanYuYuan Sep 1, 2026
23ea748
fix(pubsub): refuse a publish an owned subscriber cannot receive, and…
YuanYuYuan Sep 2, 2026
efa8430
fix(local_bus): re-raise the re-entrancy violation, count deliveries,…
YuanYuYuan Sep 2, 2026
356747b
fix: repair two bad insertions; document the guard's scope and the gr…
YuanYuYuan Sep 2, 2026
f873263
test: assert deliveries rather than invocations in the panic tests
YuanYuYuan Sep 2, 2026
05ebd82
docs(local_bus): repair a comment mangled by an earlier edit
YuanYuYuan Sep 2, 2026
3a57db0
fix(local_bus): the re-raise must not break a release build
YuanYuYuan Sep 2, 2026
d769c6e
fix(local_bus): unforgeable violation payload, and four routing/accou…
YuanYuYuan Sep 2, 2026
954df5b
fix: capture the subscriber locality before self is consumed
YuanYuYuan Sep 2, 2026
fa5f15b
fix(reentrancy): use non_exhaustive rather than a private unit field
YuanYuYuan Sep 2, 2026
c1a9303
test(reentrancy): assert the violation by type, not by message
YuanYuYuan Sep 2, 2026
95508f5
style(test): satisfy clippy on the hiroz-tests crate
YuanYuYuan Sep 2, 2026
6e2e5e1
docs: drop internal tracker references from shipped source
YuanYuYuan Sep 2, 2026
3397354
style(test): name the subscriber type in publisher_locality
YuanYuYuan Sep 2, 2026
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
1 change: 1 addition & 0 deletions crates/hiroz-tests/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@ serde = { workspace = true } # For CDR serialization in dds_interop tests
serde_json = "1.0" # For parsing --json output in the hu plugin tests

[features]
# Forwards to hiroz; see that crate. Off by default.
default = []
ros-msgs = [
"dep:hiroz-msgs",
Expand Down
Loading
Loading