From 0ff224a46181e34a651d4e2c38e7411bc9b9bcb8 Mon Sep 17 00:00:00 2001 From: mxsm Date: Sat, 30 Nov 2024 20:13:45 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#1468]=F0=9F=94=A5Clean=20test=20cases?= =?UTF-8?q?=20compile=20warning=F0=9F=9A=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rocketmq-remoting/src/net/channel.rs | 5 ----- .../src/protocol/body/broker_body/register_broker_body.rs | 1 - .../src/protocol/body/cluster_acl_version_info.rs | 8 ++++---- 3 files changed, 4 insertions(+), 10 deletions(-) diff --git a/rocketmq-remoting/src/net/channel.rs b/rocketmq-remoting/src/net/channel.rs index 3e7695b5..37efc536 100644 --- a/rocketmq-remoting/src/net/channel.rs +++ b/rocketmq-remoting/src/net/channel.rs @@ -234,11 +234,6 @@ impl Channel { #[cfg(test)] mod tests { - use std::net::IpAddr; - use std::net::Ipv4Addr; - use std::net::SocketAddr; - - use super::*; #[test] fn channel_creation_with_new() { diff --git a/rocketmq-remoting/src/protocol/body/broker_body/register_broker_body.rs b/rocketmq-remoting/src/protocol/body/broker_body/register_broker_body.rs index 789bb85f..941a1189 100644 --- a/rocketmq-remoting/src/protocol/body/broker_body/register_broker_body.rs +++ b/rocketmq-remoting/src/protocol/body/broker_body/register_broker_body.rs @@ -177,7 +177,6 @@ mod tests { use cheetah_string::CheetahString; use rocketmq_common::common::config::TopicConfig; use rocketmq_common::common::mq_version::RocketMqVersion; - use rocketmq_common::utils::serde_json_utils::SerdeJsonUtils; use super::*; diff --git a/rocketmq-remoting/src/protocol/body/cluster_acl_version_info.rs b/rocketmq-remoting/src/protocol/body/cluster_acl_version_info.rs index 17fb1900..fe3b9b2f 100644 --- a/rocketmq-remoting/src/protocol/body/cluster_acl_version_info.rs +++ b/rocketmq-remoting/src/protocol/body/cluster_acl_version_info.rs @@ -65,7 +65,7 @@ mod tests { let mut all_acl_config_data_version = HashMap::new(); all_acl_config_data_version.insert(CheetahString::from("key1"), DataVersion::default()); - let info1 = ClusterAclVersionInfo { + let _info1 = ClusterAclVersionInfo { broker_name: CheetahString::from("broker1"), broker_addr: CheetahString::from("addr1"), acl_config_data_version: Some(DataVersion::default()), @@ -73,7 +73,7 @@ mod tests { cluster_name: CheetahString::from("cluster1"), }; - let info2 = ClusterAclVersionInfo { + let _info2 = ClusterAclVersionInfo { broker_name: CheetahString::from("broker1"), broker_addr: CheetahString::from("addr1"), acl_config_data_version: Some(DataVersion::default()), @@ -84,7 +84,7 @@ mod tests { #[test] fn cluster_acl_version_info_inequality() { - let info1 = ClusterAclVersionInfo { + let _info1 = ClusterAclVersionInfo { broker_name: CheetahString::from("broker1"), broker_addr: CheetahString::from("addr1"), acl_config_data_version: Some(DataVersion::default()), @@ -92,7 +92,7 @@ mod tests { cluster_name: CheetahString::from("cluster1"), }; - let info2 = ClusterAclVersionInfo { + let _info2 = ClusterAclVersionInfo { broker_name: CheetahString::from("broker2"), broker_addr: CheetahString::from("addr2"), acl_config_data_version: None,