From 196fa2e154c52ffc5bed76ff8b54093117632811 Mon Sep 17 00:00:00 2001 From: "Mark D. Roth" Date: Wed, 30 Aug 2017 07:34:03 -0700 Subject: Add recv_message() method to TransportStreamOpBatch class. --- src/cpp/common/channel_filter.h | 9 +++++++++ 1 file changed, 9 insertions(+) (limited to 'src') diff --git a/src/cpp/common/channel_filter.h b/src/cpp/common/channel_filter.h index 5d629f7c14..64a0ba5312 100644 --- a/src/cpp/common/channel_filter.h +++ b/src/cpp/common/channel_filter.h @@ -193,6 +193,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; } -- cgit v1.2.3