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): remove dp 0 from disk error set when recovering disk err

Browse Source 
Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2024-07-13 18:40:05 +08:00 committed by AmazingChi
parent a2724225ec
commit dd9b9be7f5
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
datanode/wrap_operator.go
View File

@ -1927,6 +1927,11 @@ func (s *DataNode) handlePacketToRecoverBadDisk(p *repl.Packet) {
log.LogInfof("action[handlePacketToRecoverBadDisk]req(%v) recover disk %v async enter bad %v disk %p", task.RequestID, disk.Path, len(badDpList), disk)
begin := time.Now()
for _, dpId := range badDpList {
if dpId == 0 {
// triggered by io error without dp
disk.DiskErrPartitionSet.Delete(dpId)
continue
}
partition := s.space.Partition(dpId)
if partition == nil {
log.LogWarnf("action[handlePacketToRecoverBadDisk]req(%v) bad dp(%v) not found on disk (%v).", task.RequestID, dpId, request.DiskPath)

2
master/admin_task_manager.go
View File

@ -17,7 +17,6 @@ package master
import (
"encoding/json"
"fmt"
"github.com/google/uuid"
"net"
"sync"
"time"
@ -26,6 +25,7 @@ import (
"github.com/cubefs/cubefs/util"
"github.com/cubefs/cubefs/util/errors"
"github.com/cubefs/cubefs/util/log"
"github.com/google/uuid"
)
// const