aboutsummaryrefslogtreecommitdiff
path: root/script/jepsen.garage/src/jepsen/garage/set.clj
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-10-19 16:45:24 +0200
committerAlex Auvolat <alex@adnab.me>2023-10-19 16:45:24 +0200
commitda8b1707489b70c25395ee49383ecbbd8c9f9404 (patch)
treebf98e65cc59ea91394825f9c6ab663085bfe36ba /script/jepsen.garage/src/jepsen/garage/set.clj
parent74e50eddddf319ce1a32a9b57b3825ea40db3a6c (diff)
downloadgarage-da8b1707489b70c25395ee49383ecbbd8c9f9404.tar.gz
garage-da8b1707489b70c25395ee49383ecbbd8c9f9404.zip
jepsen: investigating listobjects error
Diffstat (limited to 'script/jepsen.garage/src/jepsen/garage/set.clj')
-rw-r--r--script/jepsen.garage/src/jepsen/garage/set.clj17
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"