Skip to content

Commit

Permalink
tags
Browse files Browse the repository at this point in the history
  • Loading branch information
milyin committed Mar 4, 2024
1 parent 2453ef3 commit e8661ab
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 0 deletions.
2 changes: 2 additions & 0 deletions docs/api_missing_tags.txt
Original file line number Diff line number Diff line change
Expand Up @@ -11,3 +11,5 @@ Purposedly not added: in Rust they exinsts only because DeelteBuilder is an alia
tags{api.downsampling_item_conf(TODO)}
tags{api.downsampling_rule_conf(TODO)}

tags{api.get.access_replies.set(TODO)}
tags{api.get.allowed_destination.set(TODO)}
2 changes: 2 additions & 0 deletions include/zenoh_commons.h
Original file line number Diff line number Diff line change
Expand Up @@ -2716,6 +2716,7 @@ int8_t zc_put_owned(struct z_session_t session,
* The `recv` end is a synchronous closure that will block until either a `z_owned_query_t` is available,
* which it will then return; or until the `send` closure is dropped and all queries have been consumed,
* at which point it will return an invalidated `z_owned_query_t`, and so will further calls.
* tags{c.zc_query_fifo_new, api.get.channel}
*/
ZENOHC_API
struct z_owned_query_channel_t zc_query_fifo_new(size_t bound);
Expand All @@ -2729,6 +2730,7 @@ struct z_owned_query_channel_t zc_query_fifo_new(size_t bound);
* The `recv` end is a synchronous closure that will block until either a `z_owned_query_t` is available,
* which it will then return; or until the `send` closure is dropped and all queries have been consumed,
* at which point it will return an invalidated `z_owned_query_t`, and so will further calls.
* tags{c.zc_query_non_blocking_fifo_new , api.get.channel}
*/
ZENOHC_API
struct z_owned_query_channel_t zc_query_non_blocking_fifo_new(size_t bound);
Expand Down
2 changes: 2 additions & 0 deletions src/closures/query_channel.rs
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,7 @@ pub extern "C" fn z_query_channel_null() -> z_owned_query_channel_t {
/// which it will then return; or until the `send` closure is dropped and all queries have been consumed,
/// at which point it will return an invalidated `z_owned_query_t`, and so will further calls.
#[no_mangle]
/// tags{c.zc_query_fifo_new, api.get.channel}
pub extern "C" fn zc_query_fifo_new(bound: usize) -> z_owned_query_channel_t {
let (send, rx) = if bound == 0 {
let (tx, rx) = std::sync::mpsc::channel();
Expand Down Expand Up @@ -98,6 +99,7 @@ pub extern "C" fn zc_query_fifo_new(bound: usize) -> z_owned_query_channel_t {
/// which it will then return; or until the `send` closure is dropped and all queries have been consumed,
/// at which point it will return an invalidated `z_owned_query_t`, and so will further calls.
#[no_mangle]
/// tags{c.zc_query_non_blocking_fifo_new , api.get.channel}
pub extern "C" fn zc_query_non_blocking_fifo_new(bound: usize) -> z_owned_query_channel_t {
let (send, rx) = if bound == 0 {
let (tx, rx) = std::sync::mpsc::channel();
Expand Down

0 comments on commit e8661ab

Please sign in to comment.