eventstore/lmdb: remove unused lastIdx code.
This commit is contained in:
@@ -4,7 +4,6 @@ import (
|
|||||||
"encoding/binary"
|
"encoding/binary"
|
||||||
"fmt"
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"sync/atomic"
|
|
||||||
|
|
||||||
"fiatjaf.com/nostr"
|
"fiatjaf.com/nostr"
|
||||||
"fiatjaf.com/nostr/eventstore"
|
"fiatjaf.com/nostr/eventstore"
|
||||||
@@ -34,8 +33,6 @@ type LMDBBackend struct {
|
|||||||
|
|
||||||
hllCache lmdb.DBI
|
hllCache lmdb.DBI
|
||||||
EnableHLLCacheFor func(kind nostr.Kind) (useCache bool, skipSavingActualEvent bool)
|
EnableHLLCacheFor func(kind nostr.Kind) (useCache bool, skipSavingActualEvent bool)
|
||||||
|
|
||||||
lastId atomic.Uint32
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *LMDBBackend) Init() error {
|
func (b *LMDBBackend) Init() error {
|
||||||
@@ -186,28 +183,5 @@ func (b *LMDBBackend) initialize() error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// get lastId
|
|
||||||
if err := b.lmdbEnv.View(func(txn *lmdb.Txn) error {
|
|
||||||
txn.RawRead = true
|
|
||||||
cursor, err := txn.OpenCursor(b.rawEventStore)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
defer cursor.Close()
|
|
||||||
k, _, err := cursor.Get(nil, nil, lmdb.Last)
|
|
||||||
if lmdb.IsNotFound(err) {
|
|
||||||
// nothing found, so we're at zero
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
b.lastId.Store(binary.BigEndian.Uint32(k))
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return b.migrate()
|
return b.migrate()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user