Skip to content

Commit

Permalink
QueryTarget::DEFAULT
Browse files Browse the repository at this point in the history
  • Loading branch information
Mallets committed Feb 9, 2024
1 parent c5ca596 commit 375fd01
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 7 deletions.
6 changes: 3 additions & 3 deletions commons/zenoh-codec/src/network/request.rs
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ where
let mut header = id::REQUEST;
let mut n_exts = ((ext_qos != &ext::QoSType::DEFAULT) as u8)
+ (ext_tstamp.is_some() as u8)
+ ((ext_target != &ext::TargetType::default()) as u8)
+ ((ext_target != &ext::TargetType::DEFAULT) as u8)
+ (ext_budget.is_some() as u8)
+ (ext_timeout.is_some() as u8)
+ ((ext_nodeid != &ext::NodeIdType::default()) as u8);
Expand Down Expand Up @@ -123,7 +123,7 @@ where
n_exts -= 1;
self.write(&mut *writer, (ts, n_exts != 0))?;
}
if ext_target != &ext::TargetType::default() {
if ext_target != &ext::TargetType::DEFAULT {
n_exts -= 1;
self.write(&mut *writer, (ext_target, n_exts != 0))?;
}
Expand Down Expand Up @@ -188,7 +188,7 @@ where
let mut ext_qos = ext::QoSType::DEFAULT;
let mut ext_tstamp = None;
let mut ext_nodeid = ext::NodeIdType::default();
let mut ext_target = ext::TargetType::default();
let mut ext_target = ext::TargetType::DEFAULT;
let mut ext_limit = None;
let mut ext_timeout = None;

Expand Down
2 changes: 1 addition & 1 deletion zenoh-ext/src/subscriber_ext.rs
Original file line number Diff line number Diff line change
Expand Up @@ -337,7 +337,7 @@ impl<'a, 'b, Handler> SubscriberBuilderExt<'a, 'b, Handler>
reliability: Reliability::DEFAULT,
origin: Locality::default(),
query_selector: None,
query_target: QueryTarget::default(),
query_target: QueryTarget::DEFAULT,
query_consolidation: QueryConsolidation::DEFAULT,
query_accept_replies: ReplyKeyExpr::MatchingQuery,
query_timeout: Duration::from_secs(10),
Expand Down
2 changes: 1 addition & 1 deletion zenoh/src/liveliness.rs
Original file line number Diff line number Diff line change
Expand Up @@ -747,7 +747,7 @@ where
.query(
&self.key_expr?.into(),
&Some(KeyExpr::from(*KE_PREFIX_LIVELINESS)),
QueryTarget::default(),
QueryTarget::DEFAULT,
QueryConsolidation::DEFAULT,
Locality::default(),
self.timeout,
Expand Down
4 changes: 2 additions & 2 deletions zenoh/src/session.rs
Original file line number Diff line number Diff line change
Expand Up @@ -775,7 +775,7 @@ impl Session {
session: self,
selector,
scope: Ok(None),
target: QueryTarget::default(),
target: QueryTarget::DEFAULT,
consolidation: QueryConsolidation::DEFAULT,
destination: Locality::default(),
timeout,
Expand Down Expand Up @@ -1701,7 +1701,7 @@ impl Session {
ext_qos: ext::QoSType::REQUEST,
ext_tstamp: None,
ext_nodeid: ext::NodeIdType::default(),
ext_target: request::ext::TargetType::default(),
ext_target: request::ext::TargetType::DEFAULT,
ext_budget: None,
ext_timeout: None,
payload: RequestBody::Pull(Pull {
Expand Down

0 comments on commit 375fd01

Please sign in to comment.