chore: Fix missing unlock in processPending function

yangbobo2021 · yangbobo2021 · commit f72f149e1baa · 2024-05-16T12:59:07.000+08:00
diff --git a/server/sched.go b/server/sched.go
@@ -119,7 +119,7 @@ func (s *Scheduler) processPending(ctx context.Context) {
 				for _, runnerList := range s.loaded {
 					loadedCount += len(runnerList)
 				}
-				s.loadedMu.Unlock()
+				
 				var runner *runnerRef = nil
 				if len(runners) > 0 {
 					var minRef = runners[0].refCount
@@ -130,6 +130,8 @@ func (s *Scheduler) processPending(ctx context.Context) {
 						}
 					}
 				}
+				s.loadedMu.Unlock()
+				
 				if runner != nil {
 					if runner.needsReload(ctx, pending) {
 						runnerToExpire = runner

Original file line number	Diff line number	Diff line change
`@@ -119,7 +119,7 @@ func (s *Scheduler) processPending(ctx context.Context) {`
`119`	`119`	`for _, runnerList := range s.loaded {`
`120`	`120`	`loadedCount += len(runnerList)`
`121`	`121`	`}`
`122`		`- s.loadedMu.Unlock()`
	`122`	`+`
`123`	`123`	`var runner *runnerRef = nil`
`124`	`124`	`if len(runners) > 0 {`
`125`	`125`	`var minRef = runners[0].refCount`
`@@ -130,6 +130,8 @@ func (s *Scheduler) processPending(ctx context.Context) {`
`130`	`130`	`}`
`131`	`131`	`}`
`132`	`132`	`}`
	`133`	`+ s.loadedMu.Unlock()`
	`134`	`+`
`133`	`135`	`if runner != nil {`
`134`	`136`	`if runner.needsReload(ctx, pending) {`
`135`	`137`	`runnerToExpire = runner`