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): check dp when creating or excuting task for aheadRead

Browse Source 
close;#1000406278

Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2025-10-29 16:26:41 +08:00
parent dc5d876568
commit 6ec3410805
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -251,6 +251,10 @@ func (arw *AheadReadWindow) doTask(task *AheadReadTask) {
if _, ok := arw.cache.blockCache.Load(key); ok {
return
}
if task.dp == nil {
log.LogWarnf("doTask dp for %v is nil", key)
return
}
_, loaded := arw.cache.creatingBlockCacheMap.LoadOrStore(key, make(chan struct{}))
if loaded {
return
@ -454,6 +458,12 @@ func (arw *AheadReadWindow) getAheadReadTask(dp *wrapper.DataPartition, req *Ext
storageClass uint32,
) *AheadReadTask {
cacheOffset := id * int(arw.streamer.aheadReadBlockSize)
if dp == nil {
key := fmt.Sprintf("%v-%v-%v-%v", arw.streamer.inode, req.ExtentKey.PartitionId, req.ExtentKey.ExtentId, cacheOffset)
log.LogWarnf("getAheadReadTask dp for key(%v) req(%v) is nil",
key, req)
return nil
}
// tiny need to add ExtentOffset
if readDataFromTinyExtent(req.ExtentKey.ExtentId) {
cacheOffset = int(req.ExtentKey.ExtentOffset)