1
0
Fork 0
mirror of https://codeberg.org/forgejo/forgejo.git synced 2024-12-16 22:42:42 +00:00
forgejo/modules/queue
zeripath 27e49cd01c
Properly flush unique queues on startup ()
There have been a number of reports of PRs being blocked whilst being
checked which have been difficult to debug. In investigating  I
have realised that whilst the Warn there is somewhat of a miscall there
was a real bug in the way that the LevelUniqueQueue was being restored
on start-up of the PersistableChannelUniqueQueue.

Next there is a conflict in the setting of the internal leveldb queue
name - This wasn't being set so it was being overridden by other unique
queues.

This PR fixes these bugs and adds a testcase.

Thanks to @brechtvl  for noticing the second issue.

Fix 
and others

---------

Signed-off-by: Andrew Thornton <art27@cantab.net>
Co-authored-by: techknowlogick <techknowlogick@gitea.io>
2023-02-28 17:55:43 -05:00
..
bytefifo.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
helper.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
manager.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
queue.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
queue_bytefifo.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
queue_channel.go Properly flush unique queues on startup () 2023-02-28 17:55:43 -05:00
queue_channel_test.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
queue_disk.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
queue_disk_channel.go Properly flush unique queues on startup () 2023-02-28 17:55:43 -05:00
queue_disk_channel_test.go Properly flush unique queues on startup () 2023-02-28 17:55:43 -05:00
queue_disk_test.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
queue_redis.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
queue_test.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
queue_wrapped.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
setting.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
unique_queue.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
unique_queue_channel.go Properly flush unique queues on startup () 2023-02-28 17:55:43 -05:00
unique_queue_channel_test.go Properly flush unique queues on startup () 2023-02-28 17:55:43 -05:00
unique_queue_disk.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
unique_queue_disk_channel.go Properly flush unique queues on startup () 2023-02-28 17:55:43 -05:00
unique_queue_disk_channel_test.go Properly flush unique queues on startup () 2023-02-28 17:55:43 -05:00
unique_queue_redis.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
unique_queue_wrapped.go Implement FSFE REUSE for golang files () 2022-11-27 18:20:29 +00:00
workerpool.go Correctly handle select on multiple channels in Queues () 2022-12-30 02:06:47 +02:00