diff options
author | Mark D. Roth <roth@google.com> | 2017-08-31 10:05:47 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-08-31 10:05:47 -0700 |
commit | 8d51e8d17e012f81ca8e94c18f525e1781130481 (patch) | |
tree | c7e3fbda5f9080a38ecd6bb19401f430b029ceac /src/cpp/common | |
parent | 179f1369c3e13ed70241b87909c2a7fb229c3bd9 (diff) | |
parent | 196fa2e154c52ffc5bed76ff8b54093117632811 (diff) |
Merge pull request #12331 from markdroth/c++_filter_api_fix
Add recv_message() method to TransportStreamOpBatch class.
Diffstat (limited to 'src/cpp/common')
-rw-r--r-- | src/cpp/common/channel_filter.h | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/cpp/common/channel_filter.h b/src/cpp/common/channel_filter.h index 4b37c202f9..c3d187d7e1 100644 --- a/src/cpp/common/channel_filter.h +++ b/src/cpp/common/channel_filter.h @@ -195,6 +195,15 @@ class TransportStreamOpBatch { op_->payload->send_message.send_message = send_message; } + grpc_byte_stream **recv_message() const { + return op_->recv_message ? op_->payload->recv_message.recv_message + : nullptr; + } + void set_recv_message(grpc_byte_stream **recv_message) { + op_->recv_message = true; + op_->payload->recv_message.recv_message = recv_message; + } + census_context *get_census_context() const { return (census_context *)op_->payload->context[GRPC_CONTEXT_TRACING].value; } |