mirror of
1
Fork 0
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 Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
helper.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
manager.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
queue.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
queue_bytefifo.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
queue_channel.go Properly flush unique queues on startup (#23154) (#23201) 2023-03-06 22:35:07 +08:00
queue_channel_test.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
queue_disk.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
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 Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
queue_redis.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
queue_test.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
queue_wrapped.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
setting.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
unique_queue.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
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 Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
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 Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
unique_queue_wrapped.go Implement FSFE REUSE for golang files (#21840) 2022-11-27 18:20:29 +00:00
workerpool.go Correctly handle select on multiple channels in Queues (#22146) 2022-12-30 02:06:47 +02:00