state->chunk_ynum = 0;
state->send_state = SST_IDLE;
if (!(state->chunk_actually_sent))
- state->try_in_a_bit = 2;
+ state->try_in_a_bit = 1;
return 1;
}
/* Checksum gets set in data block, AFTER the data has been sent. */
}
- outputf("actually sent");
state->chunk_actually_sent = 1;
/* Send a header */
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;
}
}
+ send_fsm(pcb, state);
/*
stats_display();
*/
tcp_arg(pcb, NULL);
tcp_sent(pcb, NULL);
tcp_recv(pcb, NULL);
- mem_free(state);
mem_free(state->blockbuf);
+ mem_free(state);
tcp_close(pcb);
outputf("close_conn: done");
}
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;
case ST_MAIN:
if (state->writepos < 1) return NEEDMORE;
- outputf("RFB: cmd %d", state->data[0]);
switch (state->data[0]) {
case SET_PIXEL_FORMAT:
}
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);
goto doneprocessing;
case OK:
- outputf("RFB FSM: ok");
-
if (state->readpos == state->writepos) {
state->readpos = 0;
state->writepos = 0;