Skip to content

Commit

Permalink
Merge pull request #3090 from cfromknecht/range-loop-fixes
Browse files Browse the repository at this point in the history
utxonursery+chanbackup: fix range loop binding bugs
  • Loading branch information
Roasbeef committed May 17, 2019
2 parents 30cb667 + 17ab813 commit f20ab2f
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 8 deletions.
4 changes: 2 additions & 2 deletions chanbackup/pubsub.go
Expand Up @@ -230,10 +230,10 @@ func (s *SubSwapper) backupUpdater() {

// For all closed channels, we'll remove the prior
// backup state.
for _, closedChan := range chanUpdate.ClosedChans {
for i, closedChan := range chanUpdate.ClosedChans {
log.Debugf("Removing channel %v from backup "+
"state", newLogClosure(func() string {
return closedChan.String()
return chanUpdate.ClosedChans[i].String()
}))

delete(s.backupState, closedChan)
Expand Down
4 changes: 2 additions & 2 deletions chanbackup/recover.go
Expand Up @@ -42,7 +42,7 @@ type PeerConnector interface {
func Recover(backups []Single, restorer ChannelRestorer,
peerConnector PeerConnector) error {

for _, backup := range backups {
for i, backup := range backups {
log.Infof("Restoring ChannelPoint(%v) to disk: ",
backup.FundingOutpoint)

Expand All @@ -55,7 +55,7 @@ func Recover(backups []Single, restorer ChannelRestorer,
"restore ChannelPoint(%v)",
backup.RemoteNodePub.SerializeCompressed(),
newLogClosure(func() string {
return spew.Sdump(backup.Addresses)
return spew.Sdump(backups[i].Addresses)
}), backup.FundingOutpoint)

err = peerConnector.ConnectPeer(
Expand Down
10 changes: 6 additions & 4 deletions utxonursery.go
Expand Up @@ -455,9 +455,11 @@ func (u *utxoNursery) IncubateOutputs(chanPoint wire.OutPoint,
// We'll examine all the baby outputs just inserted into the database,
// if the output has already expired, then we'll *immediately* sweep
// it. This may happen if the caller raced a block to call this method.
for _, babyOutput := range babyOutputs {
for i, babyOutput := range babyOutputs {
if uint32(bestHeight) >= babyOutput.expiry {
err = u.sweepCribOutput(babyOutput.expiry, &babyOutput)
err = u.sweepCribOutput(
babyOutput.expiry, &babyOutputs[i],
)
if err != nil {
return err
}
Expand All @@ -468,9 +470,9 @@ func (u *utxoNursery) IncubateOutputs(chanPoint wire.OutPoint,
// confirmation notification that will transition it to the
// kindergarten bucket.
if len(kidOutputs) != 0 {
for _, kidOutput := range kidOutputs {
for i := range kidOutputs {
err := u.registerPreschoolConf(
&kidOutput, broadcastHeight,
&kidOutputs[i], broadcastHeight,
)
if err != nil {
return err
Expand Down

0 comments on commit f20ab2f

Please sign in to comment.