diff --git a/cmd/tailscale/cli/ping.go b/cmd/tailscale/cli/ping.go index 25470aa69..74c5fdb77 100644 --- a/cmd/tailscale/cli/ping.go +++ b/cmd/tailscale/cli/ping.go @@ -64,6 +64,7 @@ var pingArgs struct { } func runPing(ctx context.Context, args []string) error { + fmt.Println("runPing") c, bc, ctx, cancel := connect(ctx) defer cancel() diff --git a/control/controlclient/direct.go b/control/controlclient/direct.go index 4e0622e96..74bfb7bad 100644 --- a/control/controlclient/direct.go +++ b/control/controlclient/direct.go @@ -874,8 +874,8 @@ func (c *Direct) sendMapRequest(ctx context.Context, maxPolls int, cb func(*netm c.expiry = &nm.Expiry c.mu.Unlock() - log.Println("MAPRESPONSE: ", resp.Node) - c.logf("MAPRESPONSE: %v", resp.Node) + // log.Println("MAPRESPONSE: ", resp.Node) + // c.logf("MAPRESPONSE: %v", resp.Node) cb(nm) } if ctx.Err() != nil { diff --git a/net/packet/tsmp.go b/net/packet/tsmp.go index 7ed382976..89275badb 100644 --- a/net/packet/tsmp.go +++ b/net/packet/tsmp.go @@ -14,6 +14,7 @@ import ( "encoding/binary" "errors" "fmt" + "log" "inet.af/netaddr" "tailscale.com/net/flowtrack" @@ -232,6 +233,7 @@ type TSMPPongReply struct { // AsTSMPPong returns pp as a TSMPPongReply and whether it is one. // The pong.IPHeader field is not populated. func (pp *Parsed) AsTSMPPong() (pong TSMPPongReply, ok bool) { + log.Println("TSMPPONG") if pp.IPProto != ipproto.TSMP { return } diff --git a/wgengine/magicsock/magicsock.go b/wgengine/magicsock/magicsock.go index b895b6b0a..c0933c40d 100644 --- a/wgengine/magicsock/magicsock.go +++ b/wgengine/magicsock/magicsock.go @@ -825,6 +825,7 @@ func (c *Conn) LastRecvActivityOfDisco(dk tailcfg.DiscoKey) time.Time { // Ping handles a "tailscale ping" CLI query. func (c *Conn) Ping(peer *tailcfg.Node, res *ipnstate.PingResult, cb func(*ipnstate.PingResult)) { + log.Println("CLIPING") c.mu.Lock() defer c.mu.Unlock() if c.privateKey.IsZero() { diff --git a/wgengine/userspace.go b/wgengine/userspace.go index b7b9ce36e..a85747405 100644 --- a/wgengine/userspace.go +++ b/wgengine/userspace.go @@ -1208,6 +1208,7 @@ func (e *userspaceEngine) sendTSMPPing(ip netaddr.IP, peer *tailcfg.Node, res *i log.Println("TIMECHECK") t0 := time.Now() e.setTSMPPongCallback(data, func(pong packet.TSMPPongReply) { + log.Println("Pong callback") expireTimer.Stop() d := time.Since(t0) res.LatencySeconds = d.Seconds() @@ -1224,7 +1225,7 @@ func (e *userspaceEngine) sendTSMPPing(ip netaddr.IP, peer *tailcfg.Node, res *i log.Println("PAYLOADCHECK") tsmpPing := packet.Generate(iph, tsmpPayload[:]) - log.Println("PACKETGEN", string(tsmpPing), *res) + log.Println("PACKETGEN", string(tsmpPing), *res, res.LatencySeconds) e.tundev.InjectOutbound(tsmpPing) log.Println("TUNDEVINJECT") } @@ -1309,7 +1310,7 @@ func (e *userspaceEngine) peerForIP(ip netaddr.IP) (n *tailcfg.Node, err error) // Check for exact matches before looking for subnet matches. var bestInNMPrefix netaddr.IPPrefix var bestInNM *tailcfg.Node - log.Println("Scan starting : ", nm.Peers, len(nm.Peers), nm.Addresses) + log.Println("Scan starting : ", len(nm.Peers), nm.Addresses) for _, p := range nm.Peers { log.Println("peerp", p.Addresses, p.AllowedIPs, p.ID) for _, a := range p.Addresses {