Skip to content

Commit b4a50b7

Browse files
committed
Revert sendUpdateStateRequest -> updateStatus
1 parent 57f6196 commit b4a50b7

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

server/src/main/java/org/elasticsearch/persistent/AllocatedPersistentTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ public Status getStatus() {
7878
* This doesn't affect the status of this allocated task.
7979
*/
8080
public void updatePersistentStatus(Task.Status status, ActionListener<PersistentTasksCustomMetaData.PersistentTask<?>> listener) {
81-
persistentTasksService.sendUpdateStateRequest(persistentTaskId, allocationId, status, listener);
81+
persistentTasksService.updateStatus(persistentTaskId, allocationId, status, listener);
8282
}
8383

8484
public String getPersistentTaskId() {

server/src/main/java/org/elasticsearch/persistent/PersistentTasksService.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -116,10 +116,10 @@ void sendCancelRequest(final long taskId, final String reason, final ActionListe
116116
* Persistent task implementers shouldn't call this method directly and use
117117
* {@link AllocatedPersistentTask#updatePersistentStatus} instead
118118
*/
119-
void sendUpdateStateRequest(final String taskId,
120-
final long taskAllocationID,
121-
final Task.Status status,
122-
final ActionListener<PersistentTask<?>> listener) {
119+
void updateStatus(final String taskId,
120+
final long taskAllocationID,
121+
final Task.Status status,
122+
final ActionListener<PersistentTask<?>> listener) {
123123
UpdatePersistentTaskStatusAction.Request request = new UpdatePersistentTaskStatusAction.Request(taskId, taskAllocationID, status);
124124
execute(request, UpdatePersistentTaskStatusAction.INSTANCE, listener);
125125
}

server/src/test/java/org/elasticsearch/persistent/PersistentTasksExecutorIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ public void testPersistentActionStatusUpdate() throws Exception {
215215
assertThrows(future1, IllegalStateException.class, "timed out after 10ms");
216216

217217
PlainActionFuture<PersistentTask<?>> failedUpdateFuture = new PlainActionFuture<>();
218-
persistentTasksService.sendUpdateStateRequest(taskId, -2, new Status("should fail"), failedUpdateFuture);
218+
persistentTasksService.updateStatus(taskId, -2, new Status("should fail"), failedUpdateFuture);
219219
assertThrows(failedUpdateFuture, ResourceNotFoundException.class, "the task with id " + taskId +
220220
" and allocation id -2 doesn't exist");
221221

0 commit comments

Comments
 (0)