Skip to content

Commit a841010

Browse files
committed
Address PR comment
Signed-off-by: Rishabh Maurya <[email protected]>
1 parent 9b1414e commit a841010

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

server/src/main/java/org/opensearch/transport/OutboundHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,15 +75,15 @@ void sendBytes(TcpChannel channel, BytesReference bytes, ActionListener<Void> li
7575
}
7676
}
7777

78-
public void sendBytes(long requestId, TcpChannel channel, SendContext sendContext) throws IOException {
78+
public void sendBytes(long reqId, TcpChannel channel, SendContext sendContext) throws IOException {
7979
channel.getChannelStats().markAccessed(threadPool.relativeTimeInMillis());
8080
BytesReference reference = sendContext.get();
8181
// stash thread context so that channel event loop is not polluted by thread context
8282
try (ThreadContext.StoredContext existing = threadPool.getThreadContext().stashContext()) {
83-
if (requestId == -1) {
83+
if (reqId == -1) {
8484
channel.sendMessage(reference, sendContext);
8585
} else {
86-
channel.sendMessage(requestId, reference, sendContext);
86+
channel.sendMessage(reqId, reference, sendContext);
8787
}
8888
} catch (RuntimeException ex) {
8989
sendContext.onFailure(ex);

0 commit comments

Comments
 (0)