diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-10-20 12:56:45 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-10-20 12:56:55 +0200 |
| commit | 4b93ce179a3777c8461f3b5843dc3802bddc739c (patch) | |
| tree | f0dbf38bd5acc380276bfc0a8099ca14b43fa65e /script/jepsen.garage/src/jepsen/garage/reg.clj | |
| parent | 4ba18ce9cca1b828edcf3f8c8770d49c75ed3083 (diff) | |
| download | garage-4b93ce179a3777c8461f3b5843dc3802bddc739c.tar.gz garage-4b93ce179a3777c8461f3b5843dc3802bddc739c.zip | |
jepsen: errors in reg2 workload under investigation
Diffstat (limited to 'script/jepsen.garage/src/jepsen/garage/reg.clj')
| -rw-r--r-- | script/jepsen.garage/src/jepsen/garage/reg.clj | 30 |
1 files changed, 20 insertions, 10 deletions
diff --git a/script/jepsen.garage/src/jepsen/garage/reg.clj b/script/jepsen.garage/src/jepsen/garage/reg.clj index b5bf28ff..6772abfe 100644 --- a/script/jepsen.garage/src/jepsen/garage/reg.clj +++ b/script/jepsen.garage/src/jepsen/garage/reg.clj @@ -103,18 +103,10 @@ valid? (empty? (:bad-reads final))] (assoc final :valid? valid?))))) -(defn workload - "Tests linearizable reads and writes" +(defn workload-common + "Common parts of workload" [opts] {:client (RegClient. nil) - :checker (independent/checker - (checker/compose - {:reg-read-after-write (reg-read-after-write) - ; linear test is desactivated, indeed Garage is not linear - ;:linear (checker/linearizable - ; {:model (model/register) - ; :algorithm :linear}) - :timeline (timeline/html)})) :generator (independent/concurrent-generator 10 (range) @@ -123,4 +115,22 @@ (gen/mix [op-get op-put op-del]) (gen/limit (:ops-per-key opts)))))}) +(defn workload1 + "Tests linearizable reads and writes" + [opts] + (assoc (workload-common opts) + :checker (independent/checker + (checker/compose + {:linear (checker/linearizable + {:model (model/register) + :algorithm :linear}) + :timeline (timeline/html)})))) +(defn workload2 + "Tests CRDT reads and writes" + [opts] + (assoc (workload-common opts) + :checker (independent/checker + (checker/compose + {:reg-read-after-write (reg-read-after-write) + :timeline (timeline/html)})))) |