Method handleBackend

agentprotocol/server.go:364–402

()

}

func (c *ForwardCtx) handleBackend() {
	for {
		packet := Packet{}
		err := c.decoder.Decode(&packet)
		if err != nil {
			c.logger.Error(message.Wrap(
				err,
				message.MSSHConnected,
				"Error decoding packet from backend",
			))
			return
		}
		switch packet.Type {
		case PACKET_DATA:
			c.handleData(&packet)
		case PACKET_CLOSE_CONNECTION:
			c.handleClose(&packet)
		case PACKET_SUCCESS:
			c.handleSuccess(&packet)
		case PACKET_ERROR:
			c.handleError(&packet)
		case PACKET_NEW_CONNECTION:
			c.handleNewConnection(&packet)
		case PACKET_NO_MORE_CONNECTIONS:
			if !c.stopped {
				c.stopped = true
				close(c.connectionChannel)
			}
		default:
			c.logger.Warning(
				message.NewMessage(
					message.EAgentUnknownPacket,
					"Received unknown packet type %d from agent",
					packet.Type,
				),
			)
		}
	}
}

func (c *ForwardCtx) unmarshalSetup(payload []byte) (SetupPacket, error) {
	packet := SetupPacket{}