From b2498aabf3115e77dbbcad6768f60898aab19fea Mon Sep 17 00:00:00 2001 From: chihe Date: Mon, 29 Sep 2025 19:07:16 +0800 Subject: [PATCH] fix(client):fix errMsg for aheadRead close:#1000367076 Signed-off-by: chihe --- client/fs/super.go | 2 +- client/fuse.go | 2 +- sdk/data/stream/stream_aheadread.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/client/fs/super.go b/client/fs/super.go index c08fb0e49..c792fdc1c 100644 --- a/client/fs/super.go +++ b/client/fs/super.go @@ -251,7 +251,7 @@ func NewSuper(opt *proto.MountOptions) (s *Super, err error) { EnableAsyncFlush: opt.EnableAsyncFlush, } - log.LogWarnf("ahead info enable %+v, totalMem %+v, timeout %+v, winCnt %+v", opt.AheadReadEnable, opt.AheadReadTotalMem, opt.AheadReadBlockTimeOut, opt.AheadReadWindowCnt) + log.LogInfof("ahead info enable %+v, totalMem %+v, timeout %+v, winCnt %+v", opt.AheadReadEnable, opt.AheadReadTotalMem, opt.AheadReadBlockTimeOut, opt.AheadReadWindowCnt) s.ec, err = stream.NewExtentClient(extentConfig) if err != nil { diff --git a/client/fuse.go b/client/fuse.go index 7484dbf9b..fb2af4938 100755 --- a/client/fuse.go +++ b/client/fuse.go @@ -1023,7 +1023,7 @@ func parseMountOption(cfg *config.Config) (*proto.MountOptions, error) { available = int64((total - used) / 3) if available < opt.AheadReadTotalMem { opt.AheadReadTotalMem = available - syslog.Printf("available ahead read mem: %v\n", available) + fmt.Printf("available ahead read mem: %v\n", available) } } if opt.MountPoint == "" || opt.Volname == "" || opt.Owner == "" || opt.Master == "" { diff --git a/sdk/data/stream/stream_aheadread.go b/sdk/data/stream/stream_aheadread.go index a8de04a12..744ebc358 100644 --- a/sdk/data/stream/stream_aheadread.go +++ b/sdk/data/stream/stream_aheadread.go @@ -281,7 +281,7 @@ func (arw *AheadReadWindow) doTask(task *AheadReadTask) { return e, false } if rp.ResultCode != proto.OpOk { - err = fmt.Errorf("result code[%v],msg[%v]", rp.ResultCode, string(rp.Data)) + err = fmt.Errorf("result code[%v],msg[%v]", rp.ResultCode, string(rp.Data[:rp.Size])) return err, false } // update timeStamp to prevent from deleted by timeout