diff options
author | Janoš Guljaš <janos@users.noreply.github.com> | 2018-08-09 22:15:07 +0800 |
---|---|---|
committer | Balint Gabor <balint.g@gmail.com> | 2018-08-09 22:15:07 +0800 |
commit | 3bcb501c8fefeec1bc8aac26686460cae86f2ccb (patch) | |
tree | 51d3251a1d0042d042981d334a996939ebe7ceb0 | |
parent | d3e4c2dcb00eb61c32dd3a9b94a317727c2449a7 (diff) | |
download | go-tangerine-3bcb501c8fefeec1bc8aac26686460cae86f2ccb.tar.gz go-tangerine-3bcb501c8fefeec1bc8aac26686460cae86f2ccb.tar.zst go-tangerine-3bcb501c8fefeec1bc8aac26686460cae86f2ccb.zip |
swarm/api: close tar writer in GetDirectoryTar to flush and clean (#17339)
-rw-r--r-- | swarm/api/api.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/swarm/api/api.go b/swarm/api/api.go index ad4bd7dcb..b418c45e1 100644 --- a/swarm/api/api.go +++ b/swarm/api/api.go @@ -525,6 +525,10 @@ func (a *API) GetDirectoryTar(ctx context.Context, uri *URI) (io.ReadCloser, err return nil }) + // close tar writer before closing pipew + // to flush remaining data to pipew + // regardless of error value + tw.Close() if err != nil { apiGetTarFail.Inc(1) pipew.CloseWithError(err) |