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.

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 #275] Complete snapshot(sync mode to install) #298

Merged
merged 35 commits into from
Jul 15, 2023
Merged
Changes from 1 commit
Commits
Show all changes
35 commits
Select commit Hold shift + click to select a range
eb3de76
feat(core): support protocol about install snapshot
TheR1sing3un Feb 19, 2023
0360902
feat(core): support protocol about install snapshot
TheR1sing3un Mar 8, 2023
9dc922e
feat(core): refactor basic dledger overall structure to make it more …
TheR1sing3un Jun 4, 2023
d4e86cf
feat(core): pass all original test
TheR1sing3un Jun 6, 2023
efaf104
feat(core): support batch append
TheR1sing3un Jun 24, 2023
48385d3
fix(example): resolve conflicts after rebasing master
TheR1sing3un Jun 25, 2023
ffdaefe
fix(jepsen): resolve conflicts about jepsen after rebasing master
TheR1sing3un Jun 25, 2023
1ccd2b5
fix(jepsen): fix type error
TheR1sing3un Jun 26, 2023
f354412
feat(core): support installing snapshot
TheR1sing3un Jul 2, 2023
8061e1e
feat(core): support installing snapshot
TheR1sing3un Jul 9, 2023
1d9721c
feat(jepsen): test snapshot in jepsen
TheR1sing3un Jul 9, 2023
1a6da03
test(core): polish flaky test
TheR1sing3un Jul 10, 2023
5a26409
rerun
TheR1sing3un Jul 10, 2023
d865307
feat(core): commit entry which is in current term
TheR1sing3un Jul 10, 2023
15cc20f
rerun
TheR1sing3un Jul 10, 2023
b8ce8e7
rerun
TheR1sing3un Jul 10, 2023
7eb981e
rerun
TheR1sing3un Jul 11, 2023
9f2ec8d
fix(core): make the field: position in DLedgerEntry meaningless
TheR1sing3un Jul 14, 2023
053b94d
test(core): use different store base path for each ut
TheR1sing3un Jul 14, 2023
0fac345
test(core): use different store base path for each ut
TheR1sing3un Jul 14, 2023
8023912
rerun
TheR1sing3un Jul 15, 2023
2876131
test(core): use different store base path for each ut
TheR1sing3un Jul 15, 2023
712f38f
test(core): use different store base path for each ut
TheR1sing3un Jul 15, 2023
ce2fa58
test(core): use different store base path for each ut
TheR1sing3un Jul 15, 2023
82bd3ad
fix(core): update peer watermark when compare success
TheR1sing3un Jul 15, 2023
0657687
fix(core): fix
TheR1sing3un Jul 15, 2023
49d233a
fix(core): fix
TheR1sing3un Jul 15, 2023
9f935ed
test(proxy): remove proxy test
TheR1sing3un Jul 15, 2023
5abd32a
feat(example): add batch append cmd
TheR1sing3un Jul 15, 2023
493b2a0
fix(core): reuse forks
TheR1sing3un Jul 15, 2023
0a8ad61
chore(global): add more git ignore file
TheR1sing3un Jul 15, 2023
817b304
build(global): set reuseForks to false
TheR1sing3un Jul 15, 2023
5d9bb7d
rerun
TheR1sing3un Jul 15, 2023
9929558
feat(core): clear pending map and set writeIndex when role dispatcher…
TheR1sing3un Jul 15, 2023
d910b5b
rerun
TheR1sing3un Jul 15, 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(example): add batch append cmd
1. add batch append cmd
TheR1sing3un committed Jul 15, 2023
commit 5abd32a1fd898ed0c5d4b759e32941128b1b4664
Original file line number Diff line number Diff line change
@@ -60,6 +60,15 @@ public class RegisterCommand extends BaseCommand {
@Parameter(names = {"--snapshot-threshold"}, description = "Snapshot threshold")
private int snapshotThreshold = 1000;

@Parameter(names = {"--enable-batch-append"}, description = "Enable batch append")
private boolean enableBatchAppend = false;

@Parameter(names = {"--max-batch-append-size"}, description = "Max batch append size")
private int maxBatchAppendSize = 4 * 1024;

@Parameter(names = {"--max-batch-append-interval"}, description = "Max batch append interval in ms")
private int maxBatchAppendIntervalMs = 10;

@Override
public void doCommand() {
try {
@@ -83,6 +92,9 @@ private DLedgerConfig buildDLedgerConfig() {
dLedgerConfig.setPreferredLeaderIds(this.preferredLeaderIds);
dLedgerConfig.setEnableSnapshot(enableSnapshot);
dLedgerConfig.setSnapshotThreshold(snapshotThreshold);
dLedgerConfig.setEnableBatchAppend(enableBatchAppend);
dLedgerConfig.setMaxBatchAppendSize(maxBatchAppendSize);
dLedgerConfig.setMaxBatchAppendSize(maxBatchAppendIntervalMs);
return dLedgerConfig;
}
}