diff options
| author | 2026-03-04 09:55:00 +0800 | |
|---|---|---|
| committer | 2026-03-04 09:55:00 +0800 | |
| commit | 0a8c2632d02d19dc986f34f6ea457e4994977002 (patch) | |
| tree | e34a8dc3c14ff711713e7f8640f0ed8889094c9a /internal/zlib/reader.go | |
| parent | config: Splitting (diff) | |
| signature | No signature | |
zlib: Split files
Diffstat (limited to 'internal/zlib/reader.go')
| -rw-r--r-- | internal/zlib/reader.go | 74 |
1 files changed, 0 insertions, 74 deletions
diff --git a/internal/zlib/reader.go b/internal/zlib/reader.go index e4babb9e..24db9875 100644 --- a/internal/zlib/reader.go +++ b/internal/zlib/reader.go @@ -34,15 +34,12 @@ and to read that data back: package zlib import ( - "bufio" "encoding/binary" "errors" "hash" "io" "sync" - "codeberg.org/lindenii/furgit/internal/adler32" - "github.com/klauspost/compress/flate" ) @@ -164,74 +161,3 @@ func (z *reader) Close() error { return nil } - -func (z *reader) Reset(r io.Reader, dict []byte) error { - *z = reader{decompressor: z.decompressor} - if fr, ok := r.(flate.Reader); ok { - z.r = fr - } else { - z.r = bufio.NewReader(r) - } - - // Read the header (RFC 1950 section 2.2.). - _, z.err = io.ReadFull(z.r, z.scratch[0:2]) - if z.err != nil { - if errors.Is(z.err, io.EOF) { - z.err = io.ErrUnexpectedEOF - } - - return z.err - } - - h := binary.BigEndian.Uint16(z.scratch[:2]) - if (z.scratch[0]&0x0f != zlibDeflate) || (z.scratch[0]>>4 > zlibMaxWindow) || (h%31 != 0) { - z.err = ErrHeader - - return z.err - } - - haveDict := z.scratch[1]&0x20 != 0 - if haveDict { - _, z.err = io.ReadFull(z.r, z.scratch[0:4]) - if z.err != nil { - if errors.Is(z.err, io.EOF) { - z.err = io.ErrUnexpectedEOF - } - - return z.err - } - - checksum := binary.BigEndian.Uint32(z.scratch[:4]) - if checksum != adler32.Checksum(dict) { - z.err = ErrDictionary - - return z.err - } - } - - if z.decompressor != nil { - resetter, ok := z.decompressor.(flate.Resetter) - if !ok { - panic("zlib: pooled decompressor does not implement flate.Resetter") - } - - z.err = resetter.Reset(z.r, dict) - if z.err != nil { - return z.err - } - - z.digest = adler32.New() - - return nil - } - - if haveDict { - z.decompressor = flate.NewReaderDict(z.r, dict) - } else { - z.decompressor = flate.NewReader(z.r) - } - - z.digest = adler32.New() - - return nil -} |
