impala-reviews mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Michael Ho (Code Review)" <>
Subject [Impala-ASF-CR] KUDU-2065: Support cancellation for outbound RPC call
Date Sun, 20 Aug 2017 01:11:48 GMT
Hello Todd Lipcon, Kudu Jenkins,

I'd like you to do a code review.  Please visit

to review the following change.

Change subject: KUDU-2065: Support cancellation for outbound RPC call

KUDU-2065: Support cancellation for outbound RPC call

This change implements a new interface RpcController::Cancel()
which takes a RpcController as argument and cancels any
pending OutboundCall associated with it.

RpcController::Cancel() queues a cancellation task scheduled
on the reactor thread for that outbound call. Once the task
is run, it will cancel the outbound call right away if
the RPC hasn't started sending yet or if it has already
sent the request and waiting for a response. If cancellation
happens when the RPC request is being sent, the RPC will
be cancelled only after the RPC has finished sending the
request. If the RPC is finished, the cancellation will
be a no-op.

Change-Id: Iaf53c5b113de10d573bd32fb9b2293572e806fbf
Tested-by: Kudu Jenkins
Reviewed-by: Todd Lipcon <>
M be/src/kudu/rpc/
M be/src/kudu/rpc/connection.h
M be/src/kudu/rpc/
M be/src/kudu/rpc/messenger.h
M be/src/kudu/rpc/
M be/src/kudu/rpc/outbound_call.h
M be/src/kudu/rpc/
M be/src/kudu/rpc/
M be/src/kudu/rpc/reactor.h
M be/src/kudu/rpc/rpc-test-base.h
M be/src/kudu/rpc/
M be/src/kudu/rpc/
M be/src/kudu/rpc/rpc_controller.h
M be/src/kudu/rpc/rpc_introspection.proto
M be/src/kudu/rpc/rtest.proto
15 files changed, 443 insertions(+), 24 deletions(-)

  git pull ssh:// refs/changes/43/7743/1
To view, visit
To unsubscribe, visit

Gerrit-MessageType: newchange
Gerrit-Change-Id: Iaf53c5b113de10d573bd32fb9b2293572e806fbf
Gerrit-PatchSet: 1
Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-Owner: Michael Ho <>
Gerrit-Reviewer: Kudu Jenkins
Gerrit-Reviewer: Todd Lipcon <>

View raw message