fix: rebuild judge pool

5 years ago · 5e7bfed6af
parent 5931481c03
commit 5e7bfed6af
1 changed files with 2 additions and 1 deletions
--- a/src/modules/transfer/cron/pool.go
+++ b/src/modules/transfer/cron/pool.go
@ -12,7 +12,8 @@ func RebuildJudgePool() {
 		<-t1.C
 		judges := backend.GetJudges()
 		if len(judges) == 0 {
-			return
+			//防止心跳服务故障导致judge不可用，如果judges个数为0，先不更新judge连接池
+			continue
 		}

 		backend.JudgeConnPools.Update(judges)