mirror of
https://github.com/pgsty/minio.git
synced 2026-07-24 06:26:17 +03:00
fix: add missing readTriggerCh close (#12593)
This commit is contained in:
@@ -117,6 +117,8 @@ func (p *parallelReader) Read(dst [][]byte) ([][]byte, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
readTriggerCh := make(chan bool, len(p.readers))
|
readTriggerCh := make(chan bool, len(p.readers))
|
||||||
|
defer close(readTriggerCh) // close the channel upon return
|
||||||
|
|
||||||
for i := 0; i < p.dataBlocks; i++ {
|
for i := 0; i < p.dataBlocks; i++ {
|
||||||
// Setup read triggers for p.dataBlocks number of reads so that it reads in parallel.
|
// Setup read triggers for p.dataBlocks number of reads so that it reads in parallel.
|
||||||
readTriggerCh <- true
|
readTriggerCh <- true
|
||||||
|
|||||||
Reference in New Issue
Block a user