Jepsen testing (NLnet task 3 subtask 1) #544
2 changed files with 8 additions and 11 deletions
|
@ -1,8 +1,8 @@
|
||||||
{ pkgs ? import <nixpkgs> {} }:
|
{ pkgs ? import <nixpkgs> { } }:
|
||||||
pkgs.mkShell {
|
pkgs.mkShell {
|
||||||
nativeBuildInputs = with pkgs; [
|
nativeBuildInputs = with pkgs; [
|
||||||
leiningen
|
leiningen
|
||||||
vagrant
|
vagrant
|
||||||
gnuplot
|
gnuplot
|
||||||
];
|
];
|
||||||
}
|
}
|
||||||
|
|
|
@ -57,8 +57,6 @@
|
||||||
:unexpected #{}}
|
:unexpected #{}}
|
||||||
final (reduce
|
final (reduce
|
||||||
(fn [state op]
|
(fn [state op]
|
||||||
(info "state:" state)
|
|
||||||
(info "operation:" op)
|
|
||||||
(case [(:type op) (:f op)]
|
(case [(:type op) (:f op)]
|
||||||
([:invoke :add])
|
([:invoke :add])
|
||||||
(assoc state :add-started (conj (:add-started state) (:value op)))
|
(assoc state :add-started (conj (:add-started state) (:value op)))
|
||||||
|
@ -77,7 +75,6 @@
|
||||||
state))
|
state))
|
||||||
init history)
|
init history)
|
||||||
valid? (and (empty? (:missed final)) (empty? (:unexpected final)))]
|
valid? (and (empty? (:missed final)) (empty? (:unexpected final)))]
|
||||||
(info "final state:" final)
|
|
||||||
(assoc final :valid? valid?)))))
|
(assoc final :valid? valid?)))))
|
||||||
|
|
||||||
(defn workload1
|
(defn workload1
|
||||||
|
@ -110,7 +107,7 @@
|
||||||
:timeline (timeline/html)}))
|
:timeline (timeline/html)}))
|
||||||
:generator (independent/concurrent-generator
|
:generator (independent/concurrent-generator
|
||||||
10
|
10
|
||||||
(range 100)
|
(range)
|
||||||
(fn [k]
|
(fn [k]
|
||||||
(gen/mix [op-add-rand100 op-read])))})
|
(gen/mix [op-add-rand100 op-read])))})
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue