diff --git a/fundingmanager.go b/fundingmanager.go index 95e6464e..f36183c4 100644 --- a/fundingmanager.go +++ b/fundingmanager.go @@ -3233,34 +3233,6 @@ func (f *fundingManager) handleInitFundingMsg(msg *initFundingMsg) { } } -// waitUntilChannelOpen is designed to prevent other lnd subsystems from -// sending new update messages to a channel before the channel is fully -// opened. -func (f *fundingManager) waitUntilChannelOpen(targetChan lnwire.ChannelID, - quit <-chan struct{}) error { - - f.barrierMtx.RLock() - barrier, ok := f.newChanBarriers[targetChan] - f.barrierMtx.RUnlock() - if ok { - fndgLog.Tracef("waiting for chan barrier signal for ChanID(%v)", - targetChan) - - select { - case <-barrier: - case <-quit: - return ErrFundingManagerShuttingDown - case <-f.quit: - return ErrFundingManagerShuttingDown - } - - fndgLog.Tracef("barrier for ChanID(%v) closed", targetChan) - return nil - } - - return nil -} - // processFundingError sends a message to the fundingManager allowing it to // process the occurred generic error. func (f *fundingManager) processFundingError(err *lnwire.Error,