mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-19 02:12:23 +00:00
fix comments
This commit is contained in:
parent
490587d210
commit
f671be40b4
1 changed files with 18 additions and 13 deletions
|
|
@ -310,10 +310,12 @@ func (d *Database) Get(key []byte) ([]byte, error) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
ret := make([]byte, len(dat))
|
||||||
|
copy(ret, dat)
|
||||||
if err = closer.Close(); err != nil {
|
if err = closer.Close(); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
return common.CopyBytes(dat), nil
|
return ret, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Put inserts the given value into the key-value store.
|
// Put inserts the given value into the key-value store.
|
||||||
|
|
@ -520,17 +522,17 @@ type batch struct {
|
||||||
}
|
}
|
||||||
|
|
||||||
// Put inserts the given value into the batch for later committing.
|
// Put inserts the given value into the batch for later committing.
|
||||||
func (b *batch) Put(key, value []byte) (err error) {
|
func (b *batch) Put(key, value []byte) error {
|
||||||
err = b.b.Set(key, value, nil)
|
err := b.b.Set(key, value, nil)
|
||||||
b.size += len(key) + len(value)
|
b.size += len(key) + len(value)
|
||||||
return
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Delete inserts the key removal into the batch for later committing.
|
// Delete inserts the key removal into the batch for later committing.
|
||||||
func (b *batch) Delete(key []byte) (err error) {
|
func (b *batch) Delete(key []byte) error {
|
||||||
err = b.b.Delete(key, nil)
|
err := b.b.Delete(key, nil)
|
||||||
b.size += len(key)
|
b.size += len(key)
|
||||||
return
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// ValueSize retrieves the amount of data queued up for writing.
|
// ValueSize retrieves the amount of data queued up for writing.
|
||||||
|
|
@ -555,24 +557,27 @@ func (b *batch) Reset() {
|
||||||
}
|
}
|
||||||
|
|
||||||
// Replay replays the batch contents.
|
// Replay replays the batch contents.
|
||||||
func (b *batch) Replay(w ethdb.KeyValueWriter) (bErr error) {
|
func (b *batch) Replay(w ethdb.KeyValueWriter) error {
|
||||||
reader := b.b.Reader()
|
reader := b.b.Reader()
|
||||||
for bErr == nil {
|
for {
|
||||||
kind, k, v, ok, err := reader.Next()
|
kind, k, v, ok, err := reader.Next()
|
||||||
if !ok || err != nil {
|
if !ok || err != nil {
|
||||||
break
|
return err
|
||||||
}
|
}
|
||||||
// The (k,v) slices might be overwritten if the batch is reset/reused,
|
// The (k,v) slices might be overwritten if the batch is reset/reused,
|
||||||
// and the receiver should copy them if they are to be retained long-term.
|
// and the receiver should copy them if they are to be retained long-term.
|
||||||
if kind == pebble.InternalKeyKindSet {
|
if kind == pebble.InternalKeyKindSet {
|
||||||
bErr = w.Put(k, v)
|
if err = w.Put(k, v); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
} else if kind == pebble.InternalKeyKindDelete {
|
} else if kind == pebble.InternalKeyKindDelete {
|
||||||
bErr = w.Delete(k)
|
if err = w.Delete(k); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
return fmt.Errorf("unhandled operation, keytype: %v", kind)
|
return fmt.Errorf("unhandled operation, keytype: %v", kind)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// pebbleIterator is a wrapper of underlying iterator in storage engine.
|
// pebbleIterator is a wrapper of underlying iterator in storage engine.
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue