gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(cli): Add logs for loacting problem. #1000158099

Browse Source 
Signed-off-by: zhumingze <zhumingze@oppo.com>
This commit is contained in:
zhumingze 2025-06-18 14:59:04 +08:00 committed by zhumingze1108
parent 9bb5598edf
commit b7cc2f2b8a
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client/fs/file.go
View File

@ -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"})
}

2
datanode/data_partition_repair.go
View File

@ -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 {

10
datanode/storage/extent_store.go
View File

@ -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