zeripath 38fc6c75f3 Restart zero worker if there is still work to do (#18658) (#18672) ... * Restart zero worker if there is still work to do (#18658) Backport #18658 It is possible for the zero worker to timeout before all the work is finished. This may mean that work may take a long time to complete because a worker will only be induced on repushing. Also ensure that requested count is reset after pulls and push mirror sync requests and add some more trace logging to the queue push. Fix #18607 Signed-off-by: Andrew Thornton <art27@cantab.net> * Update modules/queue/workerpool.go		2022-02-08 23:28:21 +02:00
..
bytefifo.go	Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc (#15693)	2021-05-15 16:22:26 +02:00
helper.go	Add an abstract json layout to make it's easier to change json library (#16528)	2021-07-24 18:03:58 +02:00
manager.go	Only attempt to flush queue if the underlying worker pool is not finished (#18593) (#18620)	2022-02-06 14:55:44 +08:00
queue_bytefifo.go	Add an abstract json layout to make it's easier to change json library (#16528)	2021-07-24 18:03:58 +02:00
queue_channel_test.go	Fixed assert statements. (#16089)	2021-06-07 07:27:09 +02:00
queue_channel.go	Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc (#15693)	2021-05-15 16:22:26 +02:00
queue_disk_channel_test.go	Prevent deadlock in TestPersistableChannelQueue (#17717)	2021-11-19 01:13:25 +00:00
queue_disk_channel.go	Only attempt to flush queue if the underlying worker pool is not finished (#18593) (#18620)	2022-02-06 14:55:44 +08:00
queue_disk_test.go	A better go code formatter, and now make fmt can run in Windows (#17684)	2021-11-17 20:34:35 +08:00
queue_disk.go	Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc (#15693)	2021-05-15 16:22:26 +02:00
queue_redis.go	Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc (#15693)	2021-05-15 16:22:26 +02:00
queue_test.go	Add an abstract json layout to make it's easier to change json library (#16528)	2021-07-24 18:03:58 +02:00
queue_wrapped.go	Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc (#15693)	2021-05-15 16:22:26 +02:00
queue.go	Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc (#15693)	2021-05-15 16:22:26 +02:00
setting.go	Use immediate queues in integration tests and ensure that immediate (#16927)	2021-09-03 11:20:57 +01:00
unique_queue_channel.go	Make the Mirror Queue a queue (#17326)	2021-10-17 12:43:25 +01:00
unique_queue_disk_channel.go	Fix panic (#16072)	2021-06-05 15:23:22 +01:00
unique_queue_disk.go	Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc (#15693)	2021-05-15 16:22:26 +02:00
unique_queue_redis.go	Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc (#15693)	2021-05-15 16:22:26 +02:00
unique_queue_wrapped.go	Add Unique Queue infrastructure and move TestPullRequests to this (#9856)	2020-02-02 23:19:58 +00:00
unique_queue.go	Add Unique Queue infrastructure and move TestPullRequests to this (#9856)	2020-02-02 23:19:58 +00:00
workerpool.go	Restart zero worker if there is still work to do (#18658) (#18672)	2022-02-08 23:28:21 +02:00