]> source.dussan.org Git - gitea.git/commitdiff
Remove unnecessary goroutine (#16080)
authorLunny Xiao <xiaolunwen@gmail.com>
Wed, 9 Jun 2021 19:52:55 +0000 (03:52 +0800)
committerGitHub <noreply@github.com>
Wed, 9 Jun 2021 19:52:55 +0000 (15:52 -0400)
Co-authored-by: techknowlogick <techknowlogick@gitea.io>
services/pull/check.go

index 3ec76de5e8748a1c39ae26ead71ff68f6a23fe17..9db1654cfbc055d18aa4e15c89878bc41fd72f28 100644 (file)
@@ -28,21 +28,19 @@ var prQueue queue.UniqueQueue
 
 // AddToTaskQueue adds itself to pull request test task queue.
 func AddToTaskQueue(pr *models.PullRequest) {
-       go func() {
-               err := prQueue.PushFunc(strconv.FormatInt(pr.ID, 10), func() error {
-                       pr.Status = models.PullRequestStatusChecking
-                       err := pr.UpdateColsIfNotMerged("status")
-                       if err != nil {
-                               log.Error("AddToTaskQueue.UpdateCols[%d].(add to queue): %v", pr.ID, err)
-                       } else {
-                               log.Trace("Adding PR ID: %d to the test pull requests queue", pr.ID)
-                       }
-                       return err
-               })
-               if err != nil && err != queue.ErrAlreadyInQueue {
-                       log.Error("Error adding prID %d to the test pull requests queue: %v", pr.ID, err)
+       err := prQueue.PushFunc(strconv.FormatInt(pr.ID, 10), func() error {
+               pr.Status = models.PullRequestStatusChecking
+               err := pr.UpdateColsIfNotMerged("status")
+               if err != nil {
+                       log.Error("AddToTaskQueue.UpdateCols[%d].(add to queue): %v", pr.ID, err)
+               } else {
+                       log.Trace("Adding PR ID: %d to the test pull requests queue", pr.ID)
                }
-       }()
+               return err
+       })
+       if err != nil && err != queue.ErrAlreadyInQueue {
+               log.Error("Error adding prID %d to the test pull requests queue: %v", pr.ID, err)
+       }
 }
 
 // checkAndUpdateStatus checks if pull request is possible to leaving checking status,