Method handleSuccess

agentprotocol/server.go:260–288

(packet *Packet)

}

func (c *ForwardCtx) handleSuccess(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 success packet with unknown connection id %d",
				packet.ConnectionId,
			),
		)
		return
	}

	switch conn.state {
	case CONNECTION_STATE_WAITINIT:
		conn.setState(CONNECTION_STATE_STARTED)
	case CONNECTION_STATE_WAITCLOSE:
		_ = conn.CloseImm()
	default:
		c.logger.Warning(
			message.NewMessage(
				message.EAgentConnectionInvalidState,
				"Received success packet for agent connection in non-wait state",
			),
		)
	}
}

func (c *ForwardCtx) handleError(packet *Packet) {
	c.connMapMu.Lock()