diff --git a/options.go b/options.go index da5393f..0cc4050 100644 --- a/options.go +++ b/options.go @@ -47,7 +47,7 @@ const ( var DefaultOptions = Options{ DirPath: os.TempDir(), - SegmentSize: GB, + SegmentSize: 1 * GB, SegmentFileExt: ".SEG", Sync: false, BytesPerSync: 0, diff --git a/segment.go b/segment.go index c3fde85..18e271c 100644 --- a/segment.go +++ b/segment.go @@ -100,7 +100,7 @@ func putBuffer(buf []byte) { blockPool.Put(buf) } -// openSegmentFile a new segment file. +// openSegmentFile open a segment file. func openSegmentFile(dirPath, extName string, id uint32) (*segment, error) { fd, err := os.OpenFile( SegmentFileName(dirPath, extName, id), @@ -154,10 +154,10 @@ func (seg *segment) Sync() error { // Remove removes the segment file. func (seg *segment) Remove() error { if !seg.closed { - seg.closed = true if err := seg.fd.Close(); err != nil { return err } + seg.closed = true } return os.Remove(seg.fd.Name()) @@ -168,9 +168,11 @@ func (seg *segment) Close() error { if seg.closed { return nil } - + if err := seg.fd.Close(); err != nil { + return err + } seg.closed = true - return seg.fd.Close() + return nil } // Size returns the size of the segment file.