This is an automated email from the ASF dual-hosted git repository.
twice pushed a commit to branch unstable
in repository https://gitbox.apache.org/repos/asf/kvrocks.git
The following commit(s) were added to refs/heads/unstable by this push:
new f420bd071 chore(log): replace logging calls in `types/*` (#2892)
f420bd071 is described below
commit f420bd0711c215e53ea818b2902337a323e9281a
Author: RX Xiao <[email protected]>
AuthorDate: Tue Apr 22 09:08:47 2025 +0800
chore(log): replace logging calls in `types/*` (#2892)
Signed-off-by: DeEMO <[email protected]>
Co-authored-by: DeEMO <[email protected]>
Co-authored-by: Twice <[email protected]>
---
src/types/redis_tdigest.cc | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/src/types/redis_tdigest.cc b/src/types/redis_tdigest.cc
index 90d8159e2..a5a278b18 100644
--- a/src/types/redis_tdigest.cc
+++ b/src/types/redis_tdigest.cc
@@ -354,16 +354,16 @@ rocksdb::Status TDigest::decodeCentroidFromKeyValue(const
rocksdb::Slice& key, c
auto subkey = ikey.GetSubKey();
auto type_flg = static_cast<uint8_t>(SegmentType::kGuardFlag);
if (!GetFixed8(&subkey, &type_flg)) {
- LOG(ERROR) << "corrupted tdigest centroid key, extract type failed";
+ error("corrupted tdigest centroid key, extract type failed");
return rocksdb::Status::Corruption("corrupted tdigest centroid key");
}
if (static_cast<SegmentType>(type_flg) != SegmentType::kCentroids) {
- LOG(ERROR) << "corrupted tdigest centroid key type: " << type_flg << ",
expect to be "
- << static_cast<uint8_t>(SegmentType::kCentroids);
+ error("corrupted tdigest centroid key type: {}, expect to be {}", type_flg,
+ static_cast<uint8_t>(SegmentType::kCentroids));
return rocksdb::Status::Corruption("corrupted tdigest centroid key type");
}
if (!GetDouble(&subkey, ¢roid->mean)) {
- LOG(ERROR) << "corrupted tdigest centroid key, extract mean failed";
+ error("corrupted tdigest centroid key, extract mean failed");
return rocksdb::Status::Corruption("corrupted tdigest centroid key");
}
@@ -372,7 +372,7 @@ rocksdb::Status TDigest::decodeCentroidFromKeyValue(const
rocksdb::Slice& key, c
if (rocksdb::Slice value_slice = value; // GetDouble needs a mutable
pointer of slice
!GetDouble(&value_slice, ¢roid->weight)) {
- LOG(ERROR) << "corrupted tdigest centroid value, extract weight failed";
+ error("corrupted tdigest centroid value, extract weight failed");
return rocksdb::Status::Corruption("corrupted tdigest centroid value");
}
return rocksdb::Status::OK();
@@ -419,7 +419,7 @@ rocksdb::Status
TDigest::dumpCentroidsAndBuffer(engine::Context& ctx, const std:
for (uint64_t i = 0; i < metadata.unmerged_nodes; ++i) {
double tmp_value = std::numeric_limits<double>::quiet_NaN();
if (!GetDouble(&buffer_slice, &tmp_value)) {
- LOG(ERROR) << "metadata has " << metadata.unmerged_nodes << "
records, but get " << i << " failed";
+ error("metadata has {} records, but get {} failed",
metadata.unmerged_nodes, i);
return rocksdb::Status::Corruption("corrupted tdigest buffer value");
}
buffer->emplace_back(tmp_value);
@@ -460,7 +460,7 @@ rocksdb::Status
TDigest::dumpCentroidsAndBuffer(engine::Context& ctx, const std:
}
if (centroids->size() != metadata.merged_nodes) {
- LOG(ERROR) << "metadata has " << metadata.merged_nodes << " merged nodes,
but got " << centroids->size();
+ error("metadata has {} merged nodes, but got {}", metadata.merged_nodes,
centroids->size());
return rocksdb::Status::Corruption("centroids count mismatch with
metadata");
}
return rocksdb::Status::OK();