diff options
| author |  Yuchen Zeng <y-zeng@users.noreply.github.com> | 2017-12-07 11:57:54 -0800 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2017-12-07 11:57:54 -0800 |
| commit | c01a91da2d43e858cace8b34119fa35148818458 (patch) | |
| tree | 601fa0cb754d94d649d9b691356f3773facbfea2 /src/core/ext/transport | |
| parent | 4ff97d29069022842bc33d103ee383da7f79e324 (diff) | |
| parent | 625a5c05456a3001ecd4519b133aecd61e5b333b (diff) | |
Merge pull request #13647 from y-zeng/send_ping
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.cc | 5 |
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); } |