[R4R]fix:Shift panic for zero length of heads

core/state_prefetcher.go

@@ -127,6 +127,9 @@ func (p *statePrefetcher) PrefetchMining(txs *types.TransactionsByPriceAndNonce,
 	go func(txset *types.TransactionsByPriceAndNonce) {
 		count := 0
 		for {
+			if count++; count%checkInterval == 0 {
+				txset.Forward(*txCurr)
+			}
 			tx := txset.Peek()
 			if tx == nil {
 				return
@@ -136,12 +139,6 @@ func (p *statePrefetcher) PrefetchMining(txs *types.TransactionsByPriceAndNonce,
 				return
 			default:
 			}
-			if count++; count%checkInterval == 0 {
-				if *txCurr == nil {
-					return
-				}
-				txset.Forward(*txCurr)
-			}
 			txCh <- tx
 			txset.Shift()
 		}

core/types/transaction.go

@@ -506,7 +506,9 @@ func (t *TransactionsByPriceAndNonce) CurrentSize() int {
 //Forward moves current transaction to be the one which is one index after tx
 func (t *TransactionsByPriceAndNonce) Forward(tx *Transaction) {
 	if tx == nil {
-		t.heads = t.heads[0:0]
+		if len(t.heads) > 0 {
+			t.heads = t.heads[0:0]
+		}
 		return
 	}
 	//check whether target tx exists in t.heads

core/types/transaction_test.go

@@ -392,14 +392,17 @@ func TestTransactionForward(t *testing.T) {
 	}
 
 	tmp := txset.Copy()
-	for j := 0; j < 10; j++ {
+	for j := 0; j < 11; j++ {
 		txset = tmp.Copy()
 		txsetCpy = tmp.Copy()
 		i := 0
 		for ; i < j; i++ {
 			txset.Shift()
 		}
 		tx := txset.Peek()
+		if tx == nil {
+			continue
+		}
 		txsetCpy.Forward(tx)
 		txCpy := txsetCpy.Peek()
 		if txCpy == nil {