From 7810859bca53420e7204eb1c44a1969324518b5e Mon Sep 17 00:00:00 2001
From: Noah Metz <noah@metznet.ca>
Date: Sun, 30 Jul 2023 11:07:41 -0600
Subject: [PATCH] more logging

---
 node.go | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/node.go b/node.go
index e2761fc..7158d05 100644
--- a/node.go
+++ b/node.go
@@ -146,8 +146,9 @@ func SoonestSignal(signals []QueuedSignal) (*QueuedSignal, <-chan time.Time) {
     }
   }
 
+  node_timeout := time.Until(soonest_time)
   if soonest_signal != nil {
-    return soonest_signal, time.After(time.Until(soonest_time))
+    return soonest_signal, time.After(node_timeout)
   } else {
     return nil, nil
   }
@@ -209,6 +210,7 @@ func nodeLoop(ctx *Context, node *Node) error {
       }
     case <-node.TimeoutChan:
       signal = node.NextSignal.Signal
+      t := node.NextSignal.Time
       source = node.ID
       i := -1
       for j, queued := range(node.SignalQueue) {
@@ -226,9 +228,9 @@ func nodeLoop(ctx *Context, node *Node) error {
 
       node.NextSignal, node.TimeoutChan = SoonestSignal(node.SignalQueue)
       if node.NextSignal == nil {
-        ctx.Log.Logf("node", "NODE_TIMEOUT(%s) - PROCESSING %+v - NEXT_SIGNAL nil", node.ID, signal)
+        ctx.Log.Logf("node", "NODE_TIMEOUT(%s) - PROCESSING %+v@%s - NEXT_SIGNAL nil", node.ID, t, signal)
       } else {
-        ctx.Log.Logf("node", "NODE_TIMEOUT(%s) - PROCESSING %+v - NEXT_SIGNAL: %s@%s", node.ID, signal, node.NextSignal, node.NextSignal.Time)
+        ctx.Log.Logf("node", "NODE_TIMEOUT(%s) - PROCESSING %+v@%s - NEXT_SIGNAL: %s@%s", node.ID, t, signal, node.NextSignal, node.NextSignal.Time)
       }
     }