@@ -2039,7 +2039,7 @@ private void postSolidityFilter(final long oldSolidNum, final long latestSolidif
20392039 return ;
20402040 }
20412041
2042- List <BlockCapsule > capsuleList = getCrossBlockCapsule (latestSolidifiedBlockNumber );
2042+ List <BlockCapsule > capsuleList = geContinuousBlockCapsule (latestSolidifiedBlockNumber );
20432043 for (BlockCapsule blockCapsule : capsuleList ) {
20442044 postBlockFilter (blockCapsule , true );
20452045 postLogsFilter (blockCapsule , true , false );
@@ -2060,7 +2060,7 @@ private void postSolidityTrigger(final long oldSolidNum, final long latestSolidi
20602060 }
20612061
20622062 if (eventPluginLoaded && EventPluginLoader .getInstance ().isSolidityTriggerEnable ()) {
2063- List <BlockCapsule > capsuleList = getCrossBlockCapsule (latestSolidifiedBlockNumber );
2063+ List <BlockCapsule > capsuleList = geContinuousBlockCapsule (latestSolidifiedBlockNumber );
20642064 long solidifiedTime = -1 ;
20652065 if (!capsuleList .isEmpty ()) {
20662066 BlockCapsule blockCapsule = capsuleList .get (capsuleList .size () - 1 );
@@ -2211,15 +2211,14 @@ private void postBlockTrigger(final BlockCapsule blockCapsule) {
22112211 if (eventPluginLoaded && EventPluginLoader .getInstance ().isBlockLogTriggerEnable ()) {
22122212 List <BlockCapsule > capsuleList = new ArrayList <>();
22132213 if (EventPluginLoader .getInstance ().isBlockLogTriggerSolidified ()) {
2214- capsuleList = getCrossBlockCapsule (solidityBlkNum );
2214+ capsuleList = geContinuousBlockCapsule (solidityBlkNum );
22152215 } else {
22162216 capsuleList .add (blockCapsule );
22172217 }
22182218
22192219 for (BlockCapsule capsule : capsuleList ) {
22202220 BlockLogTriggerCapsule blockLogTriggerCapsule = new BlockLogTriggerCapsule (capsule );
2221- blockLogTriggerCapsule .setLatestSolidifiedBlockNumber (getDynamicPropertiesStore ()
2222- .getLatestSolidifiedBlockNum ());
2221+ blockLogTriggerCapsule .setLatestSolidifiedBlockNumber (solidityBlkNum );
22232222 if (!triggerCapsuleQueue .offer (blockLogTriggerCapsule )) {
22242223 logger .info ("Too many triggers, block trigger lost: {}." , capsule .getBlockId ());
22252224 }
@@ -2230,7 +2229,7 @@ private void postBlockTrigger(final BlockCapsule blockCapsule) {
22302229 if (eventPluginLoaded && EventPluginLoader .getInstance ().isTransactionLogTriggerEnable ()) {
22312230 List <BlockCapsule > capsuleList = new ArrayList <>();
22322231 if (EventPluginLoader .getInstance ().isTransactionLogTriggerSolidified ()) {
2233- capsuleList = getCrossBlockCapsule (solidityBlkNum );
2232+ capsuleList = geContinuousBlockCapsule (solidityBlkNum );
22342233 } else {
22352234 // need to reset block
22362235 capsuleList .add (blockCapsule );
@@ -2242,9 +2241,10 @@ private void postBlockTrigger(final BlockCapsule blockCapsule) {
22422241 }
22432242 }
22442243
2245- private List <BlockCapsule > getCrossBlockCapsule (long solidityBlkNum ) {
2244+ private List <BlockCapsule > geContinuousBlockCapsule (long solidityBlkNum ) {
22462245 List <BlockCapsule > capsuleList = new ArrayList <>();
22472246 long start = lastUsedSolidityNum < 0 ? (solidityBlkNum - 1 ) : lastUsedSolidityNum ;
2247+ logger .info ("Continuous block start:{}, end:{}" , start +1 , solidityBlkNum );
22482248 for (long blockNum = start + 1 ; blockNum <= solidityBlkNum ; blockNum ++) {
22492249 try {
22502250 BlockCapsule capsule = chainBaseManager .getBlockByNum (blockNum );
0 commit comments