fix(txpool): check deadlock situation

consensus/consensus_test.go

@@ -71,7 +71,7 @@ func setupWithSeed(t *testing.T, seed int64) *testData {
 
 	fmt.Printf("=== test %s, seed: %d\n", t.Name(), seed)
 
-	ts := testsuite.NewTestSuiteForSeed(seed)
+	ts := testsuite.NewTestSuiteFromSeed(seed)
 
 	_, valKeys := ts.GenerateTestCommittee(4)
 	txPool := txpool.MockingTxPool()

execution/errors.go

@@ -16,7 +16,7 @@ type TransactionCommittedError struct {
 }
 
 func (e TransactionCommittedError) Error() string {
-	return fmt.Sprintf("the transaction committed before: %s",
+	return fmt.Sprintf("the transaction submitted before: %s",
 		e.ID.String())
 }
 

txpool/txpool.go

@@ -302,6 +302,10 @@ func (p *txPool) Size() int {
 	p.lk.RLock()
 	defer p.lk.RUnlock()
 
+	return p.size()
+}
+
+func (p *txPool) size() int {
 	size := 0
 	for _, pool := range p.pools {
 		size += pool.list.Size()
@@ -345,7 +349,7 @@ func (p *txPool) AllPendingTxs() []*tx.Tx {
 	p.lk.RLock()
 	defer p.lk.RUnlock()
 
-	txs := make([]*tx.Tx, 0, p.Size())
+	txs := make([]*tx.Tx, 0, p.size())
 
 	var next *linkedlist.Element[linkedmap.Pair[tx.ID, *tx.Tx]]
 	for _, pool := range p.pools {

txpool/txpool_test.go

@@ -257,8 +257,7 @@ func TestCalculatingConsumption(t *testing.T) {
 		// Handle the block in the transaction pool
 		td.pool.HandleCommittedBlock(blk)
 
-		// Uncomment me to track consumption map.
-		// fmt.Println(td.pool.consumptionMap)
+		t.Logf("consumption Map: %v\n", td.pool.consumptionMap)
 	}
 
 	require.Equal(t, expected, td.pool.consumptionMap)

util/testsuite/testsuite.go

@@ -39,8 +39,8 @@ func GenerateSeed() int64 {
 	return time.Now().UTC().UnixNano()
 }
 
-// NewTestSuiteForSeed creates a new TestSuite with the given seed.
-func NewTestSuiteForSeed(seed int64) *TestSuite {
+// NewTestSuiteFromSeed creates a new TestSuite with the given seed.
+func NewTestSuiteFromSeed(seed int64) *TestSuite {
 	return &TestSuite{
 		Seed: seed,
 		//nolint:gosec // to reproduce the failed tests

www/grpc/server_test.go

@@ -50,7 +50,7 @@ func setup(t *testing.T, conf *Config) *testData {
 		conf = testConfig()
 	}
 
-	ts := testsuite.NewTestSuiteForSeed(1717506021599855072)
+	ts := testsuite.NewTestSuite(t)
 
 	// for saving test wallets in temp directory
 	err := os.Chdir(util.TempDirPath())