diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-10-19 23:40:55 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-10-19 23:40:55 +0200 |
| commit | ef662822c9e48ff7cfd9300590617e089c0a9498 (patch) | |
| tree | 13bfaf142e3d4ea7251f0596b6e70077eadc2951 /script/jepsen.garage/src/jepsen/garage/set.clj | |
| parent | da8b1707489b70c25395ee49383ecbbd8c9f9404 (diff) | |
| download | garage-ef662822c9e48ff7cfd9300590617e089c0a9498.tar.gz garage-ef662822c9e48ff7cfd9300590617e089c0a9498.zip | |
jepsen: fix the list-objects call (?)
Diffstat (limited to 'script/jepsen.garage/src/jepsen/garage/set.clj')
| -rw-r--r-- | script/jepsen.garage/src/jepsen/garage/set.clj | 16 |
1 files changed, 9 insertions, 7 deletions
diff --git a/script/jepsen.garage/src/jepsen/garage/set.clj b/script/jepsen.garage/src/jepsen/garage/set.clj index 8a1ab83f..c5387462 100644 --- a/script/jepsen.garage/src/jepsen/garage/set.clj +++ b/script/jepsen.garage/src/jepsen/garage/set.clj @@ -44,13 +44,15 @@ (util/timeout 10000 (assoc op :type :fail, :error ::timeout) - (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)))))))) + (do + (info "call s3/list creds: " (:creds this) ", prefix:" prefix) + (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))))))))) (teardown! [this test]) (close! [this test])) |