Nulo/forgejo
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity
forgejo/modules/queue
History
Giteabot 52f52f60f1
Fix queue worker incorrectly stopped when there are still more items in the queue (#29532) (#29546) 
Backport #29532

Without `case <-t.C`, the workers would stop incorrectly, the test won't
pass. For the worse case, there might be only one running worker
processing the queue items for long time because other workers are
stopped. The root cause is related to the logic of doDispatchBatchToWorker.
It isn't a serious problem at the moment, so keep it as-is.

(cherry picked from commit 86cd94cba6d63c84528f6f8d52b1ec22b44ac2f8)
2024-03-10 18:45:59 +07:00
..
lqinternal Help to recover from corrupted levelqueue (#24912) 2023-05-29 10:52:32 +08:00
backoff.go Rewrite queue (#24505) 2023-05-08 19:49:59 +08:00
base.go Rewrite queue (#24505) 2023-05-08 19:49:59 +08:00
base_channel.go Improve queue & process & stacktrace (#24636) 2023-05-11 07:45:47 +00:00
base_channel_test.go Rewrite queue (#24505) 2023-05-08 19:49:59 +08:00
base_dummy.go Rewrite queue (#24505) 2023-05-08 19:49:59 +08:00
base_levelqueue.go Help to recover from corrupted levelqueue (#24912) 2023-05-29 10:52:32 +08:00
base_levelqueue_common.go Help to recover from corrupted levelqueue (#24912) 2023-05-29 10:52:32 +08:00
base_levelqueue_test.go Help to recover from corrupted levelqueue (#24912) 2023-05-29 10:52:32 +08:00
base_levelqueue_unique.go Help to recover from corrupted levelqueue (#24912) 2023-05-29 10:52:32 +08:00
base_redis.go Improve queue & process & stacktrace (#24636) 2023-05-11 07:45:47 +00:00
base_redis_test.go [CI] disable redis test, no redis server yet in CI 2023-11-13 11:52:15 +01:00
base_test.go Rewrite queue (#24505) 2023-05-08 19:49:59 +08:00
config.go Rewrite queue (#24505) 2023-05-08 19:49:59 +08:00
manager.go Improve queue and logger context (#24924) 2023-05-26 07:31:55 +00:00
manager_test.go Increase queue length (#27555) (#27562) 2023-10-10 20:22:26 +08:00
queue.go Expanding documentation in queue.go (#26889) 2023-09-08 05:22:43 +00:00
testhelper.go Rewrite queue (#24505) 2023-05-08 19:49:59 +08:00
workergroup.go Fix queue worker incorrectly stopped when there are still more items in the queue (#29532) (#29546) 2024-03-10 18:45:59 +07:00
workerqueue.go Fix queue worker incorrectly stopped when there are still more items in the queue (#29532) (#29546) 2024-03-10 18:45:59 +07:00
workerqueue_test.go Fix queue worker incorrectly stopped when there are still more items in the queue (#29532) (#29546) 2024-03-10 18:45:59 +07:00