1
0
Fork 0
forked from NYANDEV/forgejo
forgejo/modules/queue
zeripath 382101ecc7
In disk_channel queues synchronously push to disk on shutdown () ()
Partial Backport of 

Instead of using an asynchronous goroutine to push to disk on shutdown
just close the datachan and immediately push to the disk.

Prevents messages of incompletely flushed queues.

Signed-off-by: Andrew Thornton <art27@cantab.net>

Co-authored-by: Lunny Xiao <xiaolunwen@gmail.com>
2022-02-22 20:08:35 +08:00
..
bytefifo.go Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc () 2021-05-15 16:22:26 +02:00
helper.go Add an abstract json layout to make it's easier to change json library () 2021-07-24 18:03:58 +02:00
manager.go Only attempt to flush queue if the underlying worker pool is not finished () () 2022-02-06 14:55:44 +08:00
queue.go Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc () 2021-05-15 16:22:26 +02:00
queue_bytefifo.go In disk_channel queues synchronously push to disk on shutdown () () 2022-02-22 20:08:35 +08:00
queue_channel.go Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc () 2021-05-15 16:22:26 +02:00
queue_channel_test.go Fixed assert statements. () 2021-06-07 07:27:09 +02:00
queue_disk.go Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc () 2021-05-15 16:22:26 +02:00
queue_disk_channel.go In disk_channel queues synchronously push to disk on shutdown () () 2022-02-22 20:08:35 +08:00
queue_disk_channel_test.go In disk_channel queues synchronously push to disk on shutdown () () 2022-02-22 20:08:35 +08:00
queue_disk_test.go A better go code formatter, and now make fmt can run in Windows () 2021-11-17 20:34:35 +08:00
queue_redis.go Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc () 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 () 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 () 2021-05-15 16:22:26 +02:00
setting.go Use immediate queues in integration tests and ensure that immediate () 2021-09-03 11:20:57 +01:00
unique_queue.go Add Unique Queue infrastructure and move TestPullRequests to this () 2020-02-02 23:19:58 +00:00
unique_queue_channel.go Make the Mirror Queue a queue () 2021-10-17 12:43:25 +01:00
unique_queue_disk.go Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc () 2021-05-15 16:22:26 +02:00
unique_queue_disk_channel.go In disk_channel queues synchronously push to disk on shutdown () () 2022-02-22 20:08:35 +08:00
unique_queue_redis.go Multiple Queue improvements: LevelDB Wait on empty, shutdown empty shadow level queue, reduce goroutines etc () 2021-05-15 16:22:26 +02:00
unique_queue_wrapped.go Add Unique Queue infrastructure and move TestPullRequests to this () 2020-02-02 23:19:58 +00:00
workerpool.go Restart zero worker if there is still work to do () () 2022-02-08 23:28:21 +02:00