lnd+sweep: remove unused config MaxSweepAttempts

This commit is contained in:
yyforyongyu 2024-03-19 03:53:43 +08:00
parent 0b30d4ba3e
commit 370e4ce98d
No known key found for this signature in database
GPG Key ID: 9BCD95C4FF296868
3 changed files with 16 additions and 28 deletions

View File

@ -1076,18 +1076,17 @@ 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),
Mempool: cc.MempoolNotifier,
Notifier: cc.ChainNotifier,
Store: sweeperStore,
MaxInputsPerTx: sweep.DefaultMaxInputsPerTx,
MaxSweepAttempts: sweep.DefaultMaxSweepAttempts,
MaxFeeRate: cfg.Sweeper.MaxFeeRate,
Aggregator: aggregator,
Publisher: s.txPublisher,
FeeEstimator: cc.FeeEstimator,
GenSweepScript: newSweepPkScriptGen(cc.Wallet),
Signer: cc.Wallet.Cfg.Signer,
Wallet: newSweeperWallet(cc.Wallet),
Mempool: cc.MempoolNotifier,
Notifier: cc.ChainNotifier,
Store: sweeperStore,
MaxInputsPerTx: sweep.DefaultMaxInputsPerTx,
MaxFeeRate: cfg.Sweeper.MaxFeeRate,
Aggregator: aggregator,
Publisher: s.txPublisher,
})
s.utxoNursery = contractcourt.NewUtxoNursery(&contractcourt.NurseryConfig{

View File

@ -36,11 +36,6 @@ var (
// it is/has already been stopped.
ErrSweeperShuttingDown = errors.New("utxo sweeper shutting down")
// DefaultMaxSweepAttempts specifies the default maximum number of times
// an input is included in a publish attempt before giving up and
// returning an error to the caller.
DefaultMaxSweepAttempts = 10
// DefaultDeadlineDelta defines a default deadline delta (1 week) to be
// used when sweeping inputs with no deadline pressure.
//
@ -361,11 +356,6 @@ type UtxoSweeperConfig struct {
// created and published.
MaxInputsPerTx uint32
// MaxSweepAttempts specifies the maximum number of times an input is
// included in a publish attempt before giving up and returning an error
// to the caller.
MaxSweepAttempts int
// MaxFeeRate is the maximum fee rate allowed within the UtxoSweeper.
MaxFeeRate chainfee.SatPerVByte

View File

@ -159,12 +159,11 @@ func createSweeperTestContext(t *testing.T) *sweeperTestContext {
script[1] = 20
return script, nil
},
FeeEstimator: estimator,
MaxInputsPerTx: testMaxInputsPerTx,
MaxSweepAttempts: testMaxSweepAttempts,
MaxFeeRate: DefaultMaxFeeRate,
Aggregator: aggregator,
Publisher: mockBumper,
FeeEstimator: estimator,
MaxInputsPerTx: testMaxInputsPerTx,
MaxFeeRate: DefaultMaxFeeRate,
Aggregator: aggregator,
Publisher: mockBumper,
})
ctx.sweeper.Start()