[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	1536

#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. */
			}

			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:
			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
e9654237	19	#define RFB_BUF_SIZE 1536
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	258	state->chunk_actually_sent = 1;
b496c2b1	259
d9b82f8c JP	260	/* Send a header */
d9b82f8c JP	261	hdr.msgtype = 0;
ec5f9ca5	262	state->chunk_bytes_sent = 0;
d9b82f8c JP	263	hdr.nrects = htons(1);
	264	hdr.xpos = htons(state->chunk_xpos);
	265	hdr.ypos = htons(state->chunk_ypos);
	266	hdr.width = htons(state->chunk_width);
	267	hdr.height= htons(state->chunk_height);
	268	hdr.enctype = htonl(0);
b496c2b1	269
d9b82f8c	270	err = tcp_write(pcb, &hdr, sizeof(hdr), TCP_WRITE_FLAG_COPY);
b496c2b1	271
d9b82f8c JP	272	if (err != ERR_OK) {
	273	if (err != ERR_MEM)
	274	outputf("RFB: header send error %d", err);
b496c2b1	275
d9b82f8c JP	276	/* Try again later. */
	277	return;
	278	}
b496c2b1	279
d9b82f8c	280	state->send_state = SST_DATA;
b496c2b1	281
ec5f9ca5 JP	282	/* Snag the data. */
	283	fb->copy_pixels(state->blockbuf,
	284	state->chunk_xpos, state->chunk_ypos,
	285	state->chunk_width, state->chunk_height);
	286
d9b82f8c	287	/* FALL THROUGH to SST_DATA */
99a4c846	288
d9b82f8c	289	case SST_DATA:
8ceb0515	290
ec5f9ca5	291	bytes_left = 4 * state->chunk_width * state->chunk_height - state->chunk_bytes_sent;
b496c2b1	292
ec5f9ca5	293	if (bytes_left == 0) {
d9b82f8c	294	state->send_state = SST_HEADER;
d136cf4c	295	state->checksums[state->chunk_xnum][state->chunk_ynum] = state->chunk_checksum;
d9b82f8c JP	296	if (advance_chunk(state))
	297	return;
	298	break;
	299	}
b496c2b1	300
ec5f9ca5 JP	301	/* That's enough. */
	302	if (bytes_left > 1400) {
	303	bytes_left = 1400;
	304	}
b496c2b1	305
ec5f9ca5 JP	306	err = tcp_write(pcb, state->blockbuf + state->chunk_bytes_sent,
ec5f9ca5 JP	307	bytes_left, TCP_WRITE_FLAG_COPY);
bbfab433	308
d9b82f8c	309	if (err == ERR_OK) {
ec5f9ca5	310	state->chunk_bytes_sent += bytes_left;
d9b82f8c	311	} else {
8cc40c4d JW	312	if (err != ERR_MEM)
8cc40c4d JW	313	outputf("RFB: send error %d", err);
b496c2b1	314
d9b82f8c	315	return;
bbfab433	316	}
b496c2b1	317
bbfab433	318	if (tcp_sndbuf(pcb) == 0) {
d9b82f8c	319	return;
bbfab433	320	}
8ceb0515	321	}
8ceb0515	322	}
075bbc71 JW	323
075bbc71 JW	324	if (tcp_output(pcb) != ERR_OK)
075bbc71	325	outputf("RFB: tcp_output bailed in send_fsm?");
8ceb0515 JP	326	}
	327
	328	static err_t rfb_sent(void arg, struct tcp_pcb pcb, uint16_t len) {
	329	struct rfb_state *state = arg;
	330	send_fsm(pcb, state);
	331	return ERR_OK;
80726808 JP	332	}
80726808 JP	333
b59a6e50 JP	334	static err_t rfb_poll(void arg, struct tcp_pcb pcb) {
	335	struct rfb_state *state = arg;
	336	send_fsm(pcb, state);
751f179d JP	337	if (state->try_in_a_bit) {
	338	state->try_in_a_bit--;
	339	if (!(state->try_in_a_bit)) {
	340	state->update_requested = 1;
	341	}
	342	}
99a4c846	343	/*
b59a6e50	344	stats_display();
99a4c846	345	*/
b59a6e50 JP	346	return ERR_OK;
	347	}
	348
7da36fbd	349	static void close_conn(struct tcp_pcb pcb, struct rfb_state state) {
779b8ca8	350	outputf("close_conn: bailing");
7da36fbd JP	351	tcp_arg(pcb, NULL);
	352	tcp_sent(pcb, NULL);
	353	tcp_recv(pcb, NULL);
	354	mem_free(state);
ec5f9ca5	355	mem_free(state->blockbuf);
7da36fbd	356	tcp_close(pcb);
779b8ca8	357	outputf("close_conn: done");
7da36fbd JP	358	}
	359
	360	enum fsm_result {
	361	NEEDMORE,
	362	OK,
	363	FAIL
	364	};
	365
	366	static enum fsm_result recv_fsm(struct tcp_pcb pcb, struct rfb_state state) {
80726808 JP	367	int i;
80726808 JP	368	int pktsize;
056e0e18	369	/*
80726808 JP	370	outputf("RFB FSM: st %d rp %d wp %d", state->state, state->readpos,
80726808 JP	371	state->writepos);
056e0e18	372	*/
7da36fbd JP	373	switch(state->state) {
	374	case ST_BEGIN:
	375	if (state->writepos < 12) return NEEDMORE;
	376
	377	if (!strncmp(state->data, "RFB 003.003\n", 12)) {
	378	state->version = 3;
	379	} else if (!strncmp(state->data, "RFB 003.005\n", 12)) {
	380	/* Spec states that "RFB 003.005", an incorrect value,
	381	* should be treated by the server as 3.3. */
	382	state->version = 3;
	383	} else if (!strncmp(state->data, "RFB 003.007\n", 12)) {
	384	state->version = 7;
	385	} else if (!strncmp(state->data, "RFB 003.008\n", 12)) {
	386	state->version = 8;
	387	} else {
	388	outputf("RFB: Negotiation fail");
	389	return FAIL;
	390	}
	391
	392	outputf("RFB: Negotiated v3.%d", state->version);
	393
	394	state->readpos += 12;
	395	state->state = ST_CLIENTINIT;
	396
80726808 JP	397	/* We support one security type, currently "none".
80726808 JP	398	* Send that and SecurityResult. */
7da36fbd	399	if (state->version >= 7) {
80726808	400	tcp_write(pcb, "\x01\x01\x00\x00\x00\x00", 6, 0);
7da36fbd	401	} else {
80726808	402	tcp_write(pcb, "\x01\x00\x00\x00\x00", 5, 0);
7da36fbd JP	403	}
7da36fbd JP	404
7da36fbd JP	405	tcp_output(pcb);
	406
	407	return OK;
	408
	409	case ST_CLIENTINIT:
80726808 JP	410	if (state->version >= 7) {
	411	/* Ignore the security type and ClientInit */
	412	if (state->writepos < 2) return NEEDMORE;
	413	state->readpos += 2;
	414	} else {
	415	/* Just ClientInit */
	416	if (state->writepos < 1) return NEEDMORE;
	417	state->readpos += 1;
	418	}
	419
7da36fbd JP	420	state->state = ST_MAIN;
7da36fbd JP	421
80726808	422	outputf("RFB: Sending server info", state->version);
075bbc71	423	tcp_write(pcb, &server_info, sizeof(server_info), TCP_WRITE_FLAG_COPY);
7da36fbd JP	424	tcp_output(pcb);
	425
	426	return OK;
	427
	428	case ST_MAIN:
	429	if (state->writepos < 1) return NEEDMORE;
	430
80726808	431	outputf("RFB: cmd %d", state->data[0]);
7da36fbd JP	432	switch (state->data[0]) {
	433
	434	case SET_PIXEL_FORMAT:
	435	/* SetPixelFormat */
	436	if (state->writepos < (sizeof(struct pixel_format) + 4))
	437	return NEEDMORE;
80726808	438	outputf("RFB: SetPixelFormat");
7da36fbd JP	439	/*
	440	struct pixel_format * new_fmt =
	441	(struct pixel_format *)(&state->data[4]);
	442	*/
	443	/* XXX ... */
	444
	445	state->readpos += sizeof(struct pixel_format) + 4;
	446	return OK;
	447
	448	case SET_ENCODINGS:
	449	if (state->writepos < 4) return NEEDMORE;
	450
	451	struct set_encs_req * req = (struct set_encs_req *)state->data;
	452
80726808	453	pktsize = sizeof(struct set_encs_req) + (4 * ntohs(req->num));
7da36fbd	454
80726808 JP	455	outputf("RFB: SetEncodings [%d]", ntohs(req->num));
	456	if (state->writepos < pktsize) return NEEDMORE;
	457
	458	for (i = 0; i < ntohs(req->num); i++) {
	459	outputf("RFB: Encoding: %d", ntohl(req->encodings[i]));
	460	/* XXX ... */
80726808 JP	461	}
	462
	463	state->readpos += pktsize;
7da36fbd JP	464	return OK;
	465
	466	case FB_UPDATE_REQUEST:
	467	if (state->writepos < sizeof(struct fb_update_req))
	468	return NEEDMORE;
80726808	469	outputf("RFB: UpdateRequest");
7da36fbd	470
8ceb0515	471	state->update_requested = 1;
7da36fbd JP	472	memcpy(&state->client_interest_area, state->data,
	473	sizeof(struct fb_update_req));
	474
	475	state->readpos += sizeof(struct fb_update_req);
	476	return OK;
	477
	478	case KEY_EVENT:
	479	if (state->writepos < sizeof(struct key_event_pkt))
	480	return NEEDMORE;
	481
ec949d20	482	struct key_event_pkt * p = (struct key_event_pkt *)state->data;
dadcd4fc JP	483
dadcd4fc JP	484	outputf("RFB: Key: %d (%c)", htonl(p->keysym), (htonl(p->keysym) & 0xFF));
ec949d20	485	kbd_inject_keysym(htonl(p->keysym), p->downflag);
7da36fbd JP	486
	487	state->readpos += sizeof(struct key_event_pkt);
	488	return OK;
	489
	490	case POINTER_EVENT:
	491	if (state->writepos < sizeof(struct pointer_event_pkt))
	492	return NEEDMORE;
80726808	493	outputf("RFB: Pointer");
7da36fbd JP	494
	495	/* XXX stub */
	496
	497	state->readpos += sizeof(struct pointer_event_pkt);
	498	return OK;
	499
	500	case CLIENT_CUT_TEXT:
	501	if (state->writepos < sizeof(struct text_event_pkt))
	502	return NEEDMORE;
80726808	503	outputf("RFB: Cut Text");
7da36fbd JP	504
	505	struct text_event_pkt * pkt =
	506	(struct text_event_pkt *)state->data;
	507
	508	if (state->writepos < sizeof(struct text_event_pkt)
d9b82f8c	509	+ pkt->length)
7da36fbd JP	510	return NEEDMORE;
	511
	512	/* XXX stub */
	513
	514	state->readpos += sizeof(struct text_event_pkt)
d9b82f8c	515	+ pkt->length;
7da36fbd JP	516	return OK;
	517
	518	default:
	519	outputf("RFB: Bad command: %d", state->data[0]);
779b8ca8	520	return FAIL;
7da36fbd JP	521	}
	522	default:
	523	outputf("RFB: Bad state");
	524	return FAIL;
	525	}
	526	}
	527
	528	static err_t rfb_recv(void arg, struct tcp_pcb pcb,
d9b82f8c	529	struct pbuf *p, err_t err) {
7da36fbd	530	struct rfb_state *state = arg;
779b8ca8	531	uint16_t copylen;
7da36fbd JP	532
	533	if (state == NULL)
	534
	535	if (err != ERR_OK) {
	536	outputf("RFB: recv err %d", err);
	537	/* FIXME do something better here? */
	538	return ERR_OK;
	539	}
	540
	541	if (p == NULL) {
	542	outputf("RFB: Connection closed");
	543	close_conn(pcb, state);
	544	return ERR_OK;
	545	}
	546
	547	if (p->tot_len > (RFB_BUF_SIZE - state->writepos)) {
	548	/* Overflow! */
	549	outputf("RFB: Overflow!");
	550	close_conn(pcb, state);
	551	return ERR_OK;
	552	}
	553
779b8ca8	554	copylen = pbuf_copy_partial(p, state->data + state->writepos, p->tot_len, 0);
056e0e18	555	/*
779b8ca8	556	outputf("RFB: Processing %d, wp %d, cp %d", p->tot_len, state->writepos, copylen);
056e0e18	557	*/
80726808 JP	558	state->writepos += p->tot_len;
80726808 JP	559
7da36fbd JP	560	tcp_recved(pcb, p->tot_len);
	561	pbuf_free(p);
	562
	563	while (1) {
	564	switch (recv_fsm(pcb, state)) {
	565	case NEEDMORE:
80726808	566	outputf("RFB FSM: blocking");
779b8ca8	567	goto doneprocessing;
7da36fbd JP	568
	569	case OK:
	570	if (state->readpos == state->writepos) {
	571	state->readpos = 0;
	572	state->writepos = 0;
779b8ca8	573	goto doneprocessing;
7da36fbd JP	574	} else {
7da36fbd JP	575	memmove(state->data,
d9b82f8c JP	576	state->data + state->readpos,
d9b82f8c JP	577	state->writepos - state->readpos);
779b8ca8 JP	578	state->writepos -= state->readpos;
779b8ca8 JP	579	state->readpos = 0;
7da36fbd JP	580	}
	581	break;
	582	case FAIL:
	583	/* Shit */
	584	outputf("RFB: Protocol error");
	585	close_conn(pcb, state);
	586	return ERR_OK;
	587	}
	588	}
779b8ca8 JP	589
	590	doneprocessing:
	591
	592	/* Kick off a send. */
	593	if (state->send_state == SST_IDLE && state->update_requested) {
	594	send_fsm(pcb, state);
	595	}
	596
	597	return ERR_OK;
7da36fbd JP	598	}
	599
	600	static err_t rfb_accept(void arg, struct tcp_pcb pcb, err_t err) {
	601	struct rfb_state *state;
ec5f9ca5	602	char * blockbuf;
7da36fbd JP	603
	604	LWIP_UNUSED_ARG(arg);
	605	LWIP_UNUSED_ARG(err);
	606
	607	state = (struct rfb_state *)mem_malloc(sizeof(struct rfb_state));
	608
ec5f9ca5 JP	609	if (!state)
	610	{
	611	outputf("rfb_accept: out of memory\n");
	612	return ERR_MEM;
	613	}
	614
751f179d JP	615	memset(state, 0, sizeof(struct rfb_state));
751f179d JP	616
ec5f9ca5 JP	617	blockbuf = mem_malloc(ceildiv(fb->curmode.xres, SCREEN_CHUNKS_X)
	618	* ceildiv(fb->curmode.yres, SCREEN_CHUNKS_Y) * 4);
	619
	620	if (!blockbuf)
	621	{
	622	outputf("rfb_accept: out of memory allocating blockbuf\n");
	623	mem_free(state);
	624	return ERR_MEM;
	625	}
	626
	627	state->blockbuf = blockbuf;
80726808	628	state->state = ST_BEGIN;
8ceb0515	629	state->send_state = SST_IDLE;
80726808	630
7da36fbd JP	631	/* XXX: update_server_info() should be called from the 64ms timer, and deal
	632	* with screen resizes appropriately. */
	633	update_server_info();
	634
7da36fbd JP	635	tcp_arg(pcb, state);
7da36fbd JP	636	tcp_recv(pcb, rfb_recv);
8ceb0515	637	tcp_sent(pcb, rfb_sent);
b59a6e50	638	tcp_poll(pcb, rfb_poll, 1);
7da36fbd JP	639	/*
7da36fbd JP	640	tcp_err(pcb, rfb_err);
7da36fbd JP	641	*/
	642	tcp_write(pcb, "RFB 003.008\n", 12, 0);
	643	tcp_output(pcb);
	644
	645	return ERR_OK;
	646	}
	647
	648	void rfb_init() {
	649	struct tcp_pcb *pcb;
	650
	651	init_server_info();
	652
	653	pcb = tcp_new();
	654	tcp_bind(pcb, IP_ADDR_ANY, RFB_PORT);
	655	pcb = tcp_listen(pcb);
	656	tcp_accept(pcb, rfb_accept);
	657	}