aboutsummaryrefslogtreecommitdiff
path: root/internal/flate/decompress_bytes.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2025-11-19 08:00:00 +0800
committerGravatar Runxi Yu2025-11-19 08:00:00 +0800
commited0a113f034aa42aea23471c4bc0d7af159b7002 (patch)
tree7e828011b9e213499ce382eb17e2552da6e48de4 /internal/flate/decompress_bytes.go
parentRemove some redundant code (diff)
signatureNo signature
Probably should name the custom packages specially
Diffstat (limited to 'internal/flate/decompress_bytes.go')
-rw-r--r--internal/flate/decompress_bytes.go64
1 files changed, 0 insertions, 64 deletions
diff --git a/internal/flate/decompress_bytes.go b/internal/flate/decompress_bytes.go
deleted file mode 100644
index 18fe21fc..00000000
--- a/internal/flate/decompress_bytes.go
+++ /dev/null
@@ -1,64 +0,0 @@
-package flate
-
-import (
- "io"
- "sync"
-
- "git.sr.ht/~runxiyu/furgit/internal/bufpool"
-)
-
-// bufferDecompressor wraps the custom slice inflater so byte-slice
-// decompressions avoid repeated allocations.
-type bufferDecompressor struct {
- inflater sliceInflater
-}
-
-var bufferDecompressorPool = sync.Pool{
- New: func() any {
- fixedHuffmanDecoderInit()
- d := &bufferDecompressor{}
- d.inflater.bits = new([maxNumLit + maxNumDist]int)
- d.inflater.codebits = new([numCodes]int)
- return d
- },
-}
-
-// Decompress inflates the provided DEFLATE stream and returns the full output
-// in a pooled bufpool.Buffer along with the number of consumed bytes from src.
-func Decompress(src []byte) (bufpool.Buffer, int, error) {
- return DecompressDict(src, nil)
-}
-
-// DecompressDict inflates the provided DEFLATE stream using dict as the preset
-// dictionary and returns the full output in a pooled bufpool.Buffer. The second
-// returned value reports how many bytes of src were consumed.
-func DecompressDict(src []byte, dict []byte) (bufpool.Buffer, int, error) {
- d := bufferDecompressorPool.Get().(*bufferDecompressor)
- defer bufferDecompressorPool.Put(d)
-
- if err := d.inflater.reset(src, dict); err != nil {
- return bufpool.Buffer{}, 0, err
- }
-
- out := bufpool.Borrow(bufpool.DefaultBufferCap)
- out.Resize(0)
-
- for {
- if len(d.inflater.toRead) > 0 {
- out.Append(d.inflater.toRead)
- d.inflater.toRead = nil
- continue
- }
- if d.inflater.err != nil {
- if d.inflater.err == io.EOF {
- return out, d.inflater.pos, nil
- }
- out.Release()
- return bufpool.Buffer{}, 0, d.inflater.err
- }
- d.inflater.step(&d.inflater)
- if d.inflater.err != nil && len(d.inflater.toRead) == 0 {
- d.inflater.toRead = d.inflater.dict.readFlush()
- }
- }
-}