tap: tap,
terminator: make(chan struct{}),
}
- go peerReady(*ps)
+ go govpn.PeerTapProcessor(ps.peer, ps.tap, ps.terminator)
peersByIdLock.Lock()
kpLock.Lock()
delete(peers, addrPrev)
tap: tap,
terminator: make(chan struct{}, 1),
}
- go peerReady(*ps)
+ go govpn.PeerTapProcessor(ps.peer, ps.tap, ps.terminator)
peersLock.Lock()
peersByIdLock.Lock()
kpLock.Lock()