From 1160e54d55ee1d918490b6dd614ea820dd5ae427 Mon Sep 17 00:00:00 2001 From: Sander van Harmelen Date: Thu, 19 Dec 2024 11:42:01 +0100 Subject: [PATCH] Make the client log (most things) to debug or warn instead of info --- opcua-client/src/transport/channel.rs | 8 ++++---- opcua-client/src/transport/core.rs | 8 ++++---- opcua-client/src/transport/state.rs | 8 ++++---- 3 files changed, 12 insertions(+), 12 deletions(-) diff --git a/opcua-client/src/transport/channel.rs b/opcua-client/src/transport/channel.rs index 131b07b62..d1241d82b 100644 --- a/opcua-client/src/transport/channel.rs +++ b/opcua-client/src/transport/channel.rs @@ -2,7 +2,7 @@ use std::{str::FromStr, sync::Arc, time::Duration}; use crate::{session::SessionInfo, transport::core::TransportPollResult}; use arc_swap::{ArcSwap, ArcSwapOption}; -use log::{error, info}; +use log::{debug, error}; use opcua_core::{ comms::secure_channel::{Role, SecureChannel}, sync::RwLock, @@ -229,7 +229,7 @@ impl AsyncSecureChannel { &self, ) -> Result<(TcpTransport, tokio::sync::mpsc::Sender), StatusCode> { let endpoint_url = self.session_info.endpoint.endpoint_url.clone(); - info!("Connect"); + debug!("Connect"); let security_policy = SecurityPolicy::from_str(self.session_info.endpoint.security_policy_uri.as_ref()) .unwrap(); @@ -258,8 +258,8 @@ impl AsyncSecureChannel { let _ = secure_channel.set_remote_cert_from_byte_string( &self.session_info.endpoint.server_certificate, ); - info!("Security policy = {:?}", security_policy); - info!( + debug!("Security policy = {:?}", security_policy); + debug!( "Security mode = {:?}", self.session_info.endpoint.security_mode ); diff --git a/opcua-client/src/transport/core.rs b/opcua-client/src/transport/core.rs index f165a7eed..f6ecb77f6 100644 --- a/opcua-client/src/transport/core.rs +++ b/opcua-client/src/transport/core.rs @@ -3,7 +3,7 @@ use std::sync::Arc; use std::time::Instant; use futures::future::Either; -use log::{debug, error, info, trace}; +use log::{debug, error, trace, warn}; use opcua_core::{trace_read_lock, trace_write_lock, RequestMessage, ResponseMessage}; use parking_lot::RwLock; @@ -205,7 +205,7 @@ impl TransportState { } } MessageIsFinalType::FinalError => { - info!("Discarding chunk marked in as final error"); + warn!("Discarding chunk marked in as final error"); let message_state = self.message_states.remove(&req_id).unwrap(); let _ = message_state .callback @@ -270,8 +270,8 @@ impl TransportState { .sequence_number; for c in chunks { if c.header.sequence_header.sequence_number != expect_sequence_number { - info!( - "receive wrong chunk expect seq={},got={}", + warn!( + "receive wrong chunk expect seq={} got={}", expect_sequence_number, c.header.sequence_header.sequence_number ); continue; //may be duplicate chunk diff --git a/opcua-client/src/transport/state.rs b/opcua-client/src/transport/state.rs index c50c79e67..55564b7a9 100644 --- a/opcua-client/src/transport/state.rs +++ b/opcua-client/src/transport/state.rs @@ -3,7 +3,7 @@ use std::{ time::{Duration, Instant}, }; -use log::{debug, info, trace}; +use log::{debug, trace}; use tokio::sync::mpsc::error::SendTimeoutError; use crate::{session::process_unexpected_response, transport::OutgoingMessage}; @@ -122,9 +122,9 @@ impl SecureChannelState { ) }; - info!("Making secure channel request"); - info!("security_mode = {:?}", security_mode); - info!("security_policy = {:?}", security_policy); + debug!("Making secure channel request"); + debug!("security_mode = {:?}", security_mode); + debug!("security_policy = {:?}", security_policy); let request = OpenSecureChannelRequest { request_header: self.make_request_header(timeout),