diff options
Diffstat (limited to 'integration_test/node.go')
| -rw-r--r-- | integration_test/node.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/integration_test/node.go b/integration_test/node.go index c0c4fa1..555142d 100644 --- a/integration_test/node.go +++ b/integration_test/node.go @@ -203,11 +203,14 @@ func (n *Node) processBlock(b *types.Block) (err error) { } // Deliver blocks. for _, b = range delivered { - if err = n.db.Update(*b); err != nil { + if err = n.db.Put(*b); err != nil { return } n.app.BlockDelivered(*b) } + if err = n.lattice.PurgeBlocks(delivered); err != nil { + return + } // Update pending blocks for verified block (pass sanity check). pendings = append(pendings, verified...) } |