Skip to content

Commit 71ff57a

Browse files
committed
startPeriodicTask
1 parent afb40f7 commit 71ff57a

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

x-pack/plugin/searchable-snapshots/src/main/java/org/elasticsearch/xpack/searchablesnapshots/cache/blob/BlobStoreCacheMaintenanceService.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ public void clusterChanged(ClusterChangedEvent event) {
170170
}
171171
if (periodicTask == null || periodicTask.isCancelled()) {
172172
schedulePeriodic = true;
173-
schedulePeriodicTask();
173+
startPeriodicTask();
174174
}
175175
}
176176

@@ -186,7 +186,7 @@ public void setPeriodicTaskBatchSize(int batchSize) {
186186
this.periodicTaskBatchSize = batchSize;
187187
}
188188

189-
private synchronized void schedulePeriodicTask() {
189+
private synchronized void startPeriodicTask() {
190190
if (schedulePeriodic) {
191191
try {
192192
final TimeValue delay = periodicTaskInterval;
@@ -603,7 +603,7 @@ private void complete(PeriodicMaintenanceTask maintenanceTask, @Nullable Excepti
603603
assert previous == null : "periodic maintenance task already failed: " + previous;
604604
maintenanceTask.close();
605605
} finally {
606-
schedulePeriodicTask();
606+
startPeriodicTask();
607607
}
608608
};
609609
boolean waitForRelease = false;

0 commit comments

Comments
 (0)