summaryrefslogtreecommitdiff
path: root/vendor/github.com/klauspost/pgzip/gunzip.go
diff options
context:
space:
mode:
authordependabot-preview[bot] <27856297+dependabot-preview[bot]@users.noreply.github.com>2020-09-04 08:16:34 +0000
committerDaniel J Walsh <dwalsh@redhat.com>2020-09-05 06:37:36 -0400
commitb62fa769f8f5ccc982a2566b4c4af0b7096298f3 (patch)
tree848e9d60ea655c601886b2e0ff3d7889cec8372c /vendor/github.com/klauspost/pgzip/gunzip.go
parentfa487a65220951e84779f200f48780666b4b9209 (diff)
downloadpodman-b62fa769f8f5ccc982a2566b4c4af0b7096298f3.tar.gz
podman-b62fa769f8f5ccc982a2566b4c4af0b7096298f3.tar.bz2
podman-b62fa769f8f5ccc982a2566b4c4af0b7096298f3.zip
Bump github.com/containers/storage from 1.23.2 to 1.23.4
Bumps [github.com/containers/storage](https://github.com/containers/storage) from 1.23.2 to 1.23.4. - [Release notes](https://github.com/containers/storage/releases) - [Changelog](https://github.com/containers/storage/blob/master/docs/containers-storage-changes.md) - [Commits](https://github.com/containers/storage/compare/v1.23.2...v1.23.4) Signed-off-by: dependabot-preview[bot] <support@dependabot.com> Signed-off-by: Daniel J Walsh <dwalsh@redhat.com>
Diffstat (limited to 'vendor/github.com/klauspost/pgzip/gunzip.go')
-rw-r--r--vendor/github.com/klauspost/pgzip/gunzip.go11
1 files changed, 11 insertions, 0 deletions
diff --git a/vendor/github.com/klauspost/pgzip/gunzip.go b/vendor/github.com/klauspost/pgzip/gunzip.go
index 93efec714..d1ae730b2 100644
--- a/vendor/github.com/klauspost/pgzip/gunzip.go
+++ b/vendor/github.com/klauspost/pgzip/gunzip.go
@@ -331,6 +331,16 @@ func (z *Reader) killReadAhead() error {
// Wait for decompressor to be closed and return error, if any.
e, ok := <-z.closeErr
z.activeRA = false
+
+ for blk := range z.readAhead {
+ if blk.b != nil {
+ z.blockPool <- blk.b
+ }
+ }
+ if cap(z.current) > 0 {
+ z.blockPool <- z.current
+ z.current = nil
+ }
if !ok {
// Channel is closed, so if there was any error it has already been returned.
return nil
@@ -418,6 +428,7 @@ func (z *Reader) doReadAhead() {
case z.readAhead <- read{b: buf, err: err}:
case <-closeReader:
// Sent on close, we don't care about the next results
+ z.blockPool <- buf
return
}
if err != nil {