|
|
|
@ -567,11 +567,12 @@ func (r *relayManager) handleNewServerEndpointRunLoop(newServerEndpoint newRelay
|
|
|
|
// We're ready to start a new handshake.
|
|
|
|
// We're ready to start a new handshake.
|
|
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
|
|
work := &relayHandshakeWork{
|
|
|
|
work := &relayHandshakeWork{
|
|
|
|
ep: newServerEndpoint.ep,
|
|
|
|
ep: newServerEndpoint.ep,
|
|
|
|
se: newServerEndpoint.se,
|
|
|
|
se: newServerEndpoint.se,
|
|
|
|
doneCh: make(chan relayEndpointHandshakeWorkDoneEvent, 1),
|
|
|
|
rxDiscoMsgCh: make(chan relayHandshakeDiscoMsgEvent),
|
|
|
|
ctx: ctx,
|
|
|
|
doneCh: make(chan relayEndpointHandshakeWorkDoneEvent, 1),
|
|
|
|
cancel: cancel,
|
|
|
|
ctx: ctx,
|
|
|
|
|
|
|
|
cancel: cancel,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if byServerDisco == nil {
|
|
|
|
if byServerDisco == nil {
|
|
|
|
byServerDisco = make(map[key.DiscoPublic]*relayHandshakeWork)
|
|
|
|
byServerDisco = make(map[key.DiscoPublic]*relayHandshakeWork)
|
|
|
|
|