Gather some more data on this integ failure.

Author: tobias

web/test-integration/immutant/web/integ_test.clj

@@ -179,6 +179,13 @@
         (is (= (str "/" path)
               (-> result (deref 5000 "nil") read-string :path-info)))))))
 
+(let [serializer (java.util.concurrent.Executors/newSingleThreadExecutor)]
+  (defn mark [& msg]
+    (let [^Runnable r #(apply println
+                         (.format (java.text.SimpleDateFormat. "HH:mm:ss,SSS")
+                           (java.util.Date.)) msg)]
+      (.submit serializer r))))
+
 (deftest concurrent-ws-requests-should-not-cross-streams
   (replace-handler
     '(fn [request]
@@ -192,14 +199,16 @@
         client-count 40]
     (dotimes [n client-count]
       (future
+        (mark "CLIENT SEND" n)
         (let [client (ws/connect (str (cdef-url "ws") "?x=" n)
                        :on-receive (fn [m]
+                                     (mark "CLIENT RCVD" m)
                                      (swap! results conj m)
                                      (when (= client-count (count @results))
                                        (deliver done? true))))]
           (swap! clients conj client))))
     (is (deref done? 10000 nil))
-    (println "RESULTS" @results)
+    (mark "RESULTS" @results)
     (is (= (->> client-count (range 0) (map str) set)
           (set @results)))
     (doseq [client @clients]