You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

zeripath 3ad62127df Correctly handle select on multiple channels in Queues (#22146) (#22428) ... Backport #22146 There are a few places in FlushQueueWithContext which make an incorrect assumption about how `select` on multiple channels works. The problem is best expressed by looking at the following example: ```go package main import "fmt" func main() { closedChan := make(chan struct{}) close(closedChan) toClose := make(chan struct{}) count := 0 for { select { case <-closedChan: count++ fmt.Println(count) if count == 2 { close(toClose) } case <-toClose: return } } } ``` This PR double-checks that the contexts are closed outside of checking if there is data in the dataChan. It also rationalises the WorkerPool FlushWithContext because the previous implementation failed to handle pausing correctly. This will probably fix the underlying problem in #22145 Fix #22145 Signed-off-by: Andrew Thornton <art27@cantab.net>		2 years ago
..
bytefifo.go	…
helper.go	Add more linters to improve code readability (#19989)	2 years ago
manager.go	…
queue.go	…
queue_bytefifo.go	Add more linters to improve code readability (#19989)	2 years ago
queue_channel.go	Correctly handle select on multiple channels in Queues (#22146) (#22428)	2 years ago
queue_channel_test.go	Prevent intermittent NPE in queue tests (#19301)	3 years ago
queue_disk.go	…
queue_disk_channel.go	Add more linters to improve code readability (#19989)	2 years ago
queue_disk_channel_test.go	test: use `T.TempDir` to create temporary test directory (#21043)	2 years ago
queue_disk_test.go	test: use `T.TempDir` to create temporary test directory (#21043)	2 years ago
queue_redis.go	…
queue_test.go	…
queue_wrapped.go	Replace all instances of fmt.Errorf(%v) with fmt.Errorf(%w) (#21551)	2 years ago
setting.go	…
unique_queue.go	…
unique_queue_channel.go	Correctly handle select on multiple channels in Queues (#22146) (#22428)	2 years ago
unique_queue_channel_test.go	…
unique_queue_disk.go	Pause queues (#15928)	3 years ago
unique_queue_disk_channel.go	Add more linters to improve code readability (#19989)	2 years ago
unique_queue_redis.go	…
unique_queue_wrapped.go	…
workerpool.go	Correctly handle select on multiple channels in Queues (#22146) (#22428)	2 years ago