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

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
fix(jepsen): fix apply empty log 
1. fix apply empty log

Closes #286
  • Loading branch information
@TheR1sing3un
TheR1sing3un committed May 23, 2023
commit 3a34a5dd0e594ab9955693b5e2e8a9548a687d6e
2 changes: 1 addition & 1 deletion ...est/java/io/openmessaging/storage/dledger/statemachine/register/RegisterStateMachine.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ public class RegisterStateMachine implements StateMachine {
public void onApply(CommittedEntryIterator iter) {
while (iter.hasNext()) {
final DLedgerEntry entry = iter.next();
if (entry != null && entry.getBody() != null) {
if (entry != null && entry.getBody() != null && entry.getBody().length == 8) {
byte[] bytes = entry.getBody();
int key = BytesUtil.bytesToInt(bytes, 0);
int value = BytesUtil.bytesToInt(bytes, 4);
Expand Down