[ISSUE #2275]🔥Remove rocketmq-store log crate (#2276)

mxsm · Jan 16, 2025 · 1c3b29c · 1c3b29c
1 parent 4cfacc9
commit 1c3b29c
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/rocketmq-store/Cargo.toml b/rocketmq-store/Cargo.toml
@@ -41,7 +41,6 @@ serde_json.workspace = true
 lazy_static.workspace = true
 
 tempfile = "3.14.0"
-log = "0.4.25"
 
 memmap2 = "0.9.5"
 trait-variant.workspace = true

diff --git a/rocketmq-store/src/consume_queue/mapped_file_queue.rs b/rocketmq-store/src/consume_queue/mapped_file_queue.rs
@@ -23,10 +23,10 @@ use std::sync::atomic::Ordering;
 use std::sync::Arc;
 
 use cheetah_string::CheetahString;
-use log::warn;
 use parking_lot::RwLock;
 use rocketmq_common::UtilAll::offset_to_file_name;
 use tracing::info;
+use tracing::warn;
 
 use crate::log_file::mapped_file::default_mapped_file_impl::DefaultMappedFile;
 use crate::log_file::mapped_file::MappedFile;

diff --git a/rocketmq-store/src/index/index_file.rs b/rocketmq-store/src/index/index_file.rs
@@ -21,6 +21,8 @@ use bytes::Buf;
 use bytes::Bytes;
 use cheetah_string::CheetahString;
 use rocketmq_common::common::hasher::string_hasher::JavaStringHasher;
+use tracing::info;
+use tracing::warn;
 
 use crate::index::index_header::IndexHeader;
 use crate::index::index_header::INDEX_HEADER_SIZE;
@@ -123,7 +125,7 @@ impl IndexFile {
             self.index_header.update_byte_buffer();
             self.mapped_file.flush(0);
             self.mapped_file.release();
-            log::info!(
+            info!(
                 "flush index file elapsed time(ms) {}",
                 begin_time.elapsed().as_millis()
             );
@@ -210,7 +212,7 @@ impl IndexFile {
 
             true
         } else {
-            log::warn!(
+            warn!(
                 "Over index file capacity: index count = {}; index max num = {}",
                 self.index_header.get_index_count(),
                 self.index_num