Fix bulk import of ethereum internal data
This commit is contained in:
parent
4f7d8f0956
commit
6e51bdefd3
@ -380,6 +380,10 @@ func (b *BulkConnect) Close() error {
|
|||||||
}
|
}
|
||||||
wb := grocksdb.NewWriteBatch()
|
wb := grocksdb.NewWriteBatch()
|
||||||
defer wb.Destroy()
|
defer wb.Destroy()
|
||||||
|
if err := b.d.storeInternalDataEthereumType(wb, b.ethBlockTxs); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
b.ethBlockTxs = b.ethBlockTxs[:0]
|
||||||
bac := b.bulkAddressesCount
|
bac := b.bulkAddressesCount
|
||||||
if err := b.storeBulkAddresses(wb); err != nil {
|
if err := b.storeBulkAddresses(wb); err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user