[netwatch.git] / net / rfb.c

#include <stdint.h>
#include <minilib.h>
#include <output.h>
#include <fb.h>
#include <keyboard.h>

#include "lwip/tcp.h"
#include "lwip/stats.h"

#include "rfb.h"

#define SET_PIXEL_FORMAT	0
#define SET_ENCODINGS		2
#define FB_UPDATE_REQUEST	3
#define KEY_EVENT		4
#define POINTER_EVENT		5
#define CLIENT_CUT_TEXT		6

#define RFB_BUF_SIZE	512

#define SCREEN_CHUNKS_X 8
#define SCREEN_CHUNKS_Y 8

struct pixel_format {
	uint8_t bpp;
	uint8_t depth;
	uint8_t big_endian;
	uint8_t true_color;
	uint16_t red_max;
	uint16_t green_max;
	uint16_t blue_max;
	uint8_t red_shift;
	uint8_t green_shift;
	uint8_t blue_shift;
	uint8_t padding[3];
};

struct server_init_message {
	uint16_t fb_width;
	uint16_t fb_height;
	struct pixel_format fmt;
	uint32_t name_length;
	char name_string[8];
};

struct fb_update_req {
	uint8_t msgtype;
	uint8_t incremental;
	uint16_t xpos;
	uint16_t ypos;
	uint16_t width;
	uint16_t height;
};

struct set_encs_req {
	uint8_t msgtype;
	uint8_t padding;
	uint16_t num;
	int32_t encodings[];
};

struct key_event_pkt {
	uint8_t msgtype;
	uint8_t downflag;
	uint8_t pad[2];
	uint32_t keysym;
};

struct pointer_event_pkt {
	uint8_t msgtype;
	uint8_t button_mask;
	uint16_t x;
	uint16_t y;
};

struct text_event_pkt {
	uint8_t msgtype;
	uint8_t padding[3];
	uint32_t length;
	char text[];
};

struct update_header {
	uint8_t msgtype;
	uint8_t padding;
	uint16_t nrects;
	uint16_t xpos;
	uint16_t ypos;
	uint16_t width;
	uint16_t height;
	int32_t enctype;
};

struct rfb_state {
	enum {
		ST_BEGIN = 0,
		ST_CLIENTINIT,
		ST_MAIN
	} state;
	int version;
	int encs_remaining;

	char data[RFB_BUF_SIZE];
	int readpos;
	int writepos;

	char next_update_incremental;
	char update_requested;

	struct fb_update_req client_interest_area;

	enum {
		SST_IDLE = 0,
		SST_HEADER,
		SST_DATA
	} send_state;

	uint32_t checksums[SCREEN_CHUNKS_X][SCREEN_CHUNKS_Y];

	uint32_t chunk_xnum;
	uint32_t chunk_ynum;
	uint32_t chunk_xpos;
	uint32_t chunk_ypos;
	uint32_t chunk_width;
	uint32_t chunk_height;

	uint32_t chunk_bytes_sent;
	
	uint32_t chunk_checksum;

	int chunk_actually_sent;
	int try_in_a_bit;

	char * blockbuf;
};

static struct server_init_message server_info;

static void init_server_info() {
	server_info.name_length = htonl(8);
	memcpy(server_info.name_string, "NetWatch", 8);
}

static void update_server_info() {
	if (fb != NULL) {
		outputf("RFB: setting fmt %d", fb->curmode.format);
		server_info.fb_width = htons(fb->curmode.xres);
		server_info.fb_height = htons(fb->curmode.yres);
		switch (fb->curmode.format) {
		case FB_RGB888:
			server_info.fmt.bpp = 32;
			server_info.fmt.depth = 24;
			server_info.fmt.big_endian = 0;
			server_info.fmt.true_color = 1;
			server_info.fmt.red_max = htons(255);
			server_info.fmt.green_max = htons(255);
			server_info.fmt.blue_max = htons(255);
			server_info.fmt.red_shift = 0;
			server_info.fmt.green_shift = 8;
			server_info.fmt.blue_shift = 16;
			break;
		default:
			outputf("RFB: unknown fb fmt %d", fb->curmode.format);
			break;
		}
	} else {
		outputf("RFB: fb null");
	}
}

static int advance_chunk(struct rfb_state *state) {

	state->chunk_xnum += 1;

	if (state->chunk_xnum == SCREEN_CHUNKS_X) {
		state->chunk_ynum += 1;
		state->chunk_xnum = 0;
	}

	if (state->chunk_ynum == SCREEN_CHUNKS_Y) {
		state->chunk_ynum = 0;
		state->send_state = SST_IDLE;
		if (!(state->chunk_actually_sent))
			state->try_in_a_bit = 2;
			return 1;
	}

	return 0;
}

static int ceildiv(int a, int b) {
	int res = a / b;
	if (a % b != 0) {
		res++;
	}
	return res;
}
	
static void send_fsm(struct tcp_pcb *pcb, struct rfb_state *state) {
	struct update_header hdr;
	int bytes_left;
	int totaldim;
	err_t err;

	while(1) {

		switch (state->send_state) {

		case SST_IDLE:
			/* Nothing to do */

			if (state->update_requested) {
				outputf("RFB send: update requested");
				state->update_requested = 0;
				state->chunk_actually_sent = 0;
				state->send_state = SST_HEADER;
			} else {
				return;
			}
	
			/* FALL THROUGH to SST_HEADER */

		case SST_HEADER:

			/* Calculate the width and height for this chunk, remembering
			 * that if SCREEN_CHUNKS_[XY] do not evenly divide the width and
			 * height, we may need to have shorter chunks at the edge of
			 * the screen. */

			state->chunk_width = ceildiv(fb->curmode.xres, SCREEN_CHUNKS_X);
			state->chunk_xpos = state->chunk_width * state->chunk_xnum;
			totaldim = state->chunk_width * (state->chunk_xnum + 1);
			if (totaldim > fb->curmode.xres) {
				state->chunk_width -= (totaldim - fb->curmode.xres);
			}

			state->chunk_height = ceildiv(fb->curmode.yres, SCREEN_CHUNKS_Y);
			state->chunk_ypos = state->chunk_height
						 * state->chunk_ynum;
			totaldim = state->chunk_height * (state->chunk_ynum + 1);
			if (totaldim > fb->curmode.yres) {
				state->chunk_height -= (totaldim - fb->curmode.yres);
			}

			/* Do we _actually_ need to send this chunk? */
			if (fb->checksum_rect) {
				state->chunk_checksum = fb->checksum_rect(state->chunk_xpos, state->chunk_ypos,
								state->chunk_width, state->chunk_height);

				if (state->chunk_checksum == state->checksums[state->chunk_xnum][state->chunk_ynum]) {
					if (advance_chunk(state))
						return;
					continue;
				}
				/* Checksum gets set in data block, AFTER the data has been sent. */
			}

			outputf("actually sent");
			state->chunk_actually_sent = 1;

			/* Send a header */
			hdr.msgtype = 0;
			state->chunk_bytes_sent = 0;
			hdr.nrects = htons(1);
			hdr.xpos = htons(state->chunk_xpos);
			hdr.ypos = htons(state->chunk_ypos);
			hdr.width = htons(state->chunk_width);
			hdr.height= htons(state->chunk_height);
			hdr.enctype = htonl(0);

			err = tcp_write(pcb, &hdr, sizeof(hdr), TCP_WRITE_FLAG_COPY);

			if (err != ERR_OK) {
				if (err != ERR_MEM)
					outputf("RFB: header send error %d", err);

				/* Try again later. */
				return;
			}

			state->send_state = SST_DATA;

			/* Snag the data. */
			fb->copy_pixels(state->blockbuf,
				state->chunk_xpos, state->chunk_ypos,
				state->chunk_width, state->chunk_height);

			/* FALL THROUGH to SST_DATA */

		case SST_DATA:

			bytes_left = 4 * state->chunk_width * state->chunk_height - state->chunk_bytes_sent;

			if (bytes_left == 0) {
				state->send_state = SST_HEADER;
				state->checksums[state->chunk_xnum][state->chunk_ynum] = state->chunk_checksum;
				if (advance_chunk(state))
					return;
				break;
			}

			/* That's enough. */
			if (bytes_left > 1400) {
				bytes_left = 1400;
			}

			err = tcp_write(pcb, state->blockbuf + state->chunk_bytes_sent,
				bytes_left, TCP_WRITE_FLAG_COPY);

			if (err == ERR_OK) {
				state->chunk_bytes_sent += bytes_left;
			} else {
				if (err != ERR_MEM)
					outputf("RFB: send error %d", err);

				return;
			}
				
			if (tcp_sndbuf(pcb) == 0) {
				return;
			}
		}
	}
	
	if (tcp_output(pcb) != ERR_OK)
		outputf("RFB: tcp_output bailed in send_fsm?");
}

static err_t rfb_sent(void *arg, struct tcp_pcb *pcb, uint16_t len) {
	struct rfb_state *state = arg;
	send_fsm(pcb, state);
	return ERR_OK;
}

static err_t rfb_poll(void *arg, struct tcp_pcb *pcb) {
	struct rfb_state *state = arg;
	send_fsm(pcb, state);
	if (state->try_in_a_bit) {
		state->try_in_a_bit--;
		if (!(state->try_in_a_bit)) {
			state->update_requested = 1;
		}
	}
/*
	stats_display();
*/
	return ERR_OK;
}

static void close_conn(struct tcp_pcb *pcb, struct rfb_state *state) {
	outputf("close_conn: bailing");
	tcp_arg(pcb, NULL);
	tcp_sent(pcb, NULL);
	tcp_recv(pcb, NULL);
	mem_free(state);
	mem_free(state->blockbuf);
	tcp_close(pcb);
	outputf("close_conn: done");
}

enum fsm_result {
	NEEDMORE,
	OK,
	FAIL
};

static enum fsm_result recv_fsm(struct tcp_pcb *pcb, struct rfb_state *state) {
	int i;
	int pktsize;

	outputf("RFB FSM: st %d rp %d wp %d", state->state, state->readpos,
		state->writepos);

	switch(state->state) {
	case ST_BEGIN:
		if (state->writepos < 12) return NEEDMORE;

		if (!strncmp(state->data, "RFB 003.003\n", 12)) {
			state->version = 3;
		} else if (!strncmp(state->data, "RFB 003.005\n", 12)) {
			/* Spec states that "RFB 003.005", an incorrect value,
			 * should be treated by the server as 3.3. */
			state->version = 3;
		} else if (!strncmp(state->data, "RFB 003.007\n", 12)) {
			state->version = 7;
		} else if (!strncmp(state->data, "RFB 003.008\n", 12)) {
			state->version = 8;
		} else {
			outputf("RFB: Negotiation fail");
			return FAIL;
		}

		outputf("RFB: Negotiated v3.%d", state->version);

		state->readpos += 12;
		state->state = ST_CLIENTINIT;

		/* We support one security type, currently "none".
		 * Send that and SecurityResult. */
		if (state->version >= 7) {
			tcp_write(pcb, "\x01\x01\x00\x00\x00\x00", 6, 0);
		} else {
			tcp_write(pcb, "\x01\x00\x00\x00\x00", 5, 0);
		}

		tcp_output(pcb);

		return OK;

	case ST_CLIENTINIT:
		if (state->version >= 7) {
			/* Ignore the security type and ClientInit */
			if (state->writepos < 2) return NEEDMORE;
			state->readpos += 2;
		} else {
			/* Just ClientInit */
			if (state->writepos < 1) return NEEDMORE;
			state->readpos += 1;
		}

		state->state = ST_MAIN;

		outputf("RFB: Sending server info", state->version);
		tcp_write(pcb, &server_info, sizeof(server_info), TCP_WRITE_FLAG_COPY);
		tcp_output(pcb);

		return OK;

	case ST_MAIN:
		if (state->writepos < 1) return NEEDMORE;

		outputf("RFB: cmd %d", state->data[0]);
		switch (state->data[0]) {

		case SET_PIXEL_FORMAT:
			/* SetPixelFormat */
			if (state->writepos < (sizeof(struct pixel_format) + 4))
				return NEEDMORE;
			outputf("RFB: SetPixelFormat");
/*
			struct pixel_format * new_fmt =
				(struct pixel_format *)(&state->data[4]);
*/
			/* XXX ... */

			state->readpos += sizeof(struct pixel_format) + 4;
			return OK;

		case SET_ENCODINGS:
			if (state->writepos < 4) return NEEDMORE;

			struct set_encs_req * req = (struct set_encs_req *)state->data;

			pktsize = sizeof(struct set_encs_req) + (4 * ntohs(req->num));

			outputf("RFB: SetEncodings [%d]", ntohs(req->num));
			if (state->writepos < pktsize) return NEEDMORE;

			for (i = 0; i < ntohs(req->num); i++) {
				outputf("RFB: Encoding: %d", ntohl(req->encodings[i]));
				/* XXX ... */
			}

			state->readpos += pktsize;
			return OK;

		case FB_UPDATE_REQUEST:
			if (state->writepos < sizeof(struct fb_update_req))
				return NEEDMORE;
			outputf("RFB: UpdateRequest");

			state->update_requested = 1;
			memcpy(&state->client_interest_area, state->data,
			       sizeof(struct fb_update_req)); 

			state->readpos += sizeof(struct fb_update_req);
			return OK;

		case KEY_EVENT:
			if (state->writepos < sizeof(struct key_event_pkt))
				return NEEDMORE;

			struct key_event_pkt * p = (struct key_event_pkt *)state->data;

			outputf("RFB: Key: %d (%c)", htonl(p->keysym), (htonl(p->keysym) & 0xFF));
			kbd_inject_keysym(htonl(p->keysym), p->downflag);

			state->readpos += sizeof(struct key_event_pkt);
			return OK;

		case POINTER_EVENT:
			if (state->writepos < sizeof(struct pointer_event_pkt))
				return NEEDMORE;
			outputf("RFB: Pointer");

			/* XXX stub */

			state->readpos += sizeof(struct pointer_event_pkt);
			return OK;

		case CLIENT_CUT_TEXT:
			if (state->writepos < sizeof(struct text_event_pkt))
				return NEEDMORE;
			outputf("RFB: Cut Text");

			struct text_event_pkt * pkt =
				(struct text_event_pkt *)state->data;

			if (state->writepos < sizeof(struct text_event_pkt)
					      + pkt->length)
				return NEEDMORE;

			/* XXX stub */

			state->readpos += sizeof(struct text_event_pkt)
					  + pkt->length;
			return OK;

		default:
			outputf("RFB: Bad command: %d", state->data[0]);
			return FAIL;
		}
	default:
		outputf("RFB: Bad state");
		return FAIL;
	}
}

static err_t rfb_recv(void *arg, struct tcp_pcb *pcb,
		      struct pbuf *p, err_t err) {
	struct rfb_state *state = arg;
	uint16_t copylen;

	if (state == NULL) 

	if (err != ERR_OK) {
		outputf("RFB: recv err %d", err);
		/* FIXME do something better here? */
		return ERR_OK;
	}

	if (p == NULL) {
		outputf("RFB: Connection closed");
		close_conn(pcb, state);
		return ERR_OK;
	}

	if (p->tot_len > (RFB_BUF_SIZE - state->writepos)) {
		/* Overflow! */
		outputf("RFB: Overflow!");
		close_conn(pcb, state);
		return ERR_OK;
	}

	copylen = pbuf_copy_partial(p, state->data + state->writepos, p->tot_len, 0);
	outputf("RFB: Processing %d, wp %d, cp %d", p->tot_len, state->writepos, copylen);
	state->writepos += p->tot_len;

	tcp_recved(pcb, p->tot_len);
	pbuf_free(p);

	while (1) {
		switch (recv_fsm(pcb, state)) {
		case NEEDMORE:
			outputf("RFB FSM: blocking");
			goto doneprocessing;

		case OK:
			outputf("RFB FSM: ok");

			if (state->readpos == state->writepos) {
				state->readpos = 0;
				state->writepos = 0;
				goto doneprocessing;
			} else {
				memmove(state->data,
					state->data + state->readpos,
					state->writepos - state->readpos);
				state->writepos -= state->readpos;
				state->readpos = 0;
			}
			break;
		case FAIL:
			/* Shit */
			outputf("RFB: Protocol error");
			close_conn(pcb, state);
			return ERR_OK;
		}
	}

doneprocessing:

	/* Kick off a send. */
	if (state->send_state == SST_IDLE && state->update_requested) {
		send_fsm(pcb, state);
	}

	return ERR_OK;
}	
		
static err_t rfb_accept(void *arg, struct tcp_pcb *pcb, err_t err) {
	struct rfb_state *state;
	char * blockbuf;

	LWIP_UNUSED_ARG(arg);
	LWIP_UNUSED_ARG(err);

	state = (struct rfb_state *)mem_malloc(sizeof(struct rfb_state));

	if (!state)
	{
		outputf("rfb_accept: out of memory\n");
		return ERR_MEM;
	}

	memset(state, 0, sizeof(struct rfb_state));

	blockbuf = mem_malloc(ceildiv(fb->curmode.xres, SCREEN_CHUNKS_X)
	                    * ceildiv(fb->curmode.yres, SCREEN_CHUNKS_Y) * 4);

	if (!blockbuf)
	{
		outputf("rfb_accept: out of memory allocating blockbuf\n");
		mem_free(state);
		return ERR_MEM;
	}

	state->blockbuf = blockbuf;
	state->state = ST_BEGIN;
	state->send_state = SST_IDLE;

	/* XXX: update_server_info() should be called from the 64ms timer, and deal
	 * with screen resizes appropriately. */
	update_server_info();

	tcp_arg(pcb, state);
	tcp_recv(pcb, rfb_recv);
	tcp_sent(pcb, rfb_sent);
	tcp_poll(pcb, rfb_poll, 1);
/*
	tcp_err(pcb, rfb_err);
*/
	tcp_write(pcb, "RFB 003.008\n", 12, 0);
	tcp_output(pcb);

	return ERR_OK;
}

void rfb_init() {
	struct tcp_pcb *pcb;

	init_server_info();

	pcb = tcp_new();
	tcp_bind(pcb, IP_ADDR_ANY, RFB_PORT);
	pcb = tcp_listen(pcb);
	tcp_accept(pcb, rfb_accept);
}
Commit	Line	Data
7da36fbd JP	1	#include <stdint.h>
	2	#include <minilib.h>
	3	#include <output.h>
	4	#include <fb.h>
33e49b2e	5	#include <keyboard.h>
ec949d20	6
7da36fbd	7	#include "lwip/tcp.h"
b59a6e50	8	#include "lwip/stats.h"
7da36fbd JP	9
	10	#include "rfb.h"
	11
	12	#define SET_PIXEL_FORMAT 0
	13	#define SET_ENCODINGS 2
	14	#define FB_UPDATE_REQUEST 3
	15	#define KEY_EVENT 4
	16	#define POINTER_EVENT 5
	17	#define CLIENT_CUT_TEXT 6
	18
99a4c846	19	#define RFB_BUF_SIZE 512
7da36fbd	20
ec5f9ca5	21	#define SCREEN_CHUNKS_X 8
b496c2b1 JP	22	#define SCREEN_CHUNKS_Y 8
b496c2b1 JP	23
7da36fbd JP	24	struct pixel_format {
	25	uint8_t bpp;
	26	uint8_t depth;
	27	uint8_t big_endian;
	28	uint8_t true_color;
	29	uint16_t red_max;
	30	uint16_t green_max;
	31	uint16_t blue_max;
	32	uint8_t red_shift;
	33	uint8_t green_shift;
	34	uint8_t blue_shift;
	35	uint8_t padding[3];
	36	};
	37
	38	struct server_init_message {
	39	uint16_t fb_width;
	40	uint16_t fb_height;
	41	struct pixel_format fmt;
	42	uint32_t name_length;
	43	char name_string[8];
	44	};
	45
	46	struct fb_update_req {
	47	uint8_t msgtype;
	48	uint8_t incremental;
	49	uint16_t xpos;
	50	uint16_t ypos;
	51	uint16_t width;
	52	uint16_t height;
	53	};
	54
	55	struct set_encs_req {
	56	uint8_t msgtype;
	57	uint8_t padding;
	58	uint16_t num;
	59	int32_t encodings[];
	60	};
	61
	62	struct key_event_pkt {
	63	uint8_t msgtype;
	64	uint8_t downflag;
	65	uint8_t pad[2];
	66	uint32_t keysym;
	67	};
	68
	69	struct pointer_event_pkt {
	70	uint8_t msgtype;
	71	uint8_t button_mask;
	72	uint16_t x;
	73	uint16_t y;
	74	};
	75
	76	struct text_event_pkt {
	77	uint8_t msgtype;
	78	uint8_t padding[3];
	79	uint32_t length;
	80	char text[];
	81	};
	82
8ceb0515 JP	83	struct update_header {
	84	uint8_t msgtype;
	85	uint8_t padding;
	86	uint16_t nrects;
	87	uint16_t xpos;
	88	uint16_t ypos;
	89	uint16_t width;
	90	uint16_t height;
	91	int32_t enctype;
	92	};
	93
7da36fbd JP	94	struct rfb_state {
7da36fbd JP	95	enum {
751f179d	96	ST_BEGIN = 0,
7da36fbd JP	97	ST_CLIENTINIT,
	98	ST_MAIN
	99	} state;
	100	int version;
	101	int encs_remaining;
	102
	103	char data[RFB_BUF_SIZE];
	104	int readpos;
	105	int writepos;
	106
	107	char next_update_incremental;
8ceb0515 JP	108	char update_requested;
8ceb0515 JP	109
7da36fbd JP	110	struct fb_update_req client_interest_area;
7da36fbd JP	111
8ceb0515	112	enum {
751f179d	113	SST_IDLE = 0,
d9b82f8c JP	114	SST_HEADER,
d9b82f8c JP	115	SST_DATA
8ceb0515 JP	116	} send_state;
8ceb0515 JP	117
99a4c846	118	uint32_t checksums[SCREEN_CHUNKS_X][SCREEN_CHUNKS_Y];
b496c2b1 JP	119
	120	uint32_t chunk_xnum;
	121	uint32_t chunk_ynum;
	122	uint32_t chunk_xpos;
	123	uint32_t chunk_ypos;
	124	uint32_t chunk_width;
	125	uint32_t chunk_height;
	126
ec5f9ca5	127	uint32_t chunk_bytes_sent;
d136cf4c JW	128
d136cf4c JW	129	uint32_t chunk_checksum;
d9b82f8c	130
751f179d JP	131	int chunk_actually_sent;
751f179d JP	132	int try_in_a_bit;
ec5f9ca5 JP	133
ec5f9ca5 JP	134	char * blockbuf;
7da36fbd JP	135	};
	136
	137	static struct server_init_message server_info;
	138
	139	static void init_server_info() {
80726808	140	server_info.name_length = htonl(8);
7da36fbd JP	141	memcpy(server_info.name_string, "NetWatch", 8);
	142	}
	143
	144	static void update_server_info() {
	145	if (fb != NULL) {
80726808 JP	146	outputf("RFB: setting fmt %d", fb->curmode.format);
	147	server_info.fb_width = htons(fb->curmode.xres);
	148	server_info.fb_height = htons(fb->curmode.yres);
7da36fbd JP	149	switch (fb->curmode.format) {
	150	case FB_RGB888:
	151	server_info.fmt.bpp = 32;
	152	server_info.fmt.depth = 24;
	153	server_info.fmt.big_endian = 0;
	154	server_info.fmt.true_color = 1;
80726808 JP	155	server_info.fmt.red_max = htons(255);
	156	server_info.fmt.green_max = htons(255);
	157	server_info.fmt.blue_max = htons(255);
7da36fbd JP	158	server_info.fmt.red_shift = 0;
	159	server_info.fmt.green_shift = 8;
	160	server_info.fmt.blue_shift = 16;
	161	break;
	162	default:
	163	outputf("RFB: unknown fb fmt %d", fb->curmode.format);
	164	break;
	165	}
80726808 JP	166	} else {
80726808 JP	167	outputf("RFB: fb null");
7da36fbd JP	168	}
	169	}
	170
d9b82f8c JP	171	static int advance_chunk(struct rfb_state *state) {
	172
	173	state->chunk_xnum += 1;
	174
	175	if (state->chunk_xnum == SCREEN_CHUNKS_X) {
	176	state->chunk_ynum += 1;
	177	state->chunk_xnum = 0;
	178	}
	179
	180	if (state->chunk_ynum == SCREEN_CHUNKS_Y) {
	181	state->chunk_ynum = 0;
	182	state->send_state = SST_IDLE;
	183	if (!(state->chunk_actually_sent))
751f179d	184	state->try_in_a_bit = 2;
d9b82f8c JP	185	return 1;
	186	}
	187
	188	return 0;
	189	}
	190
ec5f9ca5 JP	191	static int ceildiv(int a, int b) {
	192	int res = a / b;
	193	if (a % b != 0) {
	194	res++;
	195	}
	196	return res;
	197	}
	198
8ceb0515 JP	199	static void send_fsm(struct tcp_pcb pcb, struct rfb_state state) {
8ceb0515 JP	200	struct update_header hdr;
ec5f9ca5	201	int bytes_left;
b496c2b1	202	int totaldim;
8ceb0515 JP	203	err_t err;
8ceb0515 JP	204
d9b82f8c	205	while(1) {
b496c2b1	206
d9b82f8c	207	switch (state->send_state) {
b496c2b1	208
d9b82f8c JP	209	case SST_IDLE:
d9b82f8c JP	210	/* Nothing to do */
8ceb0515	211
d9b82f8c JP	212	if (state->update_requested) {
	213	outputf("RFB send: update requested");
	214	state->update_requested = 0;
	215	state->chunk_actually_sent = 0;
	216	state->send_state = SST_HEADER;
	217	} else {
	218	return;
	219	}
	220
	221	/* FALL THROUGH to SST_HEADER */
	222
	223	case SST_HEADER:
	224
	225	/* Calculate the width and height for this chunk, remembering
	226	* that if SCREEN_CHUNKS_[XY] do not evenly divide the width and
	227	* height, we may need to have shorter chunks at the edge of
	228	* the screen. */
	229
ec5f9ca5	230	state->chunk_width = ceildiv(fb->curmode.xres, SCREEN_CHUNKS_X);
d9b82f8c JP	231	state->chunk_xpos = state->chunk_width * state->chunk_xnum;
	232	totaldim = state->chunk_width * (state->chunk_xnum + 1);
	233	if (totaldim > fb->curmode.xres) {
	234	state->chunk_width -= (totaldim - fb->curmode.xres);
	235	}
b496c2b1	236
ec5f9ca5	237	state->chunk_height = ceildiv(fb->curmode.yres, SCREEN_CHUNKS_Y);
d9b82f8c JP	238	state->chunk_ypos = state->chunk_height
	239	* state->chunk_ynum;
	240	totaldim = state->chunk_height * (state->chunk_ynum + 1);
	241	if (totaldim > fb->curmode.yres) {
	242	state->chunk_height -= (totaldim - fb->curmode.yres);
	243	}
8ceb0515	244
d9b82f8c JP	245	/* Do we _actually_ need to send this chunk? */
d9b82f8c JP	246	if (fb->checksum_rect) {
d136cf4c JW	247	state->chunk_checksum = fb->checksum_rect(state->chunk_xpos, state->chunk_ypos,
d136cf4c JW	248	state->chunk_width, state->chunk_height);
d9b82f8c	249
d136cf4c	250	if (state->chunk_checksum == state->checksums[state->chunk_xnum][state->chunk_ynum]) {
d9b82f8c JP	251	if (advance_chunk(state))
	252	return;
	253	continue;
d9b82f8c	254	}
d136cf4c	255	/* Checksum gets set in data block, AFTER the data has been sent. */
d9b82f8c	256	}
b496c2b1	257
d9b82f8c JP	258	outputf("actually sent");
d9b82f8c JP	259	state->chunk_actually_sent = 1;
b496c2b1	260
d9b82f8c JP	261	/* Send a header */
d9b82f8c JP	262	hdr.msgtype = 0;
ec5f9ca5	263	state->chunk_bytes_sent = 0;
d9b82f8c JP	264	hdr.nrects = htons(1);
	265	hdr.xpos = htons(state->chunk_xpos);
	266	hdr.ypos = htons(state->chunk_ypos);
	267	hdr.width = htons(state->chunk_width);
	268	hdr.height= htons(state->chunk_height);
	269	hdr.enctype = htonl(0);
b496c2b1	270
d9b82f8c	271	err = tcp_write(pcb, &hdr, sizeof(hdr), TCP_WRITE_FLAG_COPY);
b496c2b1	272
d9b82f8c JP	273	if (err != ERR_OK) {
	274	if (err != ERR_MEM)
	275	outputf("RFB: header send error %d", err);
b496c2b1	276
d9b82f8c JP	277	/* Try again later. */
	278	return;
	279	}
b496c2b1	280
d9b82f8c	281	state->send_state = SST_DATA;
b496c2b1	282
ec5f9ca5 JP	283	/* Snag the data. */
	284	fb->copy_pixels(state->blockbuf,
	285	state->chunk_xpos, state->chunk_ypos,
	286	state->chunk_width, state->chunk_height);
	287
d9b82f8c	288	/* FALL THROUGH to SST_DATA */
99a4c846	289
d9b82f8c	290	case SST_DATA:
8ceb0515	291
ec5f9ca5	292	bytes_left = 4 * state->chunk_width * state->chunk_height - state->chunk_bytes_sent;
b496c2b1	293
ec5f9ca5	294	if (bytes_left == 0) {
d9b82f8c	295	state->send_state = SST_HEADER;
d136cf4c	296	state->checksums[state->chunk_xnum][state->chunk_ynum] = state->chunk_checksum;
d9b82f8c JP	297	if (advance_chunk(state))
	298	return;
	299	break;
	300	}
b496c2b1	301
ec5f9ca5 JP	302	/* That's enough. */
	303	if (bytes_left > 1400) {
	304	bytes_left = 1400;
	305	}
b496c2b1	306
ec5f9ca5 JP	307	err = tcp_write(pcb, state->blockbuf + state->chunk_bytes_sent,
ec5f9ca5 JP	308	bytes_left, TCP_WRITE_FLAG_COPY);
bbfab433	309
d9b82f8c	310	if (err == ERR_OK) {
ec5f9ca5	311	state->chunk_bytes_sent += bytes_left;
d9b82f8c	312	} else {
8cc40c4d JW	313	if (err != ERR_MEM)
8cc40c4d JW	314	outputf("RFB: send error %d", err);
b496c2b1	315
d9b82f8c	316	return;
bbfab433	317	}
b496c2b1	318
bbfab433	319	if (tcp_sndbuf(pcb) == 0) {
d9b82f8c	320	return;
bbfab433	321	}
8ceb0515	322	}
8ceb0515	323	}
075bbc71 JW	324
075bbc71 JW	325	if (tcp_output(pcb) != ERR_OK)
075bbc71	326	outputf("RFB: tcp_output bailed in send_fsm?");
8ceb0515 JP	327	}
	328
	329	static err_t rfb_sent(void arg, struct tcp_pcb pcb, uint16_t len) {
	330	struct rfb_state *state = arg;
	331	send_fsm(pcb, state);
	332	return ERR_OK;
80726808 JP	333	}
80726808 JP	334
b59a6e50 JP	335	static err_t rfb_poll(void arg, struct tcp_pcb pcb) {
	336	struct rfb_state *state = arg;
	337	send_fsm(pcb, state);
751f179d JP	338	if (state->try_in_a_bit) {
	339	state->try_in_a_bit--;
	340	if (!(state->try_in_a_bit)) {
	341	state->update_requested = 1;
	342	}
	343	}
99a4c846	344	/*
b59a6e50	345	stats_display();
99a4c846	346	*/
b59a6e50 JP	347	return ERR_OK;
	348	}
	349
7da36fbd	350	static void close_conn(struct tcp_pcb pcb, struct rfb_state state) {
779b8ca8	351	outputf("close_conn: bailing");
7da36fbd JP	352	tcp_arg(pcb, NULL);
	353	tcp_sent(pcb, NULL);
	354	tcp_recv(pcb, NULL);
	355	mem_free(state);
ec5f9ca5	356	mem_free(state->blockbuf);
7da36fbd	357	tcp_close(pcb);
779b8ca8	358	outputf("close_conn: done");
7da36fbd JP	359	}
	360
	361	enum fsm_result {
	362	NEEDMORE,
	363	OK,
	364	FAIL
	365	};
	366
	367	static enum fsm_result recv_fsm(struct tcp_pcb pcb, struct rfb_state state) {
80726808 JP	368	int i;
	369	int pktsize;
	370
	371	outputf("RFB FSM: st %d rp %d wp %d", state->state, state->readpos,
	372	state->writepos);
7da36fbd JP	373
	374	switch(state->state) {
	375	case ST_BEGIN:
	376	if (state->writepos < 12) return NEEDMORE;
	377
	378	if (!strncmp(state->data, "RFB 003.003\n", 12)) {
	379	state->version = 3;
	380	} else if (!strncmp(state->data, "RFB 003.005\n", 12)) {
	381	/* Spec states that "RFB 003.005", an incorrect value,
	382	* should be treated by the server as 3.3. */
	383	state->version = 3;
	384	} else if (!strncmp(state->data, "RFB 003.007\n", 12)) {
	385	state->version = 7;
	386	} else if (!strncmp(state->data, "RFB 003.008\n", 12)) {
	387	state->version = 8;
	388	} else {
	389	outputf("RFB: Negotiation fail");
	390	return FAIL;
	391	}
	392
	393	outputf("RFB: Negotiated v3.%d", state->version);
	394
	395	state->readpos += 12;
	396	state->state = ST_CLIENTINIT;
	397
80726808 JP	398	/* We support one security type, currently "none".
80726808 JP	399	* Send that and SecurityResult. */
7da36fbd	400	if (state->version >= 7) {
80726808	401	tcp_write(pcb, "\x01\x01\x00\x00\x00\x00", 6, 0);
7da36fbd	402	} else {
80726808	403	tcp_write(pcb, "\x01\x00\x00\x00\x00", 5, 0);
7da36fbd JP	404	}
7da36fbd JP	405
7da36fbd JP	406	tcp_output(pcb);
	407
	408	return OK;
	409
	410	case ST_CLIENTINIT:
80726808 JP	411	if (state->version >= 7) {
	412	/* Ignore the security type and ClientInit */
	413	if (state->writepos < 2) return NEEDMORE;
	414	state->readpos += 2;
	415	} else {
	416	/* Just ClientInit */
	417	if (state->writepos < 1) return NEEDMORE;
	418	state->readpos += 1;
	419	}
	420
7da36fbd JP	421	state->state = ST_MAIN;
7da36fbd JP	422
80726808	423	outputf("RFB: Sending server info", state->version);
075bbc71	424	tcp_write(pcb, &server_info, sizeof(server_info), TCP_WRITE_FLAG_COPY);
7da36fbd JP	425	tcp_output(pcb);
	426
	427	return OK;
	428
	429	case ST_MAIN:
	430	if (state->writepos < 1) return NEEDMORE;
	431
80726808	432	outputf("RFB: cmd %d", state->data[0]);
7da36fbd JP	433	switch (state->data[0]) {
	434
	435	case SET_PIXEL_FORMAT:
	436	/* SetPixelFormat */
	437	if (state->writepos < (sizeof(struct pixel_format) + 4))
	438	return NEEDMORE;
80726808	439	outputf("RFB: SetPixelFormat");
7da36fbd JP	440	/*
	441	struct pixel_format * new_fmt =
	442	(struct pixel_format *)(&state->data[4]);
	443	*/
	444	/* XXX ... */
	445
	446	state->readpos += sizeof(struct pixel_format) + 4;
	447	return OK;
	448
	449	case SET_ENCODINGS:
	450	if (state->writepos < 4) return NEEDMORE;
	451
	452	struct set_encs_req * req = (struct set_encs_req *)state->data;
	453
80726808	454	pktsize = sizeof(struct set_encs_req) + (4 * ntohs(req->num));
7da36fbd	455
80726808 JP	456	outputf("RFB: SetEncodings [%d]", ntohs(req->num));
	457	if (state->writepos < pktsize) return NEEDMORE;
	458
	459	for (i = 0; i < ntohs(req->num); i++) {
	460	outputf("RFB: Encoding: %d", ntohl(req->encodings[i]));
	461	/* XXX ... */
80726808 JP	462	}
	463
	464	state->readpos += pktsize;
7da36fbd JP	465	return OK;
	466
	467	case FB_UPDATE_REQUEST:
	468	if (state->writepos < sizeof(struct fb_update_req))
	469	return NEEDMORE;
80726808	470	outputf("RFB: UpdateRequest");
7da36fbd	471
8ceb0515	472	state->update_requested = 1;
7da36fbd JP	473	memcpy(&state->client_interest_area, state->data,
	474	sizeof(struct fb_update_req));
	475
	476	state->readpos += sizeof(struct fb_update_req);
	477	return OK;
	478
	479	case KEY_EVENT:
	480	if (state->writepos < sizeof(struct key_event_pkt))
	481	return NEEDMORE;
	482
ec949d20	483	struct key_event_pkt * p = (struct key_event_pkt *)state->data;
dadcd4fc JP	484
dadcd4fc JP	485	outputf("RFB: Key: %d (%c)", htonl(p->keysym), (htonl(p->keysym) & 0xFF));
ec949d20	486	kbd_inject_keysym(htonl(p->keysym), p->downflag);
7da36fbd JP	487
	488	state->readpos += sizeof(struct key_event_pkt);
	489	return OK;
	490
	491	case POINTER_EVENT:
	492	if (state->writepos < sizeof(struct pointer_event_pkt))
	493	return NEEDMORE;
80726808	494	outputf("RFB: Pointer");
7da36fbd JP	495
	496	/* XXX stub */
	497
	498	state->readpos += sizeof(struct pointer_event_pkt);
	499	return OK;
	500
	501	case CLIENT_CUT_TEXT:
	502	if (state->writepos < sizeof(struct text_event_pkt))
	503	return NEEDMORE;
80726808	504	outputf("RFB: Cut Text");
7da36fbd JP	505
	506	struct text_event_pkt * pkt =
	507	(struct text_event_pkt *)state->data;
	508
	509	if (state->writepos < sizeof(struct text_event_pkt)
d9b82f8c	510	+ pkt->length)
7da36fbd JP	511	return NEEDMORE;
	512
	513	/* XXX stub */
	514
	515	state->readpos += sizeof(struct text_event_pkt)
d9b82f8c	516	+ pkt->length;
7da36fbd JP	517	return OK;
	518
	519	default:
	520	outputf("RFB: Bad command: %d", state->data[0]);
779b8ca8	521	return FAIL;
7da36fbd JP	522	}
	523	default:
	524	outputf("RFB: Bad state");
	525	return FAIL;
	526	}
	527	}
	528
	529	static err_t rfb_recv(void arg, struct tcp_pcb pcb,
d9b82f8c	530	struct pbuf *p, err_t err) {
7da36fbd	531	struct rfb_state *state = arg;
779b8ca8	532	uint16_t copylen;
7da36fbd JP	533
	534	if (state == NULL)
	535
	536	if (err != ERR_OK) {
	537	outputf("RFB: recv err %d", err);
	538	/* FIXME do something better here? */
	539	return ERR_OK;
	540	}
	541
	542	if (p == NULL) {
	543	outputf("RFB: Connection closed");
	544	close_conn(pcb, state);
	545	return ERR_OK;
	546	}
	547
	548	if (p->tot_len > (RFB_BUF_SIZE - state->writepos)) {
	549	/* Overflow! */
	550	outputf("RFB: Overflow!");
	551	close_conn(pcb, state);
	552	return ERR_OK;
	553	}
	554
779b8ca8 JP	555	copylen = pbuf_copy_partial(p, state->data + state->writepos, p->tot_len, 0);
779b8ca8 JP	556	outputf("RFB: Processing %d, wp %d, cp %d", p->tot_len, state->writepos, copylen);
80726808 JP	557	state->writepos += p->tot_len;
80726808 JP	558
7da36fbd JP	559	tcp_recved(pcb, p->tot_len);
	560	pbuf_free(p);
	561
	562	while (1) {
	563	switch (recv_fsm(pcb, state)) {
	564	case NEEDMORE:
80726808	565	outputf("RFB FSM: blocking");
779b8ca8	566	goto doneprocessing;
7da36fbd JP	567
7da36fbd JP	568	case OK:
80726808 JP	569	outputf("RFB FSM: ok");
80726808 JP	570
7da36fbd JP	571	if (state->readpos == state->writepos) {
	572	state->readpos = 0;
	573	state->writepos = 0;
779b8ca8	574	goto doneprocessing;
7da36fbd JP	575	} else {
7da36fbd JP	576	memmove(state->data,
d9b82f8c JP	577	state->data + state->readpos,
d9b82f8c JP	578	state->writepos - state->readpos);
779b8ca8 JP	579	state->writepos -= state->readpos;
779b8ca8 JP	580	state->readpos = 0;
7da36fbd JP	581	}
	582	break;
	583	case FAIL:
	584	/* Shit */
	585	outputf("RFB: Protocol error");
	586	close_conn(pcb, state);
	587	return ERR_OK;
	588	}
	589	}
779b8ca8 JP	590
	591	doneprocessing:
	592
	593	/* Kick off a send. */
	594	if (state->send_state == SST_IDLE && state->update_requested) {
	595	send_fsm(pcb, state);
	596	}
	597
	598	return ERR_OK;
7da36fbd JP	599	}
	600
	601	static err_t rfb_accept(void arg, struct tcp_pcb pcb, err_t err) {
	602	struct rfb_state *state;
ec5f9ca5	603	char * blockbuf;
7da36fbd JP	604
	605	LWIP_UNUSED_ARG(arg);
	606	LWIP_UNUSED_ARG(err);
	607
	608	state = (struct rfb_state *)mem_malloc(sizeof(struct rfb_state));
	609
ec5f9ca5 JP	610	if (!state)
	611	{
	612	outputf("rfb_accept: out of memory\n");
	613	return ERR_MEM;
	614	}
	615
751f179d JP	616	memset(state, 0, sizeof(struct rfb_state));
751f179d JP	617
ec5f9ca5 JP	618	blockbuf = mem_malloc(ceildiv(fb->curmode.xres, SCREEN_CHUNKS_X)
	619	* ceildiv(fb->curmode.yres, SCREEN_CHUNKS_Y) * 4);
	620
	621	if (!blockbuf)
	622	{
	623	outputf("rfb_accept: out of memory allocating blockbuf\n");
	624	mem_free(state);
	625	return ERR_MEM;
	626	}
	627
	628	state->blockbuf = blockbuf;
80726808	629	state->state = ST_BEGIN;
8ceb0515	630	state->send_state = SST_IDLE;
80726808	631
7da36fbd JP	632	/* XXX: update_server_info() should be called from the 64ms timer, and deal
	633	* with screen resizes appropriately. */
	634	update_server_info();
	635
7da36fbd JP	636	tcp_arg(pcb, state);
7da36fbd JP	637	tcp_recv(pcb, rfb_recv);
8ceb0515	638	tcp_sent(pcb, rfb_sent);
b59a6e50	639	tcp_poll(pcb, rfb_poll, 1);
7da36fbd JP	640	/*
7da36fbd JP	641	tcp_err(pcb, rfb_err);
7da36fbd JP	642	*/
	643	tcp_write(pcb, "RFB 003.008\n", 12, 0);
	644	tcp_output(pcb);
	645
	646	return ERR_OK;
	647	}
	648
	649	void rfb_init() {
	650	struct tcp_pcb *pcb;
	651
	652	init_server_info();
	653
	654	pcb = tcp_new();
	655	tcp_bind(pcb, IP_ADDR_ANY, RFB_PORT);
	656	pcb = tcp_listen(pcb);
	657	tcp_accept(pcb, rfb_accept);
	658	}