mirror of
https://github.com/prometheus/prometheus.git
synced 2024-11-10 23:54:05 -08:00
clean up codes
This commit is contained in:
parent
90de381cdb
commit
19340a382d
5
wal.go
5
wal.go
|
@ -714,10 +714,7 @@ func (w *SegmentWAL) Close() error {
|
||||||
return errors.Wrapf(hf.Close(), "closing WAL head %s", hf.Name())
|
return errors.Wrapf(hf.Close(), "closing WAL head %s", hf.Name())
|
||||||
}
|
}
|
||||||
|
|
||||||
if w.dirFile != nil {
|
return w.dirFile.Close()
|
||||||
w.dirFile.Close()
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
|
|
@ -273,7 +273,7 @@ func TestWALRestoreCorrupted_invalidSegment(t *testing.T) {
|
||||||
Ok(t, err)
|
Ok(t, err)
|
||||||
f2, err := wal.createSegmentFile(dir + "/000002")
|
f2, err := wal.createSegmentFile(dir + "/000002")
|
||||||
Ok(t, err)
|
Ok(t, err)
|
||||||
Ok(t, f2.Close()) // close for windows!
|
Ok(t, f2.Close())
|
||||||
|
|
||||||
// Make header of second segment invalid.
|
// Make header of second segment invalid.
|
||||||
_, err = f.WriteAt([]byte{1, 2, 3, 4}, 0)
|
_, err = f.WriteAt([]byte{1, 2, 3, 4}, 0)
|
||||||
|
|
Loading…
Reference in a new issue