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 ut fail

Browse Source 
close: #1000412030

Signed-off-by: clinx <chenlin1@oppo.com>
This commit is contained in:
clinx 2025-11-03 16:41:44 +08:00 committed by 曾雪伟
parent 0e84a32213
commit dc49d7a695
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
sdk/data/stream/stream_aheadread_test.go
View File

@ -1,7 +1,6 @@
package stream
import (
"fmt"
"sync/atomic"
"testing"
"time"
@ -47,7 +46,7 @@ func newTestStreamerWithAheadRead(t *testing.T, partitionID uint64) (*Streamer,
}
func putCacheBlock(arc *AheadReadCache, inode, partitionID, extentID uint64, cacheOffset int, availSize int, fill byte) string {
key := fmt.Sprintf("%v-%v-%v-%v", inode, partitionID, extentID, cacheOffset)
key := createAheadBlockKey(inode, partitionID, extentID, 0, cacheOffset)
bv := &AheadReadBlock{}
bv.inode = inode
bv.partitionId = partitionID