(p *peer, node *proto.Node)
| 343 | } |
| 344 | |
| 345 | func (c *core) nodeUpdateLocked(p *peer, node *proto.Node) (err error) { |
| 346 | c.logger.Debug(context.Background(), "processing node update", |
| 347 | slog.F("peer_id", p.id), |
| 348 | slog.F("node", node.String())) |
| 349 | |
| 350 | p.node = node |
| 351 | c.updateTunnelPeersLocked(p.id, node, proto.CoordinateResponse_PeerUpdate_NODE, "node update") |
| 352 | return nil |
| 353 | } |
| 354 | |
| 355 | func (c *core) updateTunnelPeersLocked(id uuid.UUID, n *proto.Node, k proto.CoordinateResponse_PeerUpdate_Kind, reason string) { |
| 356 | tp := c.tunnels.findTunnelPeers(id) |
no test coverage detected