0
Fork 0
mirror of https://codeberg.org/forgejo/forgejo.git synced 2024-12-29 10:54:02 -05:00
forgejo/modules/queue
Giteabot b1e68f39e7
Properly flush unique queues on startup (#23154) (#23201)
Backport #23154

There have been a number of reports of PRs being blocked whilst being
checked which have been difficult to debug. In investigating #23050 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 #23050
and others

Signed-off-by: Andrew Thornton <art27@cantab.net>
Co-authored-by: zeripath <art27@cantab.net>
Co-authored-by: techknowlogick <techknowlogick@gitea.io>
Co-authored-by: delvh <leon@kske.dev>
2023-03-06 22:35:07 +08:00
..
bytefifo.go
helper.go
manager.go
queue.go
queue_bytefifo.go
queue_channel.go Properly flush unique queues on startup (#23154) (#23201) 2023-03-06 22:35:07 +08:00
queue_channel_test.go
queue_disk.go
queue_disk_channel.go Properly flush unique queues on startup (#23154) (#23201) 2023-03-06 22:35:07 +08:00
queue_disk_channel_test.go Properly flush unique queues on startup (#23154) (#23201) 2023-03-06 22:35:07 +08:00
queue_disk_test.go
queue_redis.go
queue_test.go
queue_wrapped.go
setting.go
unique_queue.go
unique_queue_channel.go Properly flush unique queues on startup (#23154) (#23201) 2023-03-06 22:35:07 +08:00
unique_queue_channel_test.go Properly flush unique queues on startup (#23154) (#23201) 2023-03-06 22:35:07 +08:00
unique_queue_disk.go
unique_queue_disk_channel.go Properly flush unique queues on startup (#23154) (#23201) 2023-03-06 22:35:07 +08:00
unique_queue_disk_channel_test.go Properly flush unique queues on startup (#23154) (#23201) 2023-03-06 22:35:07 +08:00
unique_queue_redis.go
unique_queue_wrapped.go
workerpool.go