Merge pull request #562 from ethereumjs/fix/cache-err-cb

fix: propagate errors occuring in cache._flush
ethereumjs · Jul 26, 2019 · e26585f · e26585f
2 parents 0ccb64f + 616b907
commit e26585f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/state/cache.ts b/lib/state/cache.ts
@@ -125,7 +125,8 @@ export default class Cache {
         if (it.value && it.value.modified) {
           it.value.modified = false
           it.value.val = it.value.val.serialize()
-          this._trie.put(Buffer.from(it.key, 'hex'), it.value.val, () => {
+          this._trie.put(Buffer.from(it.key, 'hex'), it.value.val, (err: Error) => {
+            if (err) return done(err)
             next = it.hasNext
             it.next()
             done()
@@ -134,7 +135,8 @@ export default class Cache {
           it.value.modified = false
           it.value.deleted = false
           it.value.val = new Account().serialize()
-          this._trie.del(Buffer.from(it.key, 'hex'), () => {
+          this._trie.del(Buffer.from(it.key, 'hex'), (err: Error) => {
+            if (err) return done(err)
             next = it.hasNext
             it.next()
             done()