Method Probe

core/nylon_endpoints.go:20–57

(node state.NodeId, ep *state.NylonEndpoint, waitErr bool)

}

func (n *Nylon) Probe(node state.NodeId, ep *state.NylonEndpoint, waitErr bool) error {
	token := rand.Uint64()
	ping := &protocol.Ny{
		Type: &protocol.Ny_ProbeOp{
			ProbeOp: &protocol.Ny_Probe{
				Token:         token,
				ResponseToken: nil,
			},
		},
	}
	peer := n.Device.LookupPeer(device.NoisePublicKey(n.GetNode(node).PubKey))
	nep, err := ep.GetWgEndpoint(n.Device)
	if err != nil {
		return err
	}

	n.PingBuf.Set(token, EpPing{
		TimeSent: time.Now(),
	}, ttlcache.DefaultTTL)

	wg := sync.WaitGroup{}
	wg.Add(1)

	var sendErr error
	go func() {
		defer wg.Done()
		sendErr = n.SendNylon(ping, nep, peer)
		if sendErr != nil {
			n.PingBuf.Delete(token)
		}
	}()

	if waitErr {
		wg.Wait()
		return sendErr
	}
	return nil
}

func handleProbe(n *Nylon, pkt *protocol.Ny_Probe, endpoint conn.Endpoint, peer *device.Peer, node state.NodeId) {
	if pkt.ResponseToken == nil {