Searched refs:recv_message_payload_ (Results 1 – 3 of 3) sorted by relevance
287 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::XdsClient::ChannelState::AdsCallState384 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::XdsClient::ChannelState::LrsCallState740 op->data.recv_message.recv_message = &recv_message_payload_; in AdsCallState()773 grpc_byte_buffer_destroy(recv_message_payload_); in ~AdsCallState()1158 if (!IsCurrentCallOnChannel() || recv_message_payload_ == nullptr) { in OnResponseReceivedLocked()1163 grpc_byte_buffer_reader_init(&bbr, recv_message_payload_); in OnResponseReceivedLocked()1166 grpc_byte_buffer_destroy(recv_message_payload_); in OnResponseReceivedLocked()1167 recv_message_payload_ = nullptr; in OnResponseReceivedLocked()1225 op.data.recv_message.recv_message = &recv_message_payload_; in OnResponseReceivedLocked()1493 op->data.recv_message.recv_message = &recv_message_payload_; in LrsCallState()[all …]
224 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::__anon9fb3300c0111::GrpcLb::BalancerCallState545 grpc_byte_buffer_destroy(recv_message_payload_); in ~BalancerCallState()607 op->data.recv_message.recv_message = &recv_message_payload_; in StartQuery()752 lb_calld->recv_message_payload_ == nullptr) { in OnBalancerMessageReceivedLocked()757 grpc_byte_buffer_reader_init(&bbr, lb_calld->recv_message_payload_); in OnBalancerMessageReceivedLocked()760 grpc_byte_buffer_destroy(lb_calld->recv_message_payload_); in OnBalancerMessageReceivedLocked()761 lb_calld->recv_message_payload_ = nullptr; in OnBalancerMessageReceivedLocked()866 op.data.recv_message.recv_message = &lb_calld->recv_message_payload_; in OnBalancerMessageReceivedLocked()
215 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::__anon524789e00111::GrpcLb::BalancerCallState800 grpc_byte_buffer_destroy(recv_message_payload_); in ~BalancerCallState()863 op->data.recv_message.recv_message = &recv_message_payload_; in StartQuery()1034 recv_message_payload_ == nullptr) { in OnBalancerMessageReceivedLocked()1039 grpc_byte_buffer_reader_init(&bbr, recv_message_payload_); in OnBalancerMessageReceivedLocked()1042 grpc_byte_buffer_destroy(recv_message_payload_); in OnBalancerMessageReceivedLocked()1043 recv_message_payload_ = nullptr; in OnBalancerMessageReceivedLocked()1174 op.data.recv_message.recv_message = &recv_message_payload_; in OnBalancerMessageReceivedLocked()