Skip to content

Commit

Permalink
Fix build
Browse files Browse the repository at this point in the history
  • Loading branch information
@OlivierHecart
OlivierHecart committed Apr 18, 2024
1 parent e7092af commit a12d2c8
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
2 changes: 1 addition & 1 deletion examples/examples/z_sub_shm.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ use zenoh_shm::SharedMemoryBuf;
#[tokio::main]
async fn main() {
// Initiate logging
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();

let (mut config, key_expr) = parse_args();

Expand Down
22 changes: 11 additions & 11 deletions io/zenoh-transport/tests/unicast_time.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,7 @@ async fn time_lowlatency_transport(endpoint: &EndPoint) {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_tcp_only() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = format!("tcp/127.0.0.1:{}", 13000).parse().unwrap();
time_universal_transport(&endpoint).await;
}
Expand All @@ -239,7 +239,7 @@ async fn time_tcp_only() {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_tcp_only_with_lowlatency_transport() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = format!("tcp/127.0.0.1:{}", 13100).parse().unwrap();
time_lowlatency_transport(&endpoint).await;
}
Expand All @@ -248,7 +248,7 @@ async fn time_tcp_only_with_lowlatency_transport() {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_udp_only() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = format!("udp/127.0.0.1:{}", 13010).parse().unwrap();
time_universal_transport(&endpoint).await;
}
Expand All @@ -257,7 +257,7 @@ async fn time_udp_only() {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_udp_only_with_lowlatency_transport() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = format!("udp/127.0.0.1:{}", 13110).parse().unwrap();
time_lowlatency_transport(&endpoint).await;
}
Expand All @@ -266,7 +266,7 @@ async fn time_udp_only_with_lowlatency_transport() {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_ws_only() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = format!("ws/127.0.0.1:{}", 13020).parse().unwrap();
time_universal_transport(&endpoint).await;
}
Expand All @@ -275,7 +275,7 @@ async fn time_ws_only() {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_ws_only_with_lowlatency_transport() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = format!("ws/127.0.0.1:{}", 13120).parse().unwrap();
time_lowlatency_transport(&endpoint).await;
}
Expand All @@ -284,7 +284,7 @@ async fn time_ws_only_with_lowlatency_transport() {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_unixpipe_only() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = "unixpipe/time_unixpipe_only".parse().unwrap();
time_universal_transport(&endpoint).await;
}
Expand All @@ -293,7 +293,7 @@ async fn time_unixpipe_only() {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_unixpipe_only_with_lowlatency_transport() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = "unixpipe/time_unixpipe_only_with_lowlatency_transport"
.parse()
.unwrap();
Expand All @@ -304,7 +304,7 @@ async fn time_unixpipe_only_with_lowlatency_transport() {
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_unix_only() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let f1 = "zenoh-test-unix-socket-9.sock";
let _ = std::fs::remove_file(f1);
let endpoint: EndPoint = format!("unixsock-stream/{f1}").parse().unwrap();
Expand All @@ -318,7 +318,7 @@ async fn time_unix_only() {
#[ignore]
async fn time_tls_only() {
use zenoh_link::tls::config::*;
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
// NOTE: this an auto-generated pair of certificate and key.
// The target domain is localhost, so it has no real
// mapping to any existing domain. The certificate and key
Expand Down Expand Up @@ -514,7 +514,7 @@ R+IdLiXcyIkg0m9N8I17p0ljCSkbrgGMD3bbePRTfg==
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
#[ignore]
async fn time_vsock_only() {
zenoh_util::init_log_from_env();
zenoh_util::try_init_log_from_env();
let endpoint: EndPoint = "vsock/VMADDR_CID_LOCAL:17000".parse().unwrap();
time_lowlatency_transport(&endpoint).await;
}

0 comments on commit a12d2c8

Please sign in to comment.