fix: back source weight (#762)

* fix: back source weight Signed-off-by: Gaius <[email protected]>
dragonflyoss · Oct 27, 2021 · aaf769e · aaf769e
1 parent 6db54d8
commit aaf769e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/scheduler/supervisor/task.go b/scheduler/supervisor/task.go
@@ -311,6 +311,10 @@ func (task *Task) AddBackToSourcePeer(peerID string) {
 		return
 	}
 
+	if task.BackToSourceWeight.Load() <= 0 {
+		return
+	}
+
 	task.lock.Lock()
 	defer task.lock.Unlock()