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(client):fix errMsg for aheadRead

Browse Source 
close:#1000367076

Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2025-09-29 19:07:16 +08:00
parent 086034cb92
commit b2498aabf3
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client/fs/super.go
View File

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

2
client/fuse.go
View File

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

2
sdk/data/stream/stream_aheadread.go
View File

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