Skip to content

Commit c48d5df

Browse files
committed
Address review comments
Signed-off-by: Suraj Singh <surajrider@gmail.com>
1 parent 8116b86 commit c48d5df

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

server/src/main/java/org/opensearch/indices/replication/RemoteSegmentFileChunkWriter.java

+5
Original file line numberDiff line numberDiff line change
@@ -122,4 +122,9 @@ public void writeFileChunk(
122122
reader
123123
);
124124
}
125+
126+
@Override
127+
public void cancel() {
128+
retryableTransportClient.cancel();
129+
}
125130
}

server/src/main/java/org/opensearch/indices/replication/SegmentReplicationSourceHandler.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ public synchronized void sendFiles(GetSegmentFilesRequest request, ActionListene
189189
}
190190

191191
/**
192-
* Cancels the recovery and interrupts all eligible threads.
192+
* Cancels the replication and interrupts all eligible threads.
193193
*/
194194
public void cancel(String reason) {
195195
writer.cancel();

0 commit comments

Comments
 (0)