X-Git-Url: http://git.pond.sub.org/?p=eow;a=blobdiff_plain;f=web.lisp;h=68870b9571e2556f8d32e0a7cf48a2817d0ed1bd;hp=96fcb29d51da10120c0dd1e6a8004d6c03c5356d;hb=526dbd606f295eed0d201b9e24e114c89c2d80f2;hpb=93ee0f65819529e7361cfc585c6509a045e4344b

diff --git a/web.lisp b/web.lisp
index 96fcb29..68870b9 100644
--- 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."