Make the client log (most things) to debug or warn instead of info

FreeOpcUa · Dec 19, 2024 · 1160e54 · 1160e54
1 parent 910f340
commit 1160e54
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 12 deletions.
diff --git 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<OutgoingMessage>), 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
@@ -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
@@ -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),