opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-30 18:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

style(controller): fix the wrong typo about DLedger (#4930)

Browse Source 
1. fix the wrong typo about DLedger
This commit is contained in:
TheR1sing3un
2022-08-30 13:38:26 +08:00
committed by GitHub
parent 5206354399
commit 7f25e453cd
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java
+7 -7
View File
@@ -210,16 +210,16 @@ public class DLedgerController implements Controller {
/**
* Append the request to dledger, wait the dledger to commit the request.
*/
private boolean appendToDledgerAndWait(final AppendEntryRequest request) throws Throwable {
private boolean appendToDLedgerAndWait(final AppendEntryRequest request) throws Throwable {
if (request != null) {
request.setGroup(this.dLedgerConfig.getGroup());
request.setRemoteId(this.dLedgerConfig.getSelfId());
final AppendFuture<AppendEntryResponse> dledgerFuture = (AppendFuture<AppendEntryResponse>) dLedgerServer.handleAppend(request);
if (dledgerFuture.getPos() == -1) {
final AppendFuture<AppendEntryResponse> dLedgerFuture = (AppendFuture<AppendEntryResponse>) dLedgerServer.handleAppend(request);
if (dLedgerFuture.getPos() == -1) {
return false;
}
dledgerFuture.get(5, TimeUnit.SECONDS);
dLedgerFuture.get(5, TimeUnit.SECONDS);
return true;
}
return false;
@@ -358,7 +358,7 @@ public class DLedgerController implements Controller {
if (!eventBytes.isEmpty()) {
final BatchAppendEntryRequest request = new BatchAppendEntryRequest();
request.setBatchMsgs(eventBytes);
appendSuccess = appendToDledgerAndWait(request);
appendSuccess = appendToDLedgerAndWait(request);
}
} else {
if (DLedgerController.this.controllerConfig.isProcessReadEvent()) {
@@ -366,7 +366,7 @@ public class DLedgerController implements Controller {
// So we still need to propose an empty request to dledger.
final AppendEntryRequest request = new AppendEntryRequest();
request.setBody(new byte[0]);
appendSuccess = appendToDledgerAndWait(request);
appendSuccess = appendToDLedgerAndWait(request);
}
}
if (appendSuccess) {
@@ -433,7 +433,7 @@ public class DLedgerController implements Controller {
final AppendEntryRequest request = new AppendEntryRequest();
request.setBody(new byte[0]);
try {
if (appendToDledgerAndWait(request)) {
if (appendToDLedgerAndWait(request)) {
this.currentRole = MemberState.Role.LEADER;
DLedgerController.this.startScheduling();
break;