"time"
log "github.com/sirupsen/logrus"
- dbm "github.com/tendermint/tmlibs/db"
+ dbm "github.com/vapor/database/leveldb"
"github.com/vapor/errors"
"github.com/vapor/protocol/bc"
)
func (uk *utxoKeeper) expireWorker() {
ticker := time.NewTicker(1000 * time.Millisecond)
+ defer ticker.Stop()
+
for now := range ticker.C {
uk.expireReservation(now)
}
}
+
func (uk *utxoKeeper) expireReservation(t time.Time) {
uk.mtx.Lock()
defer uk.mtx.Unlock()
for utxoIter.Next() {
u := &UTXO{}
if err := json.Unmarshal(utxoIter.Value(), u); err != nil {
- log.WithField("err", err).Error("utxoKeeper findUtxos fail on unmarshal utxo")
+ log.WithFields(log.Fields{"module": logModule, "err": err}).Error("utxoKeeper findUtxos fail on unmarshal utxo")
continue
}
appendUtxo(u)