From d468a36d69d7850a883fd55e0ec9ef26d2ef73c6 Mon Sep 17 00:00:00 2001 From: Conner Fromknecht Date: Thu, 22 Feb 2018 14:28:31 -0800 Subject: [PATCH] peer: pass unsafe-replay to link config --- peer.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/peer.go b/peer.go index 964e0f32..52840f4d 100644 --- a/peer.go +++ b/peer.go @@ -402,7 +402,8 @@ func (p *peer) loadActiveChannels(chans []*channeldb.OpenChannel) error { time.NewTicker(50 * time.Millisecond)), FwdPkgGCTicker: htlcswitch.NewBatchTicker( time.NewTicker(time.Minute)), - BatchSize: 10, + BatchSize: 10, + UnsafeReplay: cfg.UnsafeReplay, } link := htlcswitch.NewChannelLink(linkCfg, lnChan, uint32(currentHeight)) @@ -1023,6 +1024,7 @@ func (p *peer) writeMessage(msg lnwire.Message) error { // NOTE: This method MUST be run as a goroutine. func (p *peer) writeHandler() { var exitErr error + out: for { select { @@ -1298,7 +1300,8 @@ out: time.NewTicker(50 * time.Millisecond)), FwdPkgGCTicker: htlcswitch.NewBatchTicker( time.NewTicker(time.Minute)), - BatchSize: 10, + BatchSize: 10, + UnsafeReplay: cfg.UnsafeReplay, } link := htlcswitch.NewChannelLink(linkConfig, newChan, uint32(currentHeight))