fix typo and refactor

Signed-off-by: ekexium <[email protected]>

txnkv/transaction/2pc.go

@@ -1342,14 +1342,17 @@ func keepAlive(
 						tm.close()
 					}
 					return
+					continue
 				}
-			} else {
-				keepFail = 0
-				metrics.TxnHeartBeatHistogramOK.Observe(time.Since(startTime).Seconds())
 			}
 
-			// broadcast to all stores
-			if err != nil && isPipelinedTxn {
+			keepFail = 0
+			metrics.TxnHeartBeatHistogramOK.Observe(time.Since(startTime).Seconds())
+			// Broadcast to all stores only when the heartbeat succeeds.
+			// This ensures that PK is the single source of truth for transaction status on the
+			// TiKV side. It prevents potential inconsistencies where the cached information might
+			// be more up-to-date than the info stored in the PK.
+			if isPipelinedTxn {
 				broadcastToAllStores(
 					c.txn,
 					c.store,