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(datanode): reset diskErrorCnt when recovering bad disk

Browse Source 
Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2024-07-03 17:20:16 +08:00 committed by AmazingChi
parent 21463372eb
commit 7a29ac6ba1
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
datanode/partition_raft.go
View File

@ -343,7 +343,7 @@ func (dp *DataPartition) StartRaftAfterRepair(isLoad bool) {
"localSize(%v)", dp.partitionID, initMaxExtentID, initPartitionSize, currLeaderPartitionSize, localSize)
if initPartitionSize > localSize {
log.LogErrorf("action[StartRaftAfterRepair] PartitionID(%v) leader size(%v) local size(%v) wait snapshot recover", dp.partitionID, initPartitionSize, localSize)
log.LogWarnf("action[StartRaftAfterRepair] PartitionID(%v) leader size(%v) local size(%v) wait snapshot recover", dp.partitionID, initPartitionSize, localSize)
continue
}

3
datanode/wrap_operator.go
View File

@ -26,7 +26,6 @@ import (
"strconv"
"strings"
"sync"
"sync/atomic"
"time"
"github.com/cubefs/cubefs/depends/tiglabs/raft"
@ -1920,7 +1919,7 @@ func (s *DataNode) handlePacketToRecoverBadDisk(p *repl.Packet) {
log.LogWarnf("action[handlePacketToRecoverBadDisk] bad dp(%v) not found on disk (%v).", dpId, request.DiskPath)
return true
}
atomic.AddUint64(&partition.diskErrCnt, 0)
partition.resetDiskErrCnt()
if err = partition.PersistMetadata(); err != nil {
log.LogWarnf("action[handlePacketToRecoverBadDisk] bad dp(%v) on disk (%v) persist failed %v.",
dpId, request.DiskPath, err)