Allow atomic mode switching in the sender

[eow] / web.lisp

diff --git a/web.lisp b/web.lisp
index 96fcb29d51da10120c0dd1e6a8004d6c03c5356d..68870b9571e2556f8d32e0a7cf48a2817d0ed1bd 100644 (file)
--- a/web.lisp
+++ b/web.lisp
@@ -37,6 +37,10 @@
     :accessor update-queue
     :initform (locked-queue:create)
     :documentation "Updates to be sent to the browser")
+   (update-thread
+    :accessor update-thread
+    :initform nil
+    :documentation "COMET thread waiting for updates of non-NIL")
    (connection
    :accessor connection
    :documentation "Connection to the empire game server")))
@@ -64,7 +68,13 @@
 (defun update ()
   "Send stream of updates to client"
   (with-session
-    (locked-queue:dequeue (update-queue *empire-session*))))
+      (when (update-thread *empire-session*)
+       (empire-log:info "~a: Killing update thread ~a." *empire-session* (update-thread *empire-session*))
+       (sb-thread:terminate-thread (update-thread *empire-session*)))
+    (setf (update-thread *empire-session*) sb-thread:*current-thread*)
+    (let ((next-update (locked-queue:dequeue (update-queue *empire-session*))))
+      (setf (update-thread *empire-session*) nil)
+      next-update)))
 
 (defmethod send ((s session) string)
   "Push a javascript update fragment to the client."