Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[ISSUE #289] Support Register-Model server based on DLedger #288

Merged
merged 10 commits into from
May 29, 2023
Merged

[ISSUE #289] Support Register-Model server based on DLedger #288

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
92b713a
feat(example): add Register Model DLedger
TheR1sing3un May 21, 2023
fa50911
feat(jepsen): add jepsen test framework
TheR1sing3un May 21, 2023
89b9977
feat(jepsen): support linear verify and make test more automated
TheR1sing3un May 22, 2023
5eddd62
feat(jepsen): pass network partition test
TheR1sing3un May 23, 2023
f46dee1
feat(jepsen): add apache license header
TheR1sing3un May 23, 2023
3a34a5d
fix(jepsen): fix apply empty log
TheR1sing3un May 23, 2023
d781d09
feat(example): support benchmark for register model
TheR1sing3un May 25, 2023
a075384
refactor(example): combine modules: command and example
TheR1sing3un May 25, 2023
a84d8f0
style(global): rollback changes `.gitignore`
TheR1sing3un May 25, 2023
5c9ce65
rerun
TheR1sing3un May 25, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
feat(jepsen): pass network partition test 
1. pass network partition test

Closes #286
  • Loading branch information
@TheR1sing3un
TheR1sing3un committed May 23, 2023
commit 5eddd62a31a59eb4d404b574b85375b4c1784390
2 changes: 1 addition & 1 deletion ...src/main/java/io/openmessaging/storage/dledger/example/register/RegisterStateMachine.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ public String getBindDLedgerId() {
}

public Integer getValue(Integer key) {
return this.register.getOrDefault(key, -1);
return this.register.get(key);
}

public ConcurrentHashMap<Integer, Integer> getRegister() {
Expand Down
11 changes: 5 additions & 6 deletions jepsen/src/main/clojure/io/openmessaging/storage/dledger/jepsen/core.clj
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -95,11 +95,11 @@
(reify db/DB
(setup! [_ test node]
(start! test node)
(Thread/sleep 1000))
(Thread/sleep 10000))

(teardown! [_ _ node]
(stop! node)
(Thread/sleep 1000)
(Thread/sleep 10000)
(c/exec
:rm
:-rf
Expand Down Expand Up @@ -178,10 +178,9 @@
{:perf (checker/perf)
:indep (independent/checker
(checker/compose
{:timeline (timeline/html)
:linear (checker/linearizable
{:model (model/register)
:algorithm :linear})}))})
{:linear (checker/linearizable
{:model (model/cas-register)})
:timeline (timeline/html)}))})
:generator (->> (independent/concurrent-generator
(:concurrency opts 5)
(range)
Expand Down