From a6002252e227ff8ef4de3933cce362eb9cf5e34e Mon Sep 17 00:00:00 2001 From: Yusuf Birader Date: Sun, 24 Sep 2023 12:42:26 +0100 Subject: [PATCH] update readme --- README.md | 5 +++-- extractor.go | 8 ++++---- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/README.md b/README.md index 60dc1b0..0f5a5de 100644 --- a/README.md +++ b/README.md @@ -14,14 +14,15 @@ pzip, short for parallel-zip, is a blazing fast concurrent zip archiver and extr ### Command Line For command-line usage, we provide two binaries which can be installed separately: -- pzip- concurrent zip archiving -- punzip- concurrent zip extraction +- **pzip-** concurrent zip archiving +- **punzip-** concurrent zip extraction To install, run: ### macOS For zip archiving: `brew install ybirader/pzip/pzip` + For zip extraction: `brew install ybirader/pzip/punzip` #### Debian, Ubuntu, Raspbian diff --git a/extractor.go b/extractor.go index c6e2a75..ae26814 100644 --- a/extractor.go +++ b/extractor.go @@ -39,7 +39,7 @@ func NewExtractor(outputDir string, options ...extractorOption) (*extractor, err return nil } - fileWorkerPool, err := pool.NewFileWorkerPool(fileExecutor, &pool.Config{Concurrency: e.concurrency, Capacity: 1000}) + fileWorkerPool, err := pool.NewFileWorkerPool(fileExecutor, &pool.Config{Concurrency: e.concurrency, Capacity: 10}) if err != nil { return nil, derrors.Wrap(err, "ERROR: could not create new file worker pool") } @@ -106,15 +106,15 @@ func (e *extractor) extractFile(file *zip.File) (err error) { err = errors.Join(err, outputFile.Close()) }() - fileContent, err := file.Open() + srcFile, err := file.Open() if err != nil { return derrors.Errorf("ERROR: could not open file %s", file.Name) } defer func() { - err = errors.Join(err, fileContent.Close()) + err = errors.Join(err, srcFile.Close()) }() - _, err = io.Copy(outputFile, fileContent) + _, err = io.Copy(outputFile, srcFile) if err != nil { return derrors.Errorf("ERROR: could not decompress file %s", file.Name) }