jepsen: investigating listobjects error

1 files changed, 10 insertions, 7 deletions

diff --git a/script/jepsen.garage/src/jepsen/garage/set.clj b/script/jepsen.garage/src/jepsen/garage/set.clj
index ff597095..8a1ab83f 100644
--- a/script/jepsen.garage/src/jepsen/garage/set.clj
+++ b/script/jepsen.garage/src/jepsen/garage/set.clj
@@ -44,12 +44,13 @@
           (util/timeout
             10000
             (assoc op :type :fail, :error ::timeout)
-            (let [items (s3/list (:creds this) prefix)
-                  items-stripped (map (fn [o]
+            (let [items (s3/list (:creds this) prefix)]
+              (info "list results for prefix" prefix ":" items " (node:" (:endpoint (:creds this)) ")")
+              (let [items-stripped (map (fn [o]
                                         (assert (str/starts-with? o prefix))
                                         (str/replace-first o prefix "")) items)
-                  items-set (set (map parse-long items-stripped))]
-              (assoc op :type :ok, :value (independent/tuple k items-set)))))))
+                    items-set (set (map parse-long items-stripped))]
+                (assoc op :type :ok, :value (independent/tuple k items-set))))))))
   (teardown! [this test])
   (close! [this test]))
 
@@ -100,9 +101,11 @@
                           (->> (range)
                            (map (fn [x] {:type :invoke, :f :add, :value x}))
                            (gen/limit (:ops-per-key opts)))))
-   :final-generator   (independent/sequential-generator
-                        (range 100)
-                        (fn [k] (gen/once op-read)))})
+   :final-generator   (gen/phases
+                        (independent/sequential-generator
+                          (range 100)
+                          (fn [k] (gen/once op-read)))
+                        (gen/sleep 5))})
 
 (defn workload2
   "Tests insertions and deletions"