lnd+sweep: remove unused NextAttemptDeltaFunc

Author: yyforyongyu

server.go

@@ -1064,19 +1064,18 @@ func newServer(cfg *Config, listenAddrs []net.Addr,
 	)
 
 	s.sweeper = sweep.New(&sweep.UtxoSweeperConfig{
-		FeeEstimator:         cc.FeeEstimator,
-		GenSweepScript:       newSweepPkScriptGen(cc.Wallet),
-		Signer:               cc.Wallet.Cfg.Signer,
-		Wallet:               newSweeperWallet(cc.Wallet),
-		TickerDuration:       cfg.Sweeper.BatchWindowDuration,
-		Mempool:              cc.MempoolNotifier,
-		Notifier:             cc.ChainNotifier,
-		Store:                sweeperStore,
-		MaxInputsPerTx:       sweep.DefaultMaxInputsPerTx,
-		MaxSweepAttempts:     sweep.DefaultMaxSweepAttempts,
-		NextAttemptDeltaFunc: sweep.DefaultNextAttemptDeltaFunc,
-		MaxFeeRate:           cfg.Sweeper.MaxFeeRate,
-		Aggregator:           aggregator,
+		FeeEstimator:     cc.FeeEstimator,
+		GenSweepScript:   newSweepPkScriptGen(cc.Wallet),
+		Signer:           cc.Wallet.Cfg.Signer,
+		Wallet:           newSweeperWallet(cc.Wallet),
+		TickerDuration:   cfg.Sweeper.BatchWindowDuration,
+		Mempool:          cc.MempoolNotifier,
+		Notifier:         cc.ChainNotifier,
+		Store:            sweeperStore,
+		MaxInputsPerTx:   sweep.DefaultMaxInputsPerTx,
+		MaxSweepAttempts: sweep.DefaultMaxSweepAttempts,
+		MaxFeeRate:       cfg.Sweeper.MaxFeeRate,
+		Aggregator:       aggregator,
 	})
 
 	s.utxoNursery = contractcourt.NewUtxoNursery(&contractcourt.NurseryConfig{

sweep/sweeper.go

@@ -358,10 +358,6 @@ type UtxoSweeperConfig struct {
 	// to the caller.
 	MaxSweepAttempts int
 
-	// NextAttemptDeltaFunc returns given the number of already attempted
-	// sweeps, how many blocks to wait before retrying to sweep.
-	NextAttemptDeltaFunc func(int) int32
-
 	// MaxFeeRate is the the maximum fee rate allowed within the
 	// UtxoSweeper.
 	MaxFeeRate chainfee.SatPerVByte
@@ -1337,14 +1333,6 @@ func (s *UtxoSweeper) CreateSweepTx(inputs []input.Input,
 	return tx, err
 }
 
-// DefaultNextAttemptDeltaFunc is the default calculation for next sweep attempt
-// scheduling. It implements exponential back-off with some randomness. This is
-// to prevent a stuck tx (for example because fee is too low and can't be bumped
-// in btcd) from blocking all other retried inputs in the same tx.
-func DefaultNextAttemptDeltaFunc(attempts int) int32 {
-	return 1 + rand.Int31n(1<<uint(attempts-1))
-}
-
 // ListSweeps returns a list of the the sweeps recorded by the sweep store.
 func (s *UtxoSweeper) ListSweeps() ([]chainhash.Hash, error) {
 	return s.cfg.Store.ListSweeps()

sweep/sweeper_test.go

@@ -148,12 +148,8 @@ func createSweeperTestContext(t *testing.T) *sweeperTestContext {
 		FeeEstimator:     estimator,
 		MaxInputsPerTx:   testMaxInputsPerTx,
 		MaxSweepAttempts: testMaxSweepAttempts,
-		NextAttemptDeltaFunc: func(attempts int) int32 {
-			// Use delta func without random factor.
-			return 1 << uint(attempts-1)
-		},
-		MaxFeeRate: DefaultMaxFeeRate,
-		Aggregator: aggregator,
+		MaxFeeRate:       DefaultMaxFeeRate,
+		Aggregator:       aggregator,
 	})
 
 	ctx.sweeper.Start()