github-forks
/
gitea
mirror of https://github.com/go-gitea/gitea.git
1
0
Fork 0
Code Projects Releases Activity
gitea/modules/queue
History
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>
..
bytefifo.go Implement FSFE REUSE for golang files ()
helper.go Implement FSFE REUSE for golang files ()
manager.go Implement FSFE REUSE for golang files ()
queue.go Implement FSFE REUSE for golang files ()
queue_bytefifo.go Implement FSFE REUSE for golang files ()
queue_channel.go Properly flush unique queues on startup ()
queue_channel_test.go Implement FSFE REUSE for golang files ()
queue_disk.go Implement FSFE REUSE for golang files ()
queue_disk_channel.go Properly flush unique queues on startup ()
queue_disk_channel_test.go Properly flush unique queues on startup ()
queue_disk_test.go Implement FSFE REUSE for golang files ()
queue_redis.go Implement FSFE REUSE for golang files ()
queue_test.go Implement FSFE REUSE for golang files ()
queue_wrapped.go Implement FSFE REUSE for golang files ()
setting.go Implement FSFE REUSE for golang files ()
unique_queue.go Implement FSFE REUSE for golang files ()
unique_queue_channel.go Properly flush unique queues on startup ()
unique_queue_channel_test.go Properly flush unique queues on startup ()
unique_queue_disk.go Implement FSFE REUSE for golang files ()
unique_queue_disk_channel.go Properly flush unique queues on startup ()
unique_queue_disk_channel_test.go Properly flush unique queues on startup ()
unique_queue_redis.go Implement FSFE REUSE for golang files ()
unique_queue_wrapped.go Implement FSFE REUSE for golang files ()
workerpool.go Correctly handle select on multiple channels in Queues ()