Skip to content

Commit 4ae989d

Browse files
committed
Fix some golangci-lint errors in cache/disk/casblob
1 parent 96387ea commit 4ae989d

File tree

2 files changed

+32
-29
lines changed

2 files changed

+32
-29
lines changed

cache/disk/casblob/casblob.go

Lines changed: 28 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -182,7 +182,7 @@ func ExtractLogicalSize(rc io.ReadCloser) (io.ReadCloser, int64, error) {
182182
return nil, -1, err
183183
}
184184
if n != 16 {
185-
return nil, -1, fmt.Errorf("Tried to read 16 header bytes, only read %d", n)
185+
return nil, -1, fmt.Errorf("tried to read 16 header bytes, only read %d", n)
186186
}
187187

188188
var uncompressedSize int64
@@ -192,7 +192,7 @@ func ExtractLogicalSize(rc io.ReadCloser) (io.ReadCloser, int64, error) {
192192
return nil, -1, err
193193
}
194194
if uncompressedSize <= 0 {
195-
return nil, -1, fmt.Errorf("Expected blob to have positive size, found %d",
195+
return nil, -1, fmt.Errorf("expected blob to have positive size, found %d",
196196
uncompressedSize)
197197
}
198198

@@ -218,12 +218,12 @@ func (m *multiReadCloser) Close() error {
218218
func GetUncompressedReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize int64, offset int64) (io.ReadCloser, error) {
219219
h, err := readHeader(f)
220220
if err != nil {
221-
f.Close()
221+
_ = f.Close()
222222
return nil, err
223223
}
224224

225225
if expectedSize != -1 && h.uncompressedSize != expectedSize {
226-
f.Close()
226+
_ = f.Close()
227227
return nil, fmt.Errorf("expected a blob of size %d, found %d",
228228
expectedSize, h.uncompressedSize)
229229
}
@@ -235,7 +235,7 @@ func GetUncompressedReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize
235235
if offset > 0 {
236236
_, err = f.Seek(offset, io.SeekCurrent)
237237
if err != nil {
238-
f.Close()
238+
_ = f.Close()
239239
return nil, err
240240
}
241241
}
@@ -244,7 +244,7 @@ func GetUncompressedReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize
244244
}
245245

246246
if h.compression != Zstandard {
247-
f.Close()
247+
_ = f.Close()
248248
return nil,
249249
fmt.Errorf("internal error: unsupported compression type %d",
250250
h.compression)
@@ -257,14 +257,14 @@ func GetUncompressedReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize
257257
if chunkNum > 0 {
258258
_, err = f.Seek(h.chunkOffsets[chunkNum], io.SeekStart)
259259
if err != nil {
260-
f.Close()
260+
_ = f.Close()
261261
return nil, err
262262
}
263263
}
264264
if remainder == 0 {
265265
dec, err := zstd.GetDecoder(f)
266266
if err != nil {
267-
f.Close()
267+
_ = f.Close()
268268
return nil, err
269269
}
270270

@@ -279,26 +279,26 @@ func GetUncompressedReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize
279279
compressedFirstChunk := make([]byte, h.chunkOffsets[chunkNum+1]-h.chunkOffsets[chunkNum])
280280
_, err = io.ReadFull(f, compressedFirstChunk)
281281
if err != nil {
282-
f.Close()
282+
_ = f.Close()
283283
return nil, err
284284
}
285285

286286
uncompressedFirstChunk, err := zstd.DecodeAll(compressedFirstChunk)
287287
if err != nil {
288-
f.Close()
288+
_ = f.Close()
289289
return nil, err
290290
}
291291

292292
if chunkNum == int64(len(h.chunkOffsets)-2) {
293293
// Last chunk in the file.
294294
r := bytes.NewReader(uncompressedFirstChunk[remainder:])
295-
f.Close()
295+
_ = f.Close()
296296
return io.NopCloser(r), nil
297297
}
298298

299299
z, err := zstd.GetDecoder(f)
300300
if err != nil {
301-
f.Close()
301+
_ = f.Close()
302302
return nil, err
303303
}
304304

@@ -320,12 +320,12 @@ func GetZstdReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize int64, o
320320

321321
h, err := readHeader(f)
322322
if err != nil {
323-
f.Close()
323+
_ = f.Close()
324324
return nil, err
325325
}
326326

327327
if expectedSize != -1 && h.uncompressedSize != expectedSize {
328-
f.Close()
328+
_ = f.Close()
329329
return nil, fmt.Errorf("expected a blob of size %d, found %d",
330330
expectedSize, h.uncompressedSize)
331331
}
@@ -337,7 +337,7 @@ func GetZstdReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize int64, o
337337
if offset > 0 {
338338
_, err = f.Seek(offset, io.SeekCurrent)
339339
if err != nil {
340-
f.Close()
340+
_ = f.Close()
341341
return nil, err
342342
}
343343
}
@@ -346,7 +346,7 @@ func GetZstdReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize int64, o
346346
}
347347

348348
if h.compression != Zstandard {
349-
f.Close()
349+
_ = f.Close()
350350
return nil, fmt.Errorf("unsupported compression type: %d",
351351
h.compression)
352352
}
@@ -372,7 +372,7 @@ func GetZstdReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize int64, o
372372
if chunkNum > 0 {
373373
_, err = f.Seek(h.chunkOffsets[chunkNum], io.SeekStart)
374374
if err != nil {
375-
f.Close()
375+
_ = f.Close()
376376
return nil, err
377377
}
378378
}
@@ -385,13 +385,13 @@ func GetZstdReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize int64, o
385385
compressedFirstChunk := make([]byte, h.chunkOffsets[chunkNum+1]-h.chunkOffsets[chunkNum])
386386
_, err = io.ReadFull(f, compressedFirstChunk)
387387
if err != nil {
388-
f.Close()
388+
_ = f.Close()
389389
return nil, err
390390
}
391391

392392
uncompressedFirstChunk, err := zstd.DecodeAll(compressedFirstChunk)
393393
if err != nil {
394-
f.Close()
394+
_ = f.Close()
395395
return nil, err
396396
}
397397

@@ -400,7 +400,7 @@ func GetZstdReadCloser(zstd zstdimpl.ZstdImpl, f *os.File, expectedSize int64, o
400400

401401
br := bytes.NewReader(recompressedChunk)
402402
if chunkNum == int64(len(h.chunkOffsets)-2) {
403-
f.Close()
403+
_ = f.Close()
404404
return io.NopCloser(br), nil
405405
}
406406

@@ -521,7 +521,7 @@ var chunkBufferPool = &sync.Pool{
521521
// Return the size on disk or an error if something went wrong.
522522
func WriteAndClose(zstd zstdimpl.ZstdImpl, r io.Reader, f *os.File, t CompressionType, hash string, size int64) (int64, error) {
523523
var err error
524-
defer f.Close()
524+
defer func() { _ = f.Close() }()
525525

526526
if size <= 0 {
527527
return -1, fmt.Errorf("invalid file size: %d", size)
@@ -606,7 +606,7 @@ func WriteAndClose(zstd zstdimpl.ZstdImpl, r io.Reader, f *os.File, t Compressio
606606

607607
numRead, err = io.ReadFull(r, uncompressedChunk[0:chunkEnd])
608608
if err != nil {
609-
return -1, fmt.Errorf("Only managed to read %d of %d bytes: %w", numRead, chunkEnd, err)
609+
return -1, fmt.Errorf("only managed to read %d of %d bytes: %w", numRead, chunkEnd, err)
610610
}
611611

612612
compressedChunk := zstd.EncodeAll(uncompressedChunk[0:chunkEnd])
@@ -615,7 +615,7 @@ func WriteAndClose(zstd zstdimpl.ZstdImpl, r io.Reader, f *os.File, t Compressio
615615

616616
written, err := f.Write(compressedChunk)
617617
if err != nil {
618-
return -1, fmt.Errorf("Failed to write compressed chunk to disk: %w", err)
618+
return -1, fmt.Errorf("failed to write compressed chunk to disk: %w", err)
619619
}
620620

621621
fileOffset += int64(written)
@@ -627,7 +627,7 @@ func WriteAndClose(zstd zstdimpl.ZstdImpl, r io.Reader, f *os.File, t Compressio
627627
if err == nil {
628628
return -1, fmt.Errorf("expected %d bytes but got at least %d more", size, bytesAfter)
629629
} else if err != io.EOF {
630-
return -1, fmt.Errorf("Failed to read chunk of size %d: %w", len(uncompressedChunk), err)
630+
return -1, fmt.Errorf("failed to read chunk of size %d: %w", len(uncompressedChunk), err)
631631
}
632632

633633
actualHash := hex.EncodeToString(hasher.Sum(nil))
@@ -639,22 +639,22 @@ func WriteAndClose(zstd zstdimpl.ZstdImpl, r io.Reader, f *os.File, t Compressio
639639
// We know all the chunk offsets now, go back and fill those in.
640640
_, err = f.Seek(chunkTableOffset, io.SeekStart)
641641
if err != nil {
642-
return -1, fmt.Errorf("Failed to seek to offset %d: %w", chunkTableOffset, err)
642+
return -1, fmt.Errorf("failed to seek to offset %d: %w", chunkTableOffset, err)
643643
}
644644

645645
err = binary.Write(f, binary.LittleEndian, h.chunkOffsets)
646646
if err != nil {
647-
return -1, fmt.Errorf("Failed to write chunk offsets: %w", err)
647+
return -1, fmt.Errorf("failed to write chunk offsets: %w", err)
648648
}
649649

650650
err = f.Sync()
651651
if err != nil {
652-
return -1, fmt.Errorf("Failed to sync file: %w", err)
652+
return -1, fmt.Errorf("failed to sync file: %w", err)
653653
}
654654

655655
err = f.Close()
656656
if err != nil {
657-
return -1, fmt.Errorf("Failed to close file: %w", err)
657+
return -1, fmt.Errorf("failed to close file: %w", err)
658658
}
659659

660660
return fileOffset, nil

cache/disk/casblob/casblob_test.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,10 @@ func TestZstdFromLegacy(t *testing.T) {
4949
if n != size {
5050
t.Fatalf("Unexpected short write %d, expected %d", n, size)
5151
}
52-
file.Close()
52+
err = file.Close()
53+
if err != nil {
54+
t.Fatal(err)
55+
}
5356

5457
file, err = os.Open(filename)
5558
if err != nil {

0 commit comments

Comments
 (0)