From b7cc2f2b8a85875b0502a26ebb58c14b520d1884 Mon Sep 17 00:00:00 2001 From: zhumingze Date: Wed, 18 Jun 2025 14:59:04 +0800 Subject: [PATCH] fix(cli): Add logs for loacting problem. #1000158099 Signed-off-by: zhumingze --- client/fs/file.go | 2 +- datanode/data_partition_repair.go | 2 +- datanode/storage/extent_store.go | 10 +++++----- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/client/fs/file.go b/client/fs/file.go index fd2e1ec4a..707054d15 100644 --- a/client/fs/file.go +++ b/client/fs/file.go @@ -410,7 +410,7 @@ func (f *File) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadR if f.info.Size > uint64(req.Offset) && uint64(req.Offset+int64(req.Size)) >= f.info.Size { // at least read bytes: f.info.Size - req.Offset if size > 0 && uint64(size) < f.info.Size-uint64(req.Offset) { - log.LogErrorf("Read: error data size, ino(%v) offset(%v) filesize(%v) reqsize(%v) size(%v)\n", f.info.Inode, req.Offset, f.info.Size, req.Size, size) + log.LogWarnf("Read: error data size, ino(%v) offset(%v) filesize(%v) reqsize(%v) size(%v)\n", f.info.Inode, req.Offset, f.info.Size, req.Size, size) errMetric := exporter.NewCounter("fileReadFailed") errMetric.AddWithLabels(1, map[string]string{exporter.Vol: f.super.volname, exporter.Err: "EIO"}) } diff --git a/datanode/data_partition_repair.go b/datanode/data_partition_repair.go index 671b6ee6e..4e1a6fae5 100644 --- a/datanode/data_partition_repair.go +++ b/datanode/data_partition_repair.go @@ -666,7 +666,7 @@ func (dp *DataPartition) NormalExtentRepairRead(p repl.PacketInterface, connect }) if log.EnableDebug() { - log.LogDebugf("[NormalExtentRepairRead] reply op %v data.len %v size %v crc %v err %v", reply.GetOpMsg(), len(reply.GetData()), reply.GetSize(), crc, err) + log.LogDebugf("[NormalExtentRepairRead] reply %v crc %v err %v", reply.GetNoPrefixMsg(), crc, err) } if !shallDegrade && metrics != nil { diff --git a/datanode/storage/extent_store.go b/datanode/storage/extent_store.go index 40c348c7e..24821b40f 100644 --- a/datanode/storage/extent_store.go +++ b/datanode/storage/extent_store.go @@ -769,8 +769,8 @@ func (s *ExtentStore) Read(extentID uint64, offset, size int64, nbuf []byte, isR s.partitionID, extentID, offset, size, isRepairRead, s.extentLock) defer func() { if log.EnableDebug() { - log.LogDebugf("[Read] dp %v extent[%d] offset[%d] size[%d] isRepairRead[%v] extentLock[%v] cost %v", - s.partitionID, extentID, offset, size, isRepairRead, s.extentLock, time.Since(begin).String()) + log.LogDebugf("[Read] dp %v extent[%d] offset[%d] size[%d] isRepairRead[%v] extentLock[%v] crc[%v] err[%v] cost %v", + s.partitionID, extentID, offset, size, isRepairRead, s.extentLock, crc, err, time.Since(begin).String()) } }() @@ -790,7 +790,7 @@ func (s *ExtentStore) Read(extentID uint64, offset, size int64, nbuf []byte, isR } else { if s.extentLock { if _, ok := s.extentLockMap[extentID]; ok && !isRepairRead { - log.LogErrorf("[Read]dp %v gc_extent_lock[%d] is locked， should not be read.", s.partitionID, extentID) + log.LogErrorf("[Read]dp %v gc_extent_lock[%d] is locked, should not be read.", s.partitionID, extentID) } } } @@ -811,8 +811,8 @@ func (s *ExtentStore) Read(extentID uint64, offset, size int64, nbuf []byte, isR s.partitionID, extentID, offset, size, ei.Size, e.dataSize, isRepairRead) crc, err = e.Read(nbuf, offset, size, isRepairRead, s.DirectRead) if log.EnableDebug() { - log.LogDebugf("[Read]dp %v extent %v offset %v size %v ei.Size %v e.dataSize %v isRepairRead %v,cost %v", - s.partitionID, extentID, offset, size, ei.Size, e.dataSize, isRepairRead, time.Since(begin2).String()) + log.LogDebugf("[Read]dp %v extent %v offset %v size %v ei.Size %v e.dataSize %v isRepairRead %v crc %v err %v,cost %v", + s.partitionID, extentID, offset, size, ei.Size, e.dataSize, isRepairRead, crc, err, time.Since(begin2).String()) } return