@@ -738,6 +738,7 @@ func (suite *Suite) TestGetSealedTransaction() {
738
738
require .NoError (suite .T (), bdb .WithReaderBatchWriter (func (rw storage.ReaderBatchWriter ) error {
739
739
return all .Blocks .BatchStore (lctx , rw , block )
740
740
}))
741
+ lctx .Release ()
741
742
require .NoError (suite .T (), err )
742
743
743
744
fctx := manager .NewContext ()
@@ -815,16 +816,17 @@ func (suite *Suite) TestGetTransactionResult() {
815
816
816
817
bdb := badgerimpl .ToDB (db )
817
818
manager , lctx := unittest .LockManagerWithContext (suite .T (), storage .LockInsertBlock )
818
- defer lctx .Release ()
819
819
require .NoError (suite .T (), bdb .WithReaderBatchWriter (func (rw storage.ReaderBatchWriter ) error {
820
820
return all .Blocks .BatchStore (lctx , rw , block )
821
821
}))
822
+ lctx .Release ()
823
+
822
824
lctx2 := manager .NewContext ()
823
- defer lctx2 .Release ()
824
825
require .NoError (suite .T (), lctx2 .AcquireLock (storage .LockInsertBlock ))
825
826
require .NoError (suite .T (), bdb .WithReaderBatchWriter (func (rw storage.ReaderBatchWriter ) error {
826
827
return all .Blocks .BatchStore (lctx2 , rw , blockNegative )
827
828
}))
829
+ lctx2 .Release ()
828
830
829
831
suite .state .On ("AtBlockID" , blockId ).Return (suite .sealedSnapshot )
830
832
@@ -971,10 +973,11 @@ func (suite *Suite) TestGetTransactionResult() {
971
973
}
972
974
}
973
975
fctx2 := manager .NewContext ()
974
- defer fctx2 .Release ( )
976
+ require . NoError ( suite . T (), fctx2 .AcquireLock ( storage . LockFinalizeBlock ) )
975
977
require .NoError (suite .T (), bdb .WithReaderBatchWriter (func (rw storage.ReaderBatchWriter ) error {
976
978
return operation .IndexBlockHeight (fctx2 , rw , block .Header .Height , block .ID ())
977
979
}))
980
+ fctx2 .Release ()
978
981
finalSnapshot .On ("Head" ).Return (block .Header , nil )
979
982
980
983
processExecutionReceipts (block , collection , enNodeIDs , originID , ingestEng )
0 commit comments