remove repetitive words

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

batch/interface.go

@@ -48,7 +48,7 @@ func LazyAdd() SchedulerOption {
 // set of Requests, executes them, and returns the error from the operation.
 type Scheduler interface {
 	// Execute schedules a Request for execution with the next available
-	// batch. This method blocks until the the underlying closure has been
+	// batch. This method blocks until the underlying closure has been
 	// run against the database. The resulting error is returned to the
 	// caller.
 	Execute(req *Request) error

cert/tls.go

@@ -57,7 +57,7 @@ func LoadCert(certPath, keyPath string) (tls.Certificate, *x509.Certificate,
 		return tls.Certificate{}, nil, err
 	}
 
-	// Now parse the the PEM block of the certificate into its x509 data
+	// Now parse the PEM block of the certificate into its x509 data
 	// structure so it can be examined in more detail.
 	x509Cert, err := x509.ParseCertificate(certData.Certificate[0])
 	if err != nil {
@@ -82,7 +82,7 @@ func LoadCertFromBytes(certBytes, keyBytes []byte) (tls.Certificate,
 		return tls.Certificate{}, nil, err
 	}
 
-	// Now parse the the PEM block of the certificate into its x509 data
+	// Now parse the PEM block of the certificate into its x509 data
 	// structure so it can be examined in more detail.
 	x509Cert, err := x509.ParseCertificate(certData.Certificate[0])
 	if err != nil {

cluster/etcd_elector.go

@@ -103,7 +103,7 @@ func (e *etcdLeaderElector) Leader(ctx context.Context) (string, error) {
 }
 
 // Campaign will start a new leader election campaign. Campaign will block until
-// the elector context is canceled or the the caller is elected as the leader.
+// the elector context is canceled or the caller is elected as the leader.
 func (e *etcdLeaderElector) Campaign(ctx context.Context) error {
 	return e.election.Campaign(ctx, e.id)
 }

htlcswitch/switch.go

@@ -1469,7 +1469,7 @@ func (s *Switch) failAddPacket(packet *htlcPacket, failure *LinkError) error {
 
 	log.Error(failure.Error())
 
-	// Create a failure packet for this htlc. The the full set of
+	// Create a failure packet for this htlc. The full set of
 	// information about the htlc failure is included so that they can
 	// be included in link failure notifications.
 	failPkt := &htlcPacket{

invoices/invoice_expiry_watcher.go

@@ -129,7 +129,7 @@ func NewInvoiceExpiryWatcher(clock clock.Clock,
 	}
 }
 
-// Start starts the the subscription handler and the main loop. Start() will
+// Start starts the subscription handler and the main loop. Start() will
 // return with error if InvoiceExpiryWatcher is already started. Start()
 // expects a cancellation function passed that will be use to cancel expired
 // invoices by their payment hash.

kvdb/etcd/stm.go

@@ -1170,7 +1170,7 @@ func (s *stm) Rollback() {
 }
 
 // rollback will reset the read and write sets. If clearReadSet is false we'll
-// only reset the the write set.
+// only reset the write set.
 func (s *stm) rollback(clearReadSet bool) {
 	if clearReadSet {
 		s.rset.clear()

lnrpc/signrpc/signer.proto

@@ -487,7 +487,7 @@ message MuSig2CombineKeysRequest {
     repeated bytes all_signer_pubkeys = 1;
 
     /*
-    A series of optional generic tweaks to be applied to the the aggregated
+    A series of optional generic tweaks to be applied to the aggregated
     public key.
     */
     repeated TweakDesc tweaks = 2;
@@ -551,7 +551,7 @@ message MuSig2SessionRequest {
     repeated bytes other_signer_public_nonces = 3;
 
     /*
-    A series of optional generic tweaks to be applied to the the aggregated
+    A series of optional generic tweaks to be applied to the aggregated
     public key.
     */
     repeated TweakDesc tweaks = 4;

lnrpc/signrpc/signer.swagger.json

@@ -509,7 +509,7 @@
           "items": {
             "$ref": "#/definitions/signrpcTweakDesc"
           },
-          "description": "A series of optional generic tweaks to be applied to the the aggregated\npublic key."
+          "description": "A series of optional generic tweaks to be applied to the aggregated\npublic key."
         },
         "taproot_tweak": {
           "$ref": "#/definitions/signrpcTaprootTweakDesc",
@@ -627,7 +627,7 @@
           "items": {
             "$ref": "#/definitions/signrpcTweakDesc"
           },
-          "description": "A series of optional generic tweaks to be applied to the the aggregated\npublic key."
+          "description": "A series of optional generic tweaks to be applied to the aggregated\npublic key."
         },
         "taproot_tweak": {
           "$ref": "#/definitions/signrpcTaprootTweakDesc",

lnwallet/chainfee/rates.go

@@ -13,7 +13,7 @@ const (
 	FeePerKwFloor SatPerKWeight = 253
 
 	// AbsoluteFeePerKwFloor is the lowest fee rate in sat/kw of a
-	// transaction that we should ever _create_. This is the the equivalent
+	// transaction that we should ever _create_. This is the equivalent
 	// of 1 sat/byte in sat/kw.
 	AbsoluteFeePerKwFloor SatPerKWeight = 250
 )

lnwallet/chanfunding/coin_select.go

@@ -307,7 +307,7 @@ func CoinSelectSubtractFees(feeRate chainfee.SatPerKWeight, amt,
 	outputAmt := totalSat - requiredFeeNoChange
 	changeAmt := btcutil.Amount(0)
 
-	// If the the output is too small after subtracting the fee, the coin
+	// If the output is too small after subtracting the fee, the coin
 	// selection cannot be performed with an amount this small.
 	if outputAmt < dustLimit {
 		return nil, 0, 0, fmt.Errorf("output amount(%v) after "+

queue/priority_queue.go

@@ -29,7 +29,7 @@ func (pq priorityQueue) Swap(i, j int) {
 	pq[i], pq[j] = pq[j], pq[i]
 }
 
-// Push adds a new item the the priorityQueue.
+// Push adds a new item the priorityQueue.
 func (pq *priorityQueue) Push(x interface{}) {
 	item := x.(PriorityQueueItem)
 	*pq = append(*pq, item)

sample-lnd.conf

@@ -1205,7 +1205,7 @@
 ; `Payment_In_FLIGHT` will be sent for compatibility concerns.
 ; routerrpc.usestatusinitiated=false
 
-; Defines the the maximum duration that the probing fee estimation is allowed to
+; Defines the maximum duration that the probing fee estimation is allowed to
 ; take.
 ; routerrpc.fee-estimation-timeout=1m
 

sweep/sweeper.go

@@ -292,7 +292,7 @@ type UtxoSweeperConfig struct {
 	// sweeps, how many blocks to wait before retrying to sweep.
 	NextAttemptDeltaFunc func(int) int32
 
-	// MaxFeeRate is the the maximum fee rate allowed within the
+	// MaxFeeRate is the maximum fee rate allowed within the
 	// UtxoSweeper.
 	MaxFeeRate chainfee.SatPerVByte
 
@@ -794,7 +794,7 @@ func (s *UtxoSweeper) createInputClusters() []inputCluster {
 	// if the locktime is equal.
 	lockTimeClusters, nonLockTimeInputs := s.clusterByLockTime(inputs)
 
-	// Cluster the the remaining inputs by sweep fee rate.
+	// Cluster the remaining inputs by sweep fee rate.
 	feeClusters := s.clusterBySweepFeeRate(nonLockTimeInputs)
 
 	// Since the inputs that we clustered by fee rate don't commit to a
@@ -1481,7 +1481,7 @@ 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.
+// ListSweeps returns a list of the sweeps recorded by the sweep store.
 func (s *UtxoSweeper) ListSweeps() ([]chainhash.Hash, error) {
 	return s.cfg.Store.ListSweeps()
 }

watchtower/wtserver/server.go

@@ -33,7 +33,7 @@ type Config struct {
 	// storing state updates.
 	DB DB
 
-	// NodeKeyECDH is the the ECDH capable wrapper of the key to be used in
+	// NodeKeyECDH is the ECDH capable wrapper of the key to be used in
 	// accepting new brontide connections.
 	NodeKeyECDH keychain.SingleKeyECDH