X-Git-Url: http://git.scottworley.com/tattlekey/blobdiff_plain/e3ff9e0d326c0dfce08c7b9fb7aaa2b11245a6a5..e8a53974ae88e0bbe0d616be7d53aa060b4ed80d:/client/tattlekey.c diff --git a/client/tattlekey.c b/client/tattlekey.c index 2f64323..9f28e45 100644 --- a/client/tattlekey.c +++ b/client/tattlekey.c @@ -75,15 +75,15 @@ void service_sleeps(int alarm, press_pile_t *pp) { set_resend_alarm(alarm, now, act_time); return; } - pheap_node_id_t i = ph_remove_head(pp->sleeps_heap, false); - press_t *press = &pp->presses[i]; - uint32_t ago = now - press->timestamp; - send_report_packet(press->seq, ago); - press->send_count++; - if (press->send_count < config_resend_count) - ph_insert_node(pp->sleeps_heap, i); - else - ph_free_node(pp->sleeps_heap, i); + press_t press; + if (!get_press_due_for_resend(pp, now, &press)) + signal_error_by_blinking(); + uint32_t ago = now - press.timestamp; + send_report_packet(press.seq, ago); + press.send_count++; + if (press.send_count < config_resend_count) { + add_press(pp, &press); + } } } @@ -102,7 +102,7 @@ void service_queue() { queue_remove_blocking(&queue, &e); switch (e.type) { case NEW_BUTTON_PRESS: { - create_press(pp, e.buttonpress.timestamp, seq++); + add_press(pp, &(press_t){e.buttonpress.timestamp, seq++, 0}); } break; case RESEND_TIME: { /* OK, we're awake. Cool. Thanks! (We actually do the sends in the