diff --git a/htlcswitch/link.go b/htlcswitch/link.go index 99b758ce9..9f2cfc494 100644 --- a/htlcswitch/link.go +++ b/htlcswitch/link.go @@ -1882,7 +1882,7 @@ func (l *channelLink) handleUpstreamMsg(msg lnwire.Message) { // If both commitment chains are fully synced from our PoV, // then we don't need to reply with a signature as both sides // already have a commitment with the latest accepted. - if !l.channel.OweCommitment(true) { + if !l.channel.OweCommitment() { return } @@ -1967,7 +1967,7 @@ func (l *channelLink) handleUpstreamMsg(msg lnwire.Message) { // processRemoteAdds. Also in case there are no local updates, // but there are still remote updates that are not in the remote // commit tx yet, send out an update. - if l.channel.OweCommitment(true) { + if l.channel.OweCommitment() { if !l.updateCommitTxOrFail() { return } diff --git a/lnwallet/channel.go b/lnwallet/channel.go index 63cd9a36a..30b1501ec 100644 --- a/lnwallet/channel.go +++ b/lnwallet/channel.go @@ -3825,7 +3825,7 @@ func (lc *LightningChannel) ProcessChanSyncMsg( // but died before the signature was sent. We re-transmit our // revocation, but also initiate a state transition to re-sync // them. - if lc.OweCommitment(true) { + if lc.OweCommitment() { commitSig, htlcSigs, _, err := lc.SignNextCommitment() switch { @@ -4539,11 +4539,11 @@ func (lc *LightningChannel) IsChannelClean() bool { // out a commitment signature because there are outstanding local updates and/or // updates in the local commit tx that aren't reflected in the remote commit tx // yet. -func (lc *LightningChannel) OweCommitment(local bool) bool { +func (lc *LightningChannel) OweCommitment() bool { lc.RLock() defer lc.RUnlock() - return lc.oweCommitment(local) + return lc.oweCommitment(true) } // oweCommitment is the internal version of OweCommitment. This function expects