|
|
@ -229,7 +229,7 @@ func (e *Era) readOffset(n uint64) (int64, error) { |
|
|
|
) |
|
|
|
) |
|
|
|
e.mu.Lock() |
|
|
|
e.mu.Lock() |
|
|
|
defer e.mu.Unlock() |
|
|
|
defer e.mu.Unlock() |
|
|
|
clearBuffer(e.buf[:]) |
|
|
|
clear(e.buf[:]) |
|
|
|
if _, err := e.f.ReadAt(e.buf[:], offOffset); err != nil { |
|
|
|
if _, err := e.f.ReadAt(e.buf[:], offOffset); err != nil { |
|
|
|
return 0, err |
|
|
|
return 0, err |
|
|
|
} |
|
|
|
} |
|
|
@ -248,13 +248,6 @@ func newSnappyReader(e *e2store.Reader, expectedType uint16, off int64) (io.Read |
|
|
|
return snappy.NewReader(r), int64(n), err |
|
|
|
return snappy.NewReader(r), int64(n), err |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// clearBuffer zeroes out the buffer.
|
|
|
|
|
|
|
|
func clearBuffer(buf []byte) { |
|
|
|
|
|
|
|
for i := 0; i < len(buf); i++ { |
|
|
|
|
|
|
|
buf[i] = 0 |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// metadata wraps the metadata in the block index.
|
|
|
|
// metadata wraps the metadata in the block index.
|
|
|
|
type metadata struct { |
|
|
|
type metadata struct { |
|
|
|
start uint64 |
|
|
|
start uint64 |
|
|
|