From 001e5f6c8ff744feec93ff4836208acf1d617664 Mon Sep 17 00:00:00 2001 From: Michael Ilyin Date: Tue, 12 Mar 2024 16:59:30 +0100 Subject: [PATCH] update to new ke_tree api --- Cargo.lock | 353 +++------------------ zenoh-plugin-ros2dds/src/lib.rs | 2 +- zenoh-plugin-ros2dds/src/liveliness_mgt.rs | 100 ++---- 3 files changed, 71 insertions(+), 384 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index aeaed20..4fd000e 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -415,7 +415,7 @@ checksum = "bc00ceb34980c03614e35a3a4e218276a0a824e911d07651cd0d858a51e8c0f0" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -503,7 +503,7 @@ dependencies = [ "regex", "rustc-hash", "shlex", - "syn 2.0.33", + "syn 2.0.52", "which", ] @@ -728,7 +728,7 @@ dependencies = [ "heck", "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -1005,15 +1005,6 @@ version = "1.9.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "a26ae43d7bcc3b814de94796a5e736d4029efb0ee900c12e2d54c993ad1a1e07" -[[package]] -name = "encoding_rs" -version = "0.8.33" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "7268b386296a025e474d5140678f75d6de9493ae55a5d709eeb9dd08149945e1" -dependencies = [ - "cfg-if 1.0.0", -] - [[package]] name = "env_logger" version = "0.10.0" @@ -1229,7 +1220,7 @@ checksum = "89ca545a94061b6365f2c7355b4b32bd20df3ff95f02da9329b34ccc3bd6ee72" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -1352,31 +1343,6 @@ dependencies = [ "wasm-bindgen", ] -[[package]] -name = "h2" -version = "0.3.21" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "91fc23aa11be92976ef4729127f1a74adf36d8436f7816b185d18df956790833" -dependencies = [ - "bytes", - "fnv", - "futures-core", - "futures-sink", - "futures-util", - "http", - "indexmap 1.9.3", - "slab", - "tokio", - "tokio-util", - "tracing", -] - -[[package]] -name = "hashbrown" -version = "0.12.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "8a9ee70c43aaf417c914396645a0fa852624801b24ebb7ae78fe8272889ac888" - [[package]] name = "hashbrown" version = "0.13.2" @@ -1473,17 +1439,6 @@ dependencies = [ "itoa", ] -[[package]] -name = "http-body" -version = "0.4.5" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d5f38f16d184e36f2408a55281cd658ecbd3ca05cce6d6510a176eca393e26d1" -dependencies = [ - "bytes", - "http", - "pin-project-lite 0.2.13", -] - [[package]] name = "http-client" version = "6.5.3" @@ -1524,42 +1479,12 @@ version = "1.8.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "d897f394bad6a705d5f4104762e116a75639e470d80901eed05a860a95cb1904" -[[package]] -name = "httpdate" -version = "1.0.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "df3b46402a9d5adb4c86a0cf463f42e19994e3ee891101b1841f30a545cb49a9" - [[package]] name = "humantime" version = "2.1.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "9a3a5bfb195931eeb336b2a7b4d761daec841b97f947d34394601737a7bba5e4" -[[package]] -name = "hyper" -version = "0.14.27" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ffb1cfd654a8219eaef89881fdb3bb3b1cdc5fa75ded05d6933b2b382e395468" -dependencies = [ - "bytes", - "futures-channel", - "futures-core", - "futures-util", - "h2", - "http", - "http-body", - "httparse", - "httpdate", - "itoa", - "pin-project-lite 0.2.13", - "socket2 0.4.9", - "tokio", - "tower-service", - "tracing", - "want", -] - [[package]] name = "iana-time-zone" version = "0.1.57" @@ -1593,16 +1518,6 @@ dependencies = [ "unicode-normalization", ] -[[package]] -name = "indexmap" -version = "1.9.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "bd070e393353796e801d209ad339e89596eb4c8d430d18ede6a1cced8fafbd99" -dependencies = [ - "autocfg", - "hashbrown 0.12.3", -] - [[package]] name = "indexmap" version = "2.0.0" @@ -1648,12 +1563,6 @@ dependencies = [ "windows-sys 0.48.0", ] -[[package]] -name = "ipnet" -version = "2.8.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "28b29a3cd74f0f4598934efe3aeba42bae0eb4680554128851ebbecb02af14e6" - [[package]] name = "ipnetwork" version = "0.20.0" @@ -1719,7 +1628,6 @@ dependencies = [ "anyhow", "base64 0.21.4", "bytecount", - "clap", "fancy-regex", "fraction", "getrandom 0.2.10", @@ -1731,7 +1639,6 @@ dependencies = [ "parking_lot", "percent-encoding", "regex", - "reqwest", "serde", "serde_json", "time 0.3.28", @@ -1850,12 +1757,6 @@ version = "2.6.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "8f232d6ef707e1956a43342693d2a31e72989554d58299d7a88738cc95b0d35c" -[[package]] -name = "mime" -version = "0.3.17" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6877bb514081ee2a7ff5ef9de3281f14a4dd4bceac4c09388074a6b5df8a139a" - [[package]] name = "minimal-lexical" version = "0.2.1" @@ -2157,7 +2058,7 @@ dependencies = [ "pest_meta", "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -2178,7 +2079,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "e1d3afd2628e69da2be385eb6f2fd57c8ac7977ceeff6dc166ff1657b0e386a9" dependencies = [ "fixedbitset", - "indexmap 2.0.0", + "indexmap", ] [[package]] @@ -2198,7 +2099,7 @@ checksum = "4359fd9c9171ec6e8c62926d6faaf553a8dc3f64e1507e76da7911b4f6a04405" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -2240,20 +2141,6 @@ dependencies = [ "spki", ] -[[package]] -name = "pnet" -version = "0.34.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "130c5b738eeda2dc5796fe2671e49027e6935e817ab51b930a36ec9e6a206a64" -dependencies = [ - "ipnetwork", - "pnet_base", - "pnet_datalink", - "pnet_packet", - "pnet_sys", - "pnet_transport", -] - [[package]] name = "pnet_base" version = "0.34.0" @@ -2276,39 +2163,6 @@ dependencies = [ "winapi", ] -[[package]] -name = "pnet_macros" -version = "0.34.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "688b17499eee04a0408aca0aa5cba5fc86401d7216de8a63fdf7a4c227871804" -dependencies = [ - "proc-macro2", - "quote", - "regex", - "syn 2.0.33", -] - -[[package]] -name = "pnet_macros_support" -version = "0.34.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "eea925b72f4bd37f8eab0f221bbe4c78b63498350c983ffa9dd4bcde7e030f56" -dependencies = [ - "pnet_base", -] - -[[package]] -name = "pnet_packet" -version = "0.34.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a9a005825396b7fe7a38a8e288dbc342d5034dac80c15212436424fef8ea90ba" -dependencies = [ - "glob", - "pnet_base", - "pnet_macros", - "pnet_macros_support", -] - [[package]] name = "pnet_sys" version = "0.34.0" @@ -2319,18 +2173,6 @@ dependencies = [ "winapi", ] -[[package]] -name = "pnet_transport" -version = "0.34.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "2637e14d7de974ee2f74393afccbc8704f3e54e6eb31488715e72481d1662cc3" -dependencies = [ - "libc", - "pnet_base", - "pnet_packet", - "pnet_sys", -] - [[package]] name = "polling" version = "2.8.0" @@ -2366,12 +2208,12 @@ checksum = "5b40af805b3121feab8a3c29f04d8ad262fa8e0561883e7653e024ae4479e6de" [[package]] name = "prettyplease" -version = "0.2.15" +version = "0.2.16" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ae005bd773ab59b4725093fd7df83fd7892f7d8eafb48dbd7de6e024e4215f9d" +checksum = "a41cf62165e97c7f814d2221421dbb9afcbcdb0a88068e5ea206e19951c2cbb5" dependencies = [ "proc-macro2", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -2382,9 +2224,9 @@ checksum = "dc375e1527247fe1a97d8b7156678dfe7c1af2fc075c9a4db3690ecd2a148068" [[package]] name = "proc-macro2" -version = "1.0.67" +version = "1.0.79" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3d433d9f1a3e8c1263d9456598b16fec66f4acc9a74dacffd35c7bb09b3a1328" +checksum = "e835ff2298f5721608eb1a980ecaee1aef2c132bf95ecc026a11b7bf3c01c02e" dependencies = [ "unicode-ident", ] @@ -2439,9 +2281,9 @@ dependencies = [ [[package]] name = "quote" -version = "1.0.33" +version = "1.0.35" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5267fca4496028628a95160fc423a33e8b2e6af8a5302579e322e4b520293cae" +checksum = "291ec9ab5efd934aaf503a6466c5d5251535d108ee747472c3977cc5acc868ef" dependencies = [ "proc-macro2", ] @@ -2575,40 +2417,6 @@ version = "0.7.5" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "dbb5fb1acd8a1a18b3dd5be62d25485eb770e05afb408a9627d14d451bae12da" -[[package]] -name = "reqwest" -version = "0.11.20" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3e9ad3fe7488d7e34558a2033d45a0c90b72d97b4f80705666fea71472e2e6a1" -dependencies = [ - "base64 0.21.4", - "bytes", - "encoding_rs", - "futures-core", - "futures-util", - "h2", - "http", - "http-body", - "hyper", - "ipnet", - "js-sys", - "log", - "mime", - "once_cell", - "percent-encoding", - "pin-project-lite 0.2.13", - "serde", - "serde_json", - "serde_urlencoded", - "tokio", - "tower-service", - "url", - "wasm-bindgen", - "wasm-bindgen-futures", - "web-sys", - "winreg", -] - [[package]] name = "ring" version = "0.16.20" @@ -2942,7 +2750,7 @@ checksum = "4eca7ac642d82aa35b60049a6eccb4be6be75e599bd2e9adb5f875a737654af2" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -3005,7 +2813,7 @@ version = "0.9.25" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "1a49e178e4452f45cb61d0cd8cebc1b0fafd3e41929e996cef79aa3aca91f574" dependencies = [ - "indexmap 2.0.0", + "indexmap", "itoa", "ryu", "serde", @@ -3354,9 +3162,9 @@ dependencies = [ [[package]] name = "syn" -version = "2.0.33" +version = "2.0.52" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "9caece70c63bfba29ec2fed841a09851b14a235c60010fa4de58089b6c025668" +checksum = "b699d15b36d1f02c3e7c69f8ffef53de37aefae075d8488d4ba1a7788d574a07" dependencies = [ "proc-macro2", "quote", @@ -3389,7 +3197,7 @@ checksum = "49922ecae66cc8a249b77e68d1d0623c1b2c514f0060c27cdc68bd62a1219d35" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -3529,7 +3337,7 @@ checksum = "630bdcf245f78637c13ec01ffae6187cca34625e8c63150d424b59e55af2675e" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -3544,26 +3352,6 @@ dependencies = [ "tungstenite", ] -[[package]] -name = "tokio-util" -version = "0.7.8" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "806fe8c2c87eccc8b3267cbae29ed3ab2d0bd37fca70ab622e46aaa9375ddb7d" -dependencies = [ - "bytes", - "futures-core", - "futures-sink", - "pin-project-lite 0.2.13", - "tokio", - "tracing", -] - -[[package]] -name = "tower-service" -version = "0.3.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "b6bc1c9ce2b5135ac7f93c72918fc37feb872bdc6a5533a8b85eb4b86bfdae52" - [[package]] name = "tracing" version = "0.1.37" @@ -3585,7 +3373,7 @@ checksum = "5f4f31f56159e98206da9efd823404b79b6ef3143b4a7ab76e67b1751b25a4ab" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] @@ -3597,12 +3385,6 @@ dependencies = [ "once_cell", ] -[[package]] -name = "try-lock" -version = "0.2.4" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3528ecfd12c466c6f163363caf2d02a71161dd5e1cc6ae7b34207ea2d42d81ed" - [[package]] name = "tungstenite" version = "0.20.1" @@ -3835,15 +3617,6 @@ version = "1.1.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "9d5b2c62b4012a3e1eca5a7e077d13b3bf498c4073e33ccd58626607748ceeca" -[[package]] -name = "want" -version = "0.3.1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "bfa7760aed19e106de2c7c0b581b509f2f25d3dacaf737cb82ac61bc6d760b0e" -dependencies = [ - "try-lock", -] - [[package]] name = "wasi" version = "0.9.0+wasi-snapshot-preview1" @@ -3879,7 +3652,7 @@ dependencies = [ "once_cell", "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", "wasm-bindgen-shared", ] @@ -3913,7 +3686,7 @@ checksum = "54681b18a46765f095758388f2d0cf16eb8d4169b639ab575a8f5693af210c7b" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", "wasm-bindgen-backend", "wasm-bindgen-shared", ] @@ -4127,20 +3900,10 @@ version = "0.52.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "dff9641d1cd4be8d1a070daf9e3773c5f67e78b4d9d42263020c057706765c04" -[[package]] -name = "winreg" -version = "0.50.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "524e57b2c537c0f9b1e69f1965311ec12182b4122e45035b1508cd24d2adadb1" -dependencies = [ - "cfg-if 1.0.0", - "windows-sys 0.48.0", -] - [[package]] name = "zenoh" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-global-executor", "async-std", @@ -4153,7 +3916,6 @@ dependencies = [ "form_urlencoded", "futures", "git-version", - "hex", "lazy_static", "log", "ordered-float", @@ -4207,7 +3969,7 @@ dependencies = [ [[package]] name = "zenoh-buffers" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "zenoh-collections", ] @@ -4215,7 +3977,7 @@ dependencies = [ [[package]] name = "zenoh-codec" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "log", "serde", @@ -4227,12 +3989,12 @@ dependencies = [ [[package]] name = "zenoh-collections" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" [[package]] name = "zenoh-config" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "flume", "json5", @@ -4251,7 +4013,7 @@ dependencies = [ [[package]] name = "zenoh-core" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "lazy_static", @@ -4261,7 +4023,7 @@ dependencies = [ [[package]] name = "zenoh-crypto" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "aes 0.8.3", "hmac 0.12.1", @@ -4274,7 +4036,7 @@ dependencies = [ [[package]] name = "zenoh-ext" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "bincode", @@ -4294,7 +4056,7 @@ dependencies = [ [[package]] name = "zenoh-keyexpr" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "hashbrown 0.14.0", "keyed-set", @@ -4308,7 +4070,7 @@ dependencies = [ [[package]] name = "zenoh-link" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "async-trait", @@ -4327,15 +4089,13 @@ dependencies = [ [[package]] name = "zenoh-link-commons" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "async-trait", "flume", "log", - "lz4_flex", "serde", - "typenum", "zenoh-buffers", "zenoh-codec", "zenoh-core", @@ -4348,7 +4108,7 @@ dependencies = [ [[package]] name = "zenoh-link-quic" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-rustls", "async-std", @@ -4360,7 +4120,6 @@ dependencies = [ "rustls", "rustls-native-certs 0.7.0", "rustls-pemfile 2.0.0", - "rustls-webpki 0.102.0", "secrecy", "zenoh-config", "zenoh-core", @@ -4374,7 +4133,7 @@ dependencies = [ [[package]] name = "zenoh-link-tcp" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "async-trait", @@ -4390,7 +4149,7 @@ dependencies = [ [[package]] name = "zenoh-link-tls" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-rustls", "async-std", @@ -4415,7 +4174,7 @@ dependencies = [ [[package]] name = "zenoh-link-udp" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "async-trait", @@ -4434,7 +4193,7 @@ dependencies = [ [[package]] name = "zenoh-link-unixsock_stream" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "async-trait", @@ -4452,7 +4211,7 @@ dependencies = [ [[package]] name = "zenoh-link-ws" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "async-trait", @@ -4472,25 +4231,22 @@ dependencies = [ [[package]] name = "zenoh-macros" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "proc-macro2", "quote", - "rustc_version 0.4.0", - "syn 2.0.33", - "unzip-n", + "syn 2.0.52", "zenoh-keyexpr", ] [[package]] name = "zenoh-plugin-rest" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "anyhow", "async-std", "base64 0.21.4", - "clap", "const_format", "env_logger", "flume", @@ -4543,7 +4299,7 @@ dependencies = [ [[package]] name = "zenoh-plugin-trait" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "const_format", "libloading", @@ -4559,14 +4315,12 @@ dependencies = [ [[package]] name = "zenoh-protocol" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "const_format", - "hex", "rand 0.8.5", "serde", "uhlc", - "uuid", "zenoh-buffers", "zenoh-keyexpr", "zenoh-result", @@ -4575,7 +4329,7 @@ dependencies = [ [[package]] name = "zenoh-result" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "anyhow", ] @@ -4583,11 +4337,10 @@ dependencies = [ [[package]] name = "zenoh-sync" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "event-listener 4.0.0", - "flume", "futures", "tokio", "zenoh-buffers", @@ -4598,7 +4351,7 @@ dependencies = [ [[package]] name = "zenoh-transport" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-executor", "async-global-executor", @@ -4629,27 +4382,21 @@ dependencies = [ [[package]] name = "zenoh-util" version = "0.11.0-dev" -source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#42f9384c93658b6d0001667ad9784aead285e553" +source = "git+https://github.com/eclipse-zenoh/zenoh.git?branch=main#4537dc26553397a4865953e46cacd6ed2ba5cfb6" dependencies = [ "async-std", "async-trait", - "clap", - "const_format", "flume", - "futures", - "hex", "home", "humantime", "lazy_static", "libc", "libloading", "log", - "pnet", "pnet_datalink", "shellexpand", "winapi", "zenoh-core", - "zenoh-protocol", "zenoh-result", ] @@ -4670,7 +4417,7 @@ checksum = "9ce1b18ccd8e73a9321186f97e46f9f04b778851177567b1975109d26a08d2a6" dependencies = [ "proc-macro2", "quote", - "syn 2.0.33", + "syn 2.0.52", ] [[package]] diff --git a/zenoh-plugin-ros2dds/src/lib.rs b/zenoh-plugin-ros2dds/src/lib.rs index 20ae2d3..a4a1907 100644 --- a/zenoh-plugin-ros2dds/src/lib.rs +++ b/zenoh-plugin-ros2dds/src/lib.rs @@ -368,7 +368,7 @@ impl<'a> ROS2PluginRuntime<'a> { Ok(evt) => { let ke = evt.key_expr.as_keyexpr(); if let Ok(parsed) = ke_liveliness_all::parse(ke) { - let plugin_id = parsed.plugin_id().unwrap(); + let plugin_id = parsed.plugin_id(); if plugin_id == self.plugin_id.as_ref() { // ignore own announcements continue; diff --git a/zenoh-plugin-ros2dds/src/liveliness_mgt.rs b/zenoh-plugin-ros2dds/src/liveliness_mgt.rs index 053145e..b3f3b80 100644 --- a/zenoh-plugin-ros2dds/src/liveliness_mgt.rs +++ b/zenoh-plugin-ros2dds/src/liveliness_mgt.rs @@ -51,22 +51,10 @@ pub(crate) fn parse_ke_liveliness_pub( ) -> Result<(OwnedKeyExpr, OwnedKeyExpr, String, bool, Qos), String> { let parsed = ke_liveliness_pub::parse(ke) .map_err(|e| format!("failed to parse liveliness keyexpr {ke}: {e}"))?; - let plugin_id = parsed - .plugin_id() - .map(ToOwned::to_owned) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no plugin_id"))?; - let zenoh_key_expr = parsed - .ke() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no ke"))?; - let ros2_type = parsed - .typ() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no typ"))?; - let (keyless, qos) = parsed - .qos_ke() - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no typ")) - .and_then(key_expr_to_qos) + let plugin_id = parsed.plugin_id().to_owned(); + let zenoh_key_expr = unescape_slashes(parsed.ke()); + let ros2_type = unescape_slashes(parsed.typ()); + let (keyless, qos) = key_expr_to_qos(parsed.qos_ke()) .map_err(|e| format!("failed to parse liveliness keyexpr {ke}: {e}"))?; Ok(( plugin_id, @@ -96,22 +84,10 @@ pub(crate) fn parse_ke_liveliness_sub( ) -> Result<(OwnedKeyExpr, OwnedKeyExpr, String, bool, Qos), String> { let parsed = ke_liveliness_sub::parse(ke) .map_err(|e| format!("failed to parse liveliness keyexpr {ke}: {e}"))?; - let plugin_id = parsed - .plugin_id() - .map(ToOwned::to_owned) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no plugin_id"))?; - let zenoh_key_expr = parsed - .ke() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no ke"))?; - let ros2_type = parsed - .typ() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no typ"))?; - let (keyless, qos) = parsed - .qos_ke() - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no typ")) - .and_then(key_expr_to_qos) + let plugin_id = parsed.plugin_id().to_owned(); + let zenoh_key_expr = unescape_slashes(parsed.ke()); + let ros2_type = unescape_slashes(parsed.typ()); + let (keyless, qos) = key_expr_to_qos(parsed.qos_ke()) .map_err(|e| format!("failed to parse liveliness keyexpr {ke}: {e}"))?; Ok(( plugin_id, @@ -138,18 +114,9 @@ pub(crate) fn parse_ke_liveliness_service_srv( ) -> Result<(OwnedKeyExpr, OwnedKeyExpr, String), String> { let parsed = ke_liveliness_service_srv::parse(ke) .map_err(|e| format!("failed to parse liveliness keyexpr {ke}: {e}"))?; - let plugin_id = parsed - .plugin_id() - .map(ToOwned::to_owned) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no plugin_id"))?; - let zenoh_key_expr = parsed - .ke() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no ke"))?; - let ros2_type = parsed - .typ() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no typ"))?; + let plugin_id = parsed.plugin_id().to_owned(); + let zenoh_key_expr = unescape_slashes(parsed.ke()); + let ros2_type = unescape_slashes(parsed.typ()); Ok((plugin_id, zenoh_key_expr, ros2_type.to_string())) } @@ -169,18 +136,9 @@ pub(crate) fn parse_ke_liveliness_service_cli( ) -> Result<(OwnedKeyExpr, OwnedKeyExpr, String), String> { let parsed = ke_liveliness_service_cli::parse(ke) .map_err(|e| format!("failed to parse liveliness keyexpr {ke}: {e}"))?; - let plugin_id = parsed - .plugin_id() - .map(ToOwned::to_owned) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no plugin_id"))?; - let zenoh_key_expr = parsed - .ke() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no ke"))?; - let ros2_type = parsed - .typ() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no typ"))?; + let plugin_id = parsed.plugin_id().to_owned(); + let zenoh_key_expr = unescape_slashes(parsed.ke()); + let ros2_type = unescape_slashes(parsed.typ()); Ok((plugin_id, zenoh_key_expr, ros2_type.to_string())) } @@ -200,18 +158,9 @@ pub(crate) fn parse_ke_liveliness_action_srv( ) -> Result<(OwnedKeyExpr, OwnedKeyExpr, String), String> { let parsed = ke_liveliness_action_srv::parse(ke) .map_err(|e| format!("failed to parse liveliness keyexpr {ke}: {e}"))?; - let plugin_id = parsed - .plugin_id() - .map(ToOwned::to_owned) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no plugin_id"))?; - let zenoh_key_expr = parsed - .ke() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no ke"))?; - let ros2_type = parsed - .typ() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no typ"))?; + let plugin_id = parsed.plugin_id().to_owned(); + let zenoh_key_expr = unescape_slashes(parsed.ke()); + let ros2_type = unescape_slashes(parsed.typ()); Ok((plugin_id, zenoh_key_expr, ros2_type.to_string())) } @@ -231,18 +180,9 @@ pub(crate) fn parse_ke_liveliness_action_cli( ) -> Result<(OwnedKeyExpr, OwnedKeyExpr, String), String> { let parsed = ke_liveliness_action_cli::parse(ke) .map_err(|e| format!("failed to parse liveliness keyexpr {ke}: {e}"))?; - let plugin_id = parsed - .plugin_id() - .map(ToOwned::to_owned) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no plugin_id"))?; - let zenoh_key_expr = parsed - .ke() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no ke"))?; - let ros2_type = parsed - .typ() - .map(unescape_slashes) - .ok_or_else(|| format!("failed to parse liveliness keyexpr {ke}: no typ"))?; + let plugin_id = parsed.plugin_id().to_owned(); + let zenoh_key_expr = unescape_slashes(parsed.ke()); + let ros2_type = unescape_slashes(parsed.typ()); Ok((plugin_id, zenoh_key_expr, ros2_type.to_string())) }