Method StartServerForward

agentprotocol/server.go:571–610

()

}

func (c *ForwardCtx) StartServerForward() (chan *Connection, error) {
	c.init()

	setupPacket := SetupPacket{
		ConnectionType: CONNECTION_TYPE_PORT_DIAL,
	}
	mar, err := cbor.Marshal(&setupPacket)
	if err != nil {
		c.logger.Error(message.Wrap(
			err,
			message.EAgentDecodingFailed,
			"Error marshalling setup packet",
		))
		return nil, err
	}

	packet := Packet{
		Type:    PACKET_SETUP,
		Payload: mar,
	}
	err = c.writePacket(&packet)
	if err != nil {
		return nil, err
	}

	resp := Packet{}
	err = c.decoder.Decode(&resp)
	if err != nil {
		return nil, err
	}
	if resp.Type == PACKET_ERROR {
		return nil, fmt.Errorf("received error packet from client")
	} else if resp.Type != PACKET_SUCCESS {
		return nil, fmt.Errorf("received invalid packet from client")
	}

	go c.handleBackend()

	return c.connectionChannel, nil
}

func (c *ForwardCtx) startReverseForwardingClient(setupPacket SetupPacket) (chan *Connection, error) {
	c.init()