diff --git a/bitcask.go b/bitcask.go index cb2152a..e43c238 100644 --- a/bitcask.go +++ b/bitcask.go @@ -175,11 +175,7 @@ func (b *Bitcask) Fold(f func(key string) error) error { } func (b *Bitcask) put(key string, value []byte) (int64, error) { - size, err := b.curr.Size() - if err != nil { - return -1, err - } - + size := b.curr.Size() if size >= int64(b.config.maxDatafileSize) { err := b.curr.Close() if err != nil { diff --git a/internal/datafile.go b/internal/datafile.go index 5d16785..8dc2ad9 100644 --- a/internal/datafile.go +++ b/internal/datafile.go @@ -98,10 +98,10 @@ func (df *Datafile) Sync() error { return df.w.Sync() } -func (df *Datafile) Size() (int64, error) { +func (df *Datafile) Size() int64 { df.RLock() defer df.RUnlock() - return df.offset, nil + return df.offset } func (df *Datafile) Read() (e pb.Entry, err error) {