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

Fix some spelling problems

Browse Source
This commit is contained in:
RongtongJin
2023-03-14 09:40:15 +08:00
committed by rongtong
parent 483ba12cae
commit fac699ea4d
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java
+3 -3
View File
@@ -229,10 +229,10 @@ public class AutoSwitchHAService extends DefaultHAService {
}
/**
* Check and maybe shrink the inSyncStateSet.
* Check and maybe shrink the SyncStateSet.
* A slave will be removed from SyncStateSet if (curTime - HaConnection.lastCaughtUpTime) > option(haMaxTimeSlaveNotCatchup)
*/
public Set<Long> maybeShrinkInSyncStateSet() {
public Set<Long> maybeShrinkSyncStateSet() {
final Set<Long> newSyncStateSet = getLocalSyncStateSet();
boolean isSyncStateSetChanged = false;
final long haMaxTimeSlaveNotCatchup = this.defaultMessageStore.getMessageStoreConfig().getHaMaxTimeSlaveNotCatchup();
@@ -253,7 +253,7 @@ public class AutoSwitchHAService extends DefaultHAService {
}
/**
* Check and maybe add the slave to inSyncStateSet. A slave will be added to SyncStateSet if its slaveMaxOffset >=
* Check and maybe add the slave to SyncStateSet. A slave will be added to SyncStateSet if its slaveMaxOffset >=
* current confirmOffset, and it is caught up to an offset within the current leader epoch.
*/
public void maybeExpandInSyncStateSet(final Long slaveBrokerId, final long slaveMaxOffset) {