~Jan pool debug

project.clj

@@ -1,4 +1,4 @@
-(defproject com.taoensso/carmine "2.7.0-SNAPSHOT"
+(defproject com.taoensso.debug/carmine "2.7.0-SNAPSHOT"
   :author "Peter Taoussanis <https://www.taoensso.com>"
   :description "Clojure Redis client & message queue"
   :url "https://github.com/ptaoussanis/carmine"

src/taoensso/carmine.clj

@@ -35,6 +35,7 @@
   ;; [conn-opts & [s1 & sn :as sigs]]
   [conn-opts & sigs]
   `(let [[pool# conn#] (conns/pooled-conn ~conn-opts)
+         _# (conns/log-pool-stats pool#)
 
          ;; To support `wcar` nesting with req planning, we mimmick
          ;; `with-replies` stashing logic here to simulate immediate writes:
@@ -572,3 +573,16 @@
          (wcar {} (hmget* "hkey" "a" "b"))
          (wcar {} (hgetall* "hkey"))
          (wcar {} (parse str/upper-case (hgetall* "hkey"))))
+
+(defn jan-pool-debug [conn-opts & [pool-sample-p]]
+  (binding [conns/*pool-sample-p* (or pool-sample-p 0.01)]
+    (let [k "carmine:test:debug-parallel-key"]
+      (wcar conn-opts (set k 0))
+      (->> (fn [] (future (dotimes [n 100] (wcar {} (incr k)))))
+           (repeatedly 100) ; No. of parallel clients
+           (doall)
+           (map deref)
+           (dorun))
+      (wcar conn-opts (get k)))))
+
+(comment (jan-pool-debug {} 0.001))

src/taoensso/carmine/connections.clj

@@ -3,6 +3,7 @@
   pool. Originally adapted from redis-clojure."
   {:author "Peter Taoussanis"}
   (:require [taoensso.encore           :as encore]
+            [taoensso.timbre           :as timbre]
             [taoensso.carmine.protocol :as protocol])
   (:import  [java.net Socket URI]
             [java.io BufferedInputStream DataInputStream BufferedOutputStream]
@@ -170,3 +171,13 @@
                   [pool (get-conn pool spec)])))
          (catch Exception e
            (throw (Exception. "Carmine connection error" e))))))
+
+(def ^:dynamic *pool-sample-p*  0.01)
+(defn log-pool-stats [pool]
+  (let [^GenericKeyedObjectPool pool (:pool pool)
+        active (.getNumActive pool)
+        idle   (.getNumIdle   pool)
+        total  (+ active idle)]
+    (timbre/sometimes *pool-sample-p*
+      (println ;;timbre/debug
+        "Pool stats:" {:active active :idle idle :total total}))))