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(data): fix gc clear data failed bug. #22957485

Browse Source 
Signed-off-by: Victor1319 <zengxuewei@oppo.com>
This commit is contained in:
Victor1319 2025-01-06 10:19:53 +08:00 committed by zhumingze1108
parent d6ad6681dd
commit 4ed781a41a
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
datanode/repl/repl_protocol.go
View File

@ -287,7 +287,7 @@ func (rp *ReplProtocol) readPkgAndPrepare() (err error) {
return
}
// log.LogDebugf("action[readPkgAndPrepare] packet(%v) op %v from remote(%v) conn(%v) ",
// request.GetUniqueLogId(), request.Opcode, rp.sourceConn.RemoteAddr().String(), rp.sourceConn)
// request.GetUniqueLogId(), request.Opcode, rp.sourceConn.RemoteAddr().String(), rp.sourceConn)
if err = request.resolveFollowersAddr(); err != nil {
err = rp.putResponse(request)

6
datanode/wrap_operator.go
View File

@ -938,7 +938,7 @@ func (s *DataNode) handleWritePacket(p *repl.Packet) {
IsSync: p.IsSyncWrite(),
IsHole: false,
IsRepair: false,
IsBackupWrite: false,
IsBackupWrite: p.GetOpcode() == proto.OpBackupWrite,
}
_, err = store.Write(param)
}); !writable {
@ -972,7 +972,7 @@ func (s *DataNode) handleWritePacket(p *repl.Packet) {
IsSync: p.IsSyncWrite(),
IsHole: false,
IsRepair: false,
IsBackupWrite: false,
IsBackupWrite: p.GetOpcode() == proto.OpBackupWrite,
}
_, err = store.Write(param)
}); !writable {
@ -1012,7 +1012,7 @@ func (s *DataNode) handleWritePacket(p *repl.Packet) {
IsSync: p.IsSyncWrite(),
IsHole: false,
IsRepair: false,
IsBackupWrite: false,
IsBackupWrite: p.GetOpcode() == proto.OpBackupWrite,
}
_, err = store.Write(param)
}); !writable {

2
proto/packet.go
View File

@ -1064,7 +1064,7 @@ func (p *Packet) IsReadOperation() bool {
return p.Opcode == OpStreamRead || p.Opcode == OpRead ||
p.Opcode == OpExtentRepairRead || p.Opcode == OpReadTinyDeleteRecord ||
p.Opcode == OpTinyExtentRepairRead || p.Opcode == OpStreamFollowerRead ||
p.Opcode == OpSnapshotExtentRepairRead
p.Opcode == OpSnapshotExtentRepairRead || p.Opcode == OpBackupRead
}
func (p *Packet) IsReadMetaPkt() bool {