Skip to content
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.

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

Protocol update: Entity ID #714

Closed
wants to merge 33 commits into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
33 commits
Select commit Hold shift + click to select a range
2c18758
New Subscribers EntityId behavior for clients and peers
OlivierHecart Feb 2, 2024
ef1034e
Improve routing logging
OlivierHecart Feb 5, 2024
61c7dc3
New Queryables EntityId behavior for clients and peers
OlivierHecart Feb 5, 2024
1173547
Improve routing logging
OlivierHecart Feb 5, 2024
f43e9c1
Use proper QueryableId in Session and AdminSpace
OlivierHecart Feb 7, 2024
373d9a4
Sessions use runtime Id generator to avoid collisions
OlivierHecart Feb 7, 2024
ddcb6d5
AdminSpace use runtime Id generator to avoid collisions
OlivierHecart Feb 7, 2024
585db56
Use proper ResponderId
OlivierHecart Feb 7, 2024
d521496
Define EntityId type
OlivierHecart Feb 7, 2024
053565b
Add source_eid to SourceInfo
OlivierHecart Feb 7, 2024
540e1d1
Update source_info_stack_size test
OlivierHecart Feb 8, 2024
18af62b
Update source_info_stack_size test
OlivierHecart Feb 9, 2024
8398535
Introduce EntityGlobalId type
OlivierHecart Feb 9, 2024
efe1135
Update Reply protocol definition and codec (#717)
Mallets Feb 9, 2024
8b3c094
Add id() function to Subscriber, Queryable and Publisher
OlivierHecart Feb 12, 2024
ccd6b9c
Add Publication::with_source_info() function
OlivierHecart Feb 12, 2024
7811590
Code format
OlivierHecart Feb 15, 2024
4d4bdb2
Remove ref to PR #703
OlivierHecart Feb 15, 2024
d6ffebf
Clean-up of protocol types (#729)
Mallets Feb 15, 2024
cc8d4a1
Allow DeclareInterest for any keyexpr (#739)
Mallets Feb 26, 2024
24e5ef5
ConsolidationMode can be Auto (#738)
Mallets Feb 28, 2024
e41f768
Fix bug building reply
OlivierHecart Feb 28, 2024
9ae62c9
Merge branch 'protocol_changes' into entityid
OlivierHecart Feb 28, 2024
1a60970
Fix doctests
OlivierHecart Feb 29, 2024
77ab676
Merge with main
Mallets Mar 8, 2024
2558a67
Merge branch 'protocol_changes' into entityid
OlivierHecart Mar 11, 2024
a8cdbbe
Revised Encoding API and wire format (#764)
Mallets Mar 12, 2024
b11a20e
Fix protocol comment
Mallets Mar 12, 2024
493502c
Add comments
OlivierHecart Mar 12, 2024
0901a44
Remove comments
OlivierHecart Mar 12, 2024
fcbceb0
Improve Endpoint and Locator doc
Mallets Mar 12, 2024
4b7b131
Merge branch 'protocol_changes' into entityid
OlivierHecart Mar 12, 2024
4cfd6c9
Merge branch 'protocol_changes' into entityid
OlivierHecart Mar 12, 2024
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
140 changes: 112 additions & 28 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

7 changes: 5 additions & 2 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -110,11 +110,12 @@ libloading = "0.8"
log = "0.4.17"
lz4_flex = "0.11"
nix = { version = "0.27", features = ["fs"] }
num_cpus = "1.15.0"
num_cpus = "1.16.0"
ordered-float = "4.1.1"
panic-message = "0.3.0"
paste = "1.0.12"
petgraph = "0.6.3"
phf = { version = "0.11.2", features = ["macros"] }
pnet = "0.34"
pnet_datalink = "0.34"
proc-macro2 = "1.0.51"
Expand All @@ -136,7 +137,9 @@ secrecy = { version = "0.8.0", features = ["serde", "alloc"] }
serde = { version = "1.0.154", default-features = false, features = [
"derive",
] } # Default features are disabled due to usage in no_std crates
serde_json = "1.0.94"
serde_cbor = "0.11.2"
serde_json = "1.0.114"
serde-pickle = "1.1.1"
serde_yaml = "0.9.19"
sha3 = "0.10.6"
shared_memory = "0.12.4"
Expand Down
3 changes: 2 additions & 1 deletion commons/zenoh-buffers/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,8 @@ pub mod buffer {
let mut slices = self.slices();
match slices.len() {
0 => Cow::Borrowed(b""),
1 => Cow::Borrowed(slices.next().unwrap()),
// SAFETY: it's safe to use unwrap_unchecked() beacuse we are explicitly checking the length is 1.
1 => Cow::Borrowed(unsafe { slices.next().unwrap_unchecked() }),
_ => Cow::Owned(slices.fold(Vec::new(), |mut acc, it| {
acc.extend(it);
acc
Expand Down
Loading