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

reliability propagation #1291

Closed
Closed
Changes from 1 commit
Commits
Show all changes
60 commits
Select commit Hold shift + click to select a range
b62ddaf
Add Default for SourceInfo
sashacmc Jun 4, 2024
4614d49
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 3, 2024
2247070
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 4, 2024
5a25296
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 5, 2024
a302174
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 5, 2024
87d9283
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 5, 2024
353c67b
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 5, 2024
859b181
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 5, 2024
16d9e97
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 7, 2024
7a6f645
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 8, 2024
3ffebc6
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 8, 2024
be4f16a
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 12, 2024
e8789d4
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 12, 2024
89ebf40
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 16, 2024
0da9545
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 16, 2024
08f4e40
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 18, 2024
56852f8
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 18, 2024
836778c
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 19, 2024
197b814
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 19, 2024
b9cb6a2
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 19, 2024
5763673
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 22, 2024
f524d6f
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 22, 2024
6c4aed6
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 23, 2024
8f3c76c
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 23, 2024
0d36739
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 24, 2024
0621e3b
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 24, 2024
6293d60
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 24, 2024
e714009
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 25, 2024
ff21f52
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 25, 2024
1bd5e62
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 25, 2024
9c66aac
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 26, 2024
7c6f03e
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 26, 2024
2043adb
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 26, 2024
49adddb
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 29, 2024
871142c
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 30, 2024
7e50919
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 30, 2024
16a07a1
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 31, 2024
f18d3d0
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 31, 2024
852eca5
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Jul 31, 2024
4ebb3d5
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Aug 1, 2024
889fd86
Routing tables maintain SusbcriberInfo (step1)
OlivierHecart Jul 8, 2024
3be7f70
refactor: handle subscriber info update in routing
wyfo Jul 24, 2024
fe42ffc
refactor: refactor queryable info merge
wyfo Jul 24, 2024
8a4f8cc
refactor: refactor `SubscriberInfo` merging
wyfo Jul 26, 2024
86b5e69
refactor: add reliability into `Push`
wyfo Jul 30, 2024
801e0aa
refactor: small refactor
wyfo Aug 1, 2024
5da275d
refactor: fix rebase errors
wyfo Aug 2, 2024
3dda254
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Aug 2, 2024
3d1f8f8
fix: typo
wyfo Aug 2, 2024
2a407a8
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Aug 2, 2024
c1b5116
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Aug 2, 2024
565227a
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Aug 5, 2024
6e79eb0
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Aug 5, 2024
4aeac2a
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Aug 6, 2024
c50768d
Fix is_reliable() function
OlivierHecart Aug 6, 2024
c820ec6
Make routing utils inline
OlivierHecart Aug 6, 2024
b635080
Merge branch 'eclipse-zenoh:dev/1.0.0' into dev/1.0.0
zettascale-bot Aug 6, 2024
f7eb03c
Merge branch 'dev/1.0.0' into dev/reliability_propagation
OlivierHecart Aug 6, 2024
92453a2
Reliability propagation
OlivierHecart Aug 7, 2024
17ddaf4
Fix bug computing local_sub_info
OlivierHecart Aug 7, 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
Prev Previous commit
Fix bug computing local_sub_info
OlivierHecart committed Aug 7, 2024
commit 17ddaf4edf6b37c4072c610a3810b986255b0a13
2 changes: 1 addition & 1 deletion zenoh/src/net/routing/hat/client/pubsub.rs
Original file line number Diff line number Diff line change
@@ -47,7 +47,7 @@ fn local_sub_info(_tables: &Tables, res: &Arc<Resource>, face: &Arc<FaceState>)
let infos = res
.session_ctxs
.values()
.filter(|ctx| ctx.face.id != face.id)
.filter(|ctx| ctx.face.whatami == WhatAmI::Client && ctx.face.id != face.id)
.filter_map(|ctx| ctx.subs);
merge_subscriber_infos(infos).unwrap_or_default()
}
2 changes: 1 addition & 1 deletion zenoh/src/net/routing/hat/p2p_peer/pubsub.rs
Original file line number Diff line number Diff line change
@@ -50,7 +50,7 @@ fn local_sub_info(_tables: &Tables, res: &Arc<Resource>, face: &Arc<FaceState>)
let infos = res
.session_ctxs
.values()
.filter(|ctx| ctx.face.id != face.id)
.filter(|ctx| ctx.face.whatami == WhatAmI::Client && ctx.face.id != face.id)
.filter_map(|ctx| ctx.subs);
merge_subscriber_infos(infos).unwrap_or_default()
}