Skip to content

Commit

Permalink
Publications from a publisher are done with the correct priotity and …
Browse files Browse the repository at this point in the history
…congestion control
  • Loading branch information
OlivierHecart committed Sep 8, 2023
1 parent 1829a20 commit 960edbc
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions zenoh/src/publication.rs
Original file line number Diff line number Diff line change
Expand Up @@ -431,10 +431,11 @@ impl SyncResolve for Publication<'_> {
if publisher.destination != Locality::SessionLocal {
primitives.send_push(Push {
wire_expr: publisher.key_expr.to_wire(&publisher.session).to_owned(),
ext_qos: ext::QoSType::push_default(), // TODO
// use publisher.priority
// use publisher.congestion_control
// need to check subscriptions to determine the right reliability value
ext_qos: ext::QoSType::new(
publisher.priority.into(),
publisher.congestion_control,
false,
),
ext_tstamp: None,
ext_nodeid: ext::NodeIdType::default(),
payload: PushBody::Put(Put {
Expand Down

0 comments on commit 960edbc

Please sign in to comment.