From 13686ad80c1fb6350f86490d36566991d7f88447 Mon Sep 17 00:00:00 2001 From: i-norden Date: Mon, 31 Jan 2022 13:20:25 -0600 Subject: [PATCH] fix possible race condition --- params/version.go | 2 +- statediff/indexer/database/sql/indexer.go | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/params/version.go b/params/version.go index e42277733..6a5ab4b1d 100644 --- a/params/version.go +++ b/params/version.go @@ -24,7 +24,7 @@ const ( VersionMajor = 1 // Major version component of the current release VersionMinor = 10 // Minor version component of the current release VersionPatch = 15 // Patch version component of the current release - VersionMeta = "statediff-3.0.0" // Version metadata to append to the version string + VersionMeta = "statediff-3.0.1" // Version metadata to append to the version string ) // Version holds the textual version string. diff --git a/statediff/indexer/database/sql/indexer.go b/statediff/indexer/database/sql/indexer.go index c8d526d6f..3e578a469 100644 --- a/statediff/indexer/database/sql/indexer.go +++ b/statediff/indexer/database/sql/indexer.go @@ -150,8 +150,10 @@ func (sdi *StateDiffIndexer) PushBlock(block *types.Block, receipts types.Receip dbtx: tx, // handle transaction commit or rollback for any return case submit: func(self *BatchTx, err error) error { - close(self.quit) - close(self.iplds) + defer func() { + close(self.quit) + close(self.iplds) + }() if p := recover(); p != nil { rollback(sdi.ctx, tx) panic(p)