forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

internal/era/e2store: export HeaderSize

Browse source
This commit is contained in:
lightclient@protonmail.com 2023-05-19 21:09:48 +02:00 committed by lightclient
parent f3ec256867
commit a9304e8c04
No known key found for this signature in database
GPG key ID: 75C916AFEE20183E
1 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
internal/era/e2store/e2store.go
View file

@ -23,7 +23,7 @@ import (
) )
const ( const (
headerSize = 8 HeaderSize = 8
valueSizeLimit = 1024 * 1024 * 50 valueSizeLimit = 1024 * 1024 * 50
) )
@ -50,7 +50,7 @@ func NewWriter(w io.Writer) *Writer {
// record store the type (2 bytes), the length (4 bytes), and some reserved // record store the type (2 bytes), the length (4 bytes), and some reserved
// data (2 bytes). The remaining bytes store b. // data (2 bytes). The remaining bytes store b.
func (w *Writer) Write(typ uint16, b []byte) (int, error) { func (w *Writer) Write(typ uint16, b []byte) (int, error) {
buf := make([]byte, headerSize+len(b)) buf := make([]byte, HeaderSize+len(b))
binary.LittleEndian.PutUint16(buf, typ) binary.LittleEndian.PutUint16(buf, typ)
binary.LittleEndian.PutUint32(buf[2:], uint32(len(b))) binary.LittleEndian.PutUint32(buf[2:], uint32(len(b)))
copy(buf[8:], b) copy(buf[8:], b)
@ -91,16 +91,16 @@ func (r *Reader) ReadAt(entry *Entry, off int64) (int, error) {
// Check length bounds. // Check length bounds.
if length > valueSizeLimit { if length > valueSizeLimit {
return headerSize, fmt.Errorf("item larger than item size limit %d: have %d", valueSizeLimit, length) return HeaderSize, fmt.Errorf("item larger than item size limit %d: have %d", valueSizeLimit, length)
} }
if length == 0 { if length == 0 {
return headerSize, nil return HeaderSize, nil
} }
// Read value. // Read value.
val := make([]byte, length) val := make([]byte, length)
if n, err := r.r.ReadAt(val, off+headerSize); err != nil { if n, err := r.r.ReadAt(val, off+HeaderSize); err != nil {
n += headerSize n += HeaderSize
// An entry with a non-zero length should not return EOF when // An entry with a non-zero length should not return EOF when
// reading the value. // reading the value.
if err == io.EOF { if err == io.EOF {
@ -109,12 +109,12 @@ func (r *Reader) ReadAt(entry *Entry, off int64) (int, error) {
return n, err return n, err
} }
entry.Value = val entry.Value = val
return int(headerSize + length), nil return int(HeaderSize + length), nil
} }
// ReadMetadataAt reads the header metadata at the given offset. // ReadMetadataAt reads the header metadata at the given offset.
func (r *Reader) ReadMetadataAt(off int64) (typ uint16, length uint32, err error) { func (r *Reader) ReadMetadataAt(off int64) (typ uint16, length uint32, err error) {
b := make([]byte, headerSize) b := make([]byte, HeaderSize)
if n, err := r.r.ReadAt(b, off); err != nil { if n, err := r.r.ReadAt(b, off); err != nil {
if err == io.EOF && n > 0 { if err == io.EOF && n > 0 {
return 0, 0, io.ErrUnexpectedEOF return 0, 0, io.ErrUnexpectedEOF
@ -154,7 +154,7 @@ func (r *Reader) Find(want uint16) (*Entry, error) {
} }
return &e, nil return &e, nil
} }
off += int64(headerSize + length) off += int64(HeaderSize + length)
} }
} }
@ -181,6 +181,6 @@ func (r *Reader) FindAll(want uint16) ([]*Entry, error) {
} }
entries = append(entries, e) entries = append(entries, e)
} }
off += int64(headerSize + length) off += int64(HeaderSize + length)
} }
} }