diff options
author | Alex Auvolat <alex@adnab.me> | 2023-10-19 16:45:24 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2023-10-19 16:45:24 +0200 |
commit | da8b1707489b70c25395ee49383ecbbd8c9f9404 (patch) | |
tree | bf98e65cc59ea91394825f9c6ab663085bfe36ba /script/jepsen.garage/src/jepsen/garage/set.clj | |
parent | 74e50eddddf319ce1a32a9b57b3825ea40db3a6c (diff) | |
download | garage-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.clj | 17 |
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" |