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): if follower read is enabled, try other hosts when triggering OpNotExistErr

Browse Source 
close:#1000078338

Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2025-04-23 14:57:14 +08:00 committed by zhumingze1108
parent 4a38fa1418
commit 42e6bd21da
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
sdk/data/stream/extent_reader.go
View File

@ -130,9 +130,10 @@ func (reader *ExtentReader) checkStreamReply(request *Packet, reply *Packet) (er
return TryOtherAddrError
}
if reply.ResultCode == proto.OpNotExistErr {
return ExtentNotFoundError
}
// if follower read is enabled, try other hosts when triggering OpNotExistErr
// if reply.ResultCode == proto.OpNotExistErr {
// return ExtentNotFoundError
// }
if reply.ResultCode != proto.OpOk {
if request.Opcode == proto.OpStreamFollowerRead && reply.ResultCode != proto.OpForbidErr {