Skip to content

[hotfix][typo] Fix typo in DelayedOperationManager #217

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

Merged
wuchong merged 1 commit into from
Dec 18, 2024
+7 −7
Merged

[hotfix][typo] Fix typo in DelayedOperationManager #217

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
14 changes: 7 additions & 7 deletions ...-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedOperationManager.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public final class DelayedOperationManager<T extends DelayedOperation> {
private static final int DEFAULT_SHARDS = 512;

private final String managerName;
private final Timer timoutTimer;
private final Timer timeoutTimer;

private final int serverId;
private final int purgeInterval;
Expand All @@ -68,7 +68,7 @@ public final class DelayedOperationManager<T extends DelayedOperation> {
public DelayedOperationManager(
String managerName, int serverId, int purgeInterval, MetricGroup metricGroup) {
this.managerName = managerName;
this.timoutTimer = new DefaultTimer(managerName);
this.timeoutTimer = new DefaultTimer(managerName);
this.serverId = serverId;
this.purgeInterval = purgeInterval;
this.watcherLists = new ArrayList<>(DEFAULT_SHARDS);
Expand Down Expand Up @@ -117,7 +117,7 @@ public boolean tryCompleteElseWatch(T operation, List<Object> watchKeys) {

// if it cannot be completed by now and hence is watched, add to the expiry queue also.
if (!operation.isCompleted()) {
timoutTimer.add(operation);
timeoutTimer.add(operation);

if (operation.isCompleted()) {
// cancel the timer task.
Expand Down Expand Up @@ -163,7 +163,7 @@ public int watched() {

/** Return the number of delayed operations in the expiry queue. */
public int numDelayed() {
return timoutTimer.numOfTimerTasks();
return timeoutTimer.numOfTimerTasks();
}

/**
Expand Down Expand Up @@ -220,7 +220,7 @@ public void shutdown() {
expirationReaper.initiateShutdown();
// improve shutdown time by waking up any ShutdownableThread(s) blocked on poll by
// sending a no-op.
timoutTimer.add(
timeoutTimer.add(
new TimerTask(0) {
@Override
public void run() {}
Expand All @@ -231,7 +231,7 @@ public void run() {}
throw new FlussRuntimeException("Error while shutdown delayed operation manager", e);
}

timoutTimer.shutdown();
timeoutTimer.shutdown();
}

/** A list of operation watching keys. */
Expand Down Expand Up @@ -346,7 +346,7 @@ public void doWork() {
}

private void advanceClock() throws InterruptedException {
timoutTimer.advanceClock(200L);
timeoutTimer.advanceClock(200L);

// Trigger an expiry operation if the number of completed but still being watched
// operations is
Expand Down