Adjust call of "notifyTransactionProviderIfNeeded".

process/block/preprocess/transactions.go

@@ -238,6 +238,7 @@ func (txs *transactions) RemoveBlockDataFromPools(body *block.Body, miniBlockPoo
 
 // RemoveTxsFromPools removes transactions from associated pools
 func (txs *transactions) RemoveTxsFromPools(body *block.Body) error {
+	txs.notifyTransactionProviderIfNeeded()
 	return txs.removeTxsFromPools(body, txs.txPool, txs.isMiniBlockCorrect)
 }
 
@@ -644,10 +645,6 @@ func (txs *transactions) processTxsFromMe(
 		return false
 	}
 
-	defer func() {
-		go txs.notifyTransactionProviderIfNeeded()
-	}()
-
 	calculatedMiniBlocks, _, mapSCTxs, err := txs.createAndProcessMiniBlocksFromMe(
 		haveTime,
 		isShardStuckFalse,
@@ -1104,10 +1101,6 @@ func (txs *transactions) CreateAndProcessMiniBlocks(haveTime func() bool, random
 		return make(block.MiniBlockSlice, 0), nil
 	}
 
-	defer func() {
-		go txs.notifyTransactionProviderIfNeeded()
-	}()
-
 	startTime = time.Now()
 	miniBlocks, remainingTxs, mapSCTxs, err := txs.createAndProcessMiniBlocksFromMe(
 		haveTime,
@@ -1210,10 +1203,6 @@ func (txs *transactions) createAndProcessMiniBlocksFromMeV1(
 		return nil, nil, err
 	}
 
-	defer func() {
-		go txs.notifyTransactionProviderIfNeeded()
-	}()
-
 	remainingTxs := make([]*txcache.WrappedTransaction, 0)
 	for idx, wtx := range sortedTxs {
 		actions, tx := mbBuilder.checkAddTransaction(wtx)