aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/cpp/common/channel_filter.h
diff options
context:
space:
mode:
authorGravatar Mark D. Roth <roth@google.com>2017-08-31 10:05:47 -0700
committerGravatar GitHub <noreply@github.com>2017-08-31 10:05:47 -0700
commit8d51e8d17e012f81ca8e94c18f525e1781130481 (patch)
treec7e3fbda5f9080a38ecd6bb19401f430b029ceac /src/cpp/common/channel_filter.h
parent179f1369c3e13ed70241b87909c2a7fb229c3bd9 (diff)
parent196fa2e154c52ffc5bed76ff8b54093117632811 (diff)
Merge pull request #12331 from markdroth/c++_filter_api_fix
Add recv_message() method to TransportStreamOpBatch class.
Diffstat (limited to 'src/cpp/common/channel_filter.h')
-rw-r--r--src/cpp/common/channel_filter.h9
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;
}