diff options
| author |  Runxi Yu | 2026-03-06 18:38:44 +0800 |
|---|---|---|
| committer | Runxi Yu | 2026-03-06 18:58:30 +0800 |
| commit | f2922155de01b734e3e8b3f50be8f263ec13cacd (patch) | |
| tree | 6dcfcf5689e63eea09314dce543e1de26cab89fe /format/pack/ingest/drain.go | |
| parent | internal/compress: Format (diff) | |
| signature | No signature | |
*: Lint v0.1.68
Diffstat (limited to 'format/pack/ingest/drain.go')
| -rw-r--r-- | format/pack/ingest/drain.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/format/pack/ingest/drain.go b/format/pack/ingest/drain.go index b92683c3..671423fb 100644 --- a/format/pack/ingest/drain.go +++ b/format/pack/ingest/drain.go @@ -18,7 +18,7 @@ func drainEntryPayload(state *ingestState, record objectRecord) (int64, uint64, reader, err := zlib.NewReader(state.stream) if err != nil { - return 0, 0, zero, &ErrMalformedPackEntry{Offset: record.offset, Reason: fmt.Sprintf("open zlib stream: %v", err)} + return 0, 0, zero, &MalformedPackEntryError{Offset: record.offset, Reason: fmt.Sprintf("open zlib stream: %v", err)} } defer func() { _ = reader.Close() }() @@ -28,7 +28,7 @@ func drainEntryPayload(state *ingestState, record objectRecord) (int64, uint64, if packfmt.IsBaseObjectType(record.packedType) { header, ok := objectheader.Encode(record.packedType, record.declaredSize) if !ok { - return 0, 0, zero, &ErrMalformedPackEntry{Offset: record.offset, Reason: "encode object header"} + return 0, 0, zero, &MalformedPackEntryError{Offset: record.offset, Reason: "encode object header"} } hashImpl, err := state.algo.New() @@ -40,7 +40,7 @@ func drainEntryPayload(state *ingestState, record objectRecord) (int64, uint64, n, err := io.Copy(hashImpl, reader) if err != nil { - return 0, 0, zero, &ErrMalformedPackEntry{Offset: record.offset, Reason: fmt.Sprintf("inflate base object: %v", err)} + return 0, 0, zero, &MalformedPackEntryError{Offset: record.offset, Reason: fmt.Sprintf("inflate base object: %v", err)} } total = n @@ -56,7 +56,7 @@ func drainEntryPayload(state *ingestState, record objectRecord) (int64, uint64, if record.packedType == objecttype.TypeOfsDelta || record.packedType == objecttype.TypeRefDelta { n, err := io.Copy(io.Discard, reader) if err != nil { - return 0, 0, zero, &ErrMalformedPackEntry{Offset: record.offset, Reason: fmt.Sprintf("inflate delta payload: %v", err)} + return 0, 0, zero, &MalformedPackEntryError{Offset: record.offset, Reason: fmt.Sprintf("inflate delta payload: %v", err)} } total = n @@ -64,5 +64,5 @@ func drainEntryPayload(state *ingestState, record objectRecord) (int64, uint64, return total, reader.InputConsumed(), zero, nil } - return 0, 0, zero, &ErrMalformedPackEntry{Offset: record.offset, Reason: "unsupported payload type"} + return 0, 0, zero, &MalformedPackEntryError{Offset: record.offset, Reason: "unsupported payload type"} } |