@@ -911,34 +911,28 @@ func (t *TxPublisher) processRecords() {
911
911
// For records that are confirmed, we'll notify the caller about this
912
912
// result.
913
913
for requestID , r := range confirmedRecords {
914
- rec := r
915
-
916
914
log .Debugf ("Tx=%v is confirmed" , r .tx .TxHash ())
917
915
t .wg .Add (1 )
918
- go t .handleTxConfirmed (rec , requestID )
916
+ go t .handleTxConfirmed (r , requestID )
919
917
}
920
918
921
919
// Get the current height to be used in the following goroutines.
922
920
currentHeight := t .currentHeight .Load ()
923
921
924
922
// For records that are not confirmed, we perform a fee bump if needed.
925
923
for requestID , r := range feeBumpRecords {
926
- rec := r
927
-
928
924
log .Debugf ("Attempting to fee bump Tx=%v" , r .tx .TxHash ())
929
925
t .wg .Add (1 )
930
- go t .handleFeeBumpTx (requestID , rec , currentHeight )
926
+ go t .handleFeeBumpTx (requestID , r , currentHeight )
931
927
}
932
928
933
929
// For records that are failed, we'll notify the caller about this
934
930
// result.
935
931
for requestID , r := range failedRecords {
936
- rec := r
937
-
938
932
log .Debugf ("Tx=%v has inputs been spent by a third party, " +
939
933
"failing it now" , r .tx .TxHash ())
940
934
t .wg .Add (1 )
941
- go t .handleThirdPartySpent (rec , requestID )
935
+ go t .handleThirdPartySpent (r , requestID )
942
936
}
943
937
}
944
938
0 commit comments