From: Christopher Allan Webber Date: Thu, 19 Nov 2015 21:33:37 +0000 (-0600) Subject: Add scheduled segment contents to the queue... in theory at least... :) X-Git-Tag: v0.1.0~145 X-Git-Url: https://jxself.org/git/?a=commitdiff_plain;h=396c2542b7c546ac669605470a83b8c0ee8c0381;p=8sync.git Add scheduled segment contents to the queue... in theory at least... :) --- diff --git a/loopy.scm b/loopy.scm index 2f733c0..e96b130 100644 --- a/loopy.scm +++ b/loopy.scm @@ -303,7 +303,7 @@ (define* (start-agenda agenda #:optional stop-condition) (let loop ((agenda agenda)) - (let ((new-agenda + (let ((agenda ;; @@: Hm, maybe here would be a great place to handle ;; select'ing on ports. ;; We could compose over agenda-run-once and agenda-read-ports @@ -311,12 +311,18 @@ (agenda-run-once agenda)))) (if (and stop-condition (stop-condition agenda)) 'done - (let ((updated-agenda - ;; Adjust the agenda's time just in time - ;; We do this here rather than in agenda-run-once to make - ;; agenda-run-once's behavior fairly predictable - (set-field new-agenda (agenda-time) (gettimeofday)))) - (loop updated-agenda)))))) + (let* ((new-time (gettimeofday)) + (agenda + ;; Adjust the agenda's time just in time + ;; We do this here rather than in agenda-run-once to make + ;; agenda-run-once's behavior fairly predictable + (set-field agenda (agenda-time) new-time))) + ;; Update the agenda's current queue based on + ;; currently applicable time segments + (add-segments-contents-to-queue! + (schedule-extract-until! (agenda-schedule agenda) new-time) + (agenda-queue agenda)) + (loop agenda)))))) (define (agenda-run-once agenda) "Run once through the agenda, and produce a new agenda