diff options
author | 2018-06-21 22:44:05 -0700 | |
---|---|---|
committer | 2018-06-22 10:00:48 -0700 | |
commit | f5f1d57d7abdd68c9037576729e3e85437aaa833 (patch) | |
tree | 9437b97cf60393bf853807ab1e347c1561affa1a /src/cpp/common/channel_filter.h | |
parent | 7a2a8ca4ba2cd505961ac43c656cc0a7a33c7bb0 (diff) |
Add load reporting filter
Diffstat (limited to 'src/cpp/common/channel_filter.h')
-rw-r--r-- | src/cpp/common/channel_filter.h | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/src/cpp/common/channel_filter.h b/src/cpp/common/channel_filter.h index bd0ec969b4..5e569c97e6 100644 --- a/src/cpp/common/channel_filter.h +++ b/src/cpp/common/channel_filter.h @@ -207,6 +207,18 @@ class TransportStreamOpBatch { op_->payload->context[GRPC_CONTEXT_TRACING].value); } + const gpr_atm* get_peer_string() const { + if (op_->send_initial_metadata && + op_->payload->send_initial_metadata.peer_string != nullptr) { + return op_->payload->send_initial_metadata.peer_string; + } else if (op_->recv_initial_metadata && + op_->payload->recv_initial_metadata.peer_string != nullptr) { + return op_->payload->recv_initial_metadata.peer_string; + } else { + return nullptr; + } + } + private: grpc_transport_stream_op_batch* op_; // Not owned. MetadataBatch send_initial_metadata_; |