Method handleError

agentprotocol/server.go:290–314

(packet *Packet)

}

func (c *ForwardCtx) handleError(packet *Packet) {
	c.connMapMu.Lock()
	defer c.connMapMu.Unlock()
	conn, ok := c.connMap[packet.ConnectionId]
	if !ok {
		c.logger.Info(
			message.NewMessage(
				message.EAgentUnknownConnection,
				"Received error packet with unknown connection id %d",
				packet.ConnectionId,
			),
		)
		return
	}

	c.logger.Info(
		message.NewMessage(
			message.MAgentRemoteError,
			"Received error packet for connection %d from remote",
			packet.ConnectionId,
		),
	)

	_ = conn.CloseImm()
}

func (c *ForwardCtx) handleNewConnection(packet *Packet) {
	newConnectionPacket, err := c.unmarshalNewConnection(packet.Payload)