+static void time_to_send(uint _) {
+ /* This runs in interrupt context; don't linger. */
+ event_t e;
+ e.type = SEND;
+ queue_try_add_ignoring_errors(&queue, &e);
+}
+
+void service_sleeps(int alarm, send_t *sleeping_sends, pheap_t *sleeps_heap) {
+ hardware_alarm_cancel(alarm);
+
+ while (1) {
+ uint32_t now = time_s();
+ int32_t act_time = next_scheduled_send(sleeping_sends, sleeps_heap);
+ if (act_time == -1)
+ return;
+ if (act_time > now) {
+ uint32_t sleep_duration = act_time - now;
+ if (hardware_alarm_set_target(
+ alarm, make_timeout_time_ms(sleep_duration * 1000)))
+ signal_error_by_blinking();
+ return;
+ }
+ pheap_node_id_t i = ph_remove_head(sleeps_heap, false);
+ send_t *send = &sleeping_sends[i];
+ uint32_t ago = now - send->timestamp;
+ send_report(send->seq, ago);
+ send->send_count++;
+ if (send->send_count < config_resend_count)
+ ph_insert_node(sleeps_heap, i);
+ else
+ ph_free_node(sleeps_heap, i);
+ }
+}
+