From: Scott Worley <scottworley@scottworley.com>
Date: Tue, 10 Oct 2023 02:46:28 +0000 (-0700)
Subject: client: next_scheduled_send()
X-Git-Tag: v0.1.0~41
X-Git-Url: http://git.scottworley.com/tattlekey/commitdiff_plain/b512ec26593fde453ce121f30ba8d36b1e3678df?ds=sidebyside

client: next_scheduled_send()
---

diff --git a/client/sends.c b/client/sends.c
index b265634..0125bf2 100644
--- a/client/sends.c
+++ b/client/sends.c
@@ -1,6 +1,6 @@
 #include "sends.h"
 
-uint32_t next_send(send_t *s) {
+static uint32_t next_send(send_t *s) {
   return s->timestamp + (1 << s->send_count) - 1;
 }
 
@@ -23,3 +23,10 @@ void create_send(send_t *sleeping_sends, pheap_t *sleeps_heap,
   sleeping_sends[i].send_count = 0;
   ph_insert_node(sleeps_heap, i);
 }
+
+int32_t next_scheduled_send(send_t *sleeping_sends, pheap_t *sleeps_heap) {
+  pheap_node_id_t i = ph_peek_head(sleeps_heap);
+  if (i == 0)
+    return -1;
+  return next_send(&sleeping_sends[i]);
+}
diff --git a/client/sends.h b/client/sends.h
index 651d0e4..3dc1c74 100644
--- a/client/sends.h
+++ b/client/sends.h
@@ -10,11 +10,13 @@ typedef struct {
   u8_t send_count;
 } send_t;
 
-uint32_t next_send(send_t *s);
-
 bool next_send_less_than(void *user_data, pheap_node_id_t a, pheap_node_id_t b);
 
 void create_send(send_t *sleeping_sends, pheap_t *sleeps_heap,
                  uint32_t timestamp, u16_t seq);
 
+/* When do we next need to send something (in seconds since boot)?
+ * Returns -1 if there's nothing pending. */
+int32_t next_scheduled_send(send_t *sleeping_sends, pheap_t *sleeps_heap);
+
 #endif
diff --git a/client/tattlekey.c b/client/tattlekey.c
index b433b44..f5306c2 100644
--- a/client/tattlekey.c
+++ b/client/tattlekey.c
@@ -60,19 +60,18 @@ void service_sleeps(int alarm, send_t *sleeping_sends, pheap_t *sleeps_heap) {
 
   while (1) {
     uint32_t now = time_s();
-    pheap_node_id_t i = ph_peek_head(sleeps_heap);
-    if (i == 0)
+    int32_t act_time = next_scheduled_send(sleeping_sends, sleeps_heap);
+    if (act_time == -1)
       return;
-    send_t *send = &sleeping_sends[i];
-    if (next_send(send) > now) {
-      uint32_t sleep_duration = next_send(send) - now;
+    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;
     }
-    if (ph_remove_head(sleeps_heap, false) != i)
-      signal_error_by_blinking();
+    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++;