worker: panic if recycle a nil worker

pingcap · Jan 18, 2019 · 1ad16a0 · 1ad16a0
1 parent c749958
commit 1ad16a0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lightning/worker/worker.go b/lightning/worker/worker.go
@@ -40,6 +40,9 @@ func (pool *RestoreWorkerPool) Apply() *RestoreWorker {
 }
 
 func (pool *RestoreWorkerPool) Recycle(worker *RestoreWorker) {
+	if worker == nil {
+		panic("invalid restore worker")
+	}
 	pool.workers <- worker
 	metric.IdleWorkersGauge.WithLabelValues(pool.name).Set(float64(len(pool.workers)))
 }