dragonflyoss
/
dragonfly
mirror of https://github.com/dragonflyoss/dragonfly.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix index map in storage_manager (#3145) 

Signed-off-by: Qi <37133148+aobt@users.noreply.github.com>
This commit is contained in:
Qi 2024-03-25 21:07:57 +08:00 committed by GitHub
parent 8b05b83cca
commit 49ac8d52bd
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
client/daemon/storage/storage_manager.go
View File

@ -625,7 +625,11 @@ func (s *storageManager) cleanIndex(taskID, peerID string) {
} }
remain = append(remain, t) remain = append(remain, t)
} }
s.indexTask2PeerTask[taskID] = remain if len(remain) > 0 {
s.indexTask2PeerTask[taskID] = remain
} else {
delete(s.indexTask2PeerTask, taskID)
}
} }
func (s *storageManager) cleanSubIndex(taskID, peerID string) { func (s *storageManager) cleanSubIndex(taskID, peerID string) {
@ -644,7 +648,11 @@ func (s *storageManager) cleanSubIndex(taskID, peerID string) {
} }
remain = append(remain, t) remain = append(remain, t)
} }
s.subIndexTask2PeerTask[taskID] = remain if len(remain) > 0 {
s.subIndexTask2PeerTask[taskID] = remain
} else {
delete(s.subIndexTask2PeerTask, taskID)
}
} }
func (s *storageManager) ValidateDigest(req *PeerTaskMetadata) error { func (s *storageManager) ValidateDigest(req *PeerTaskMetadata) error {