aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/ext/transport
diff options
context:
space:
mode:
authorGravatar Yuchen Zeng <zyc@google.com>2017-12-05 12:18:34 -0800
committerGravatar Yuchen Zeng <zyc@google.com>2017-12-05 12:18:34 -0800
commitc272dd73aad1273b70fbd038efb02d6f0e169b60 (patch)
tree2275f33d78180d96dee264cc1d305dbad100c7b7 /src/core/ext/transport
parent96311af518789adb7743bf63f735087680d460f9 (diff)
Add on_initiate callback for the send_ping tranport op
Diffstat (limited to 'src/core/ext/transport')
-rw-r--r--src/core/ext/transport/chttp2/transport/chttp2_transport.cc5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/core/ext/transport/chttp2/transport/chttp2_transport.cc b/src/core/ext/transport/chttp2/transport/chttp2_transport.cc
index 63ac65ac78..ea637e6bec 100644
--- a/src/core/ext/transport/chttp2/transport/chttp2_transport.cc
+++ b/src/core/ext/transport/chttp2/transport/chttp2_transport.cc
@@ -1815,8 +1815,9 @@ static void perform_transport_op_locked(grpc_exec_ctx* exec_ctx,
grpc_endpoint_add_to_pollset_set(exec_ctx, t->ep, op->bind_pollset_set);
}
- if (op->send_ping) {
- send_ping_locked(exec_ctx, t, nullptr, op->send_ping);
+ if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) {
+ send_ping_locked(exec_ctx, t, op->send_ping.on_initiate,
+ op->send_ping.on_ack);
grpc_chttp2_initiate_write(exec_ctx, t,
GRPC_CHTTP2_INITIATE_WRITE_APPLICATION_PING);
}