Searched refs:recv_message_payload_ (Results 1 – 3 of 3) sorted by relevance
288 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::XdsClient::ChannelState::AdsCallState385 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::XdsClient::ChannelState::LrsCallState741 op->data.recv_message.recv_message = &recv_message_payload_; in AdsCallState()774 grpc_byte_buffer_destroy(recv_message_payload_); in ~AdsCallState()1152 if (!IsCurrentCallOnChannel() || recv_message_payload_ == nullptr) { in OnResponseReceivedLocked()1157 grpc_byte_buffer_reader_init(&bbr, recv_message_payload_); in OnResponseReceivedLocked()1160 grpc_byte_buffer_destroy(recv_message_payload_); in OnResponseReceivedLocked()1161 recv_message_payload_ = nullptr; in OnResponseReceivedLocked()1219 op.data.recv_message.recv_message = &recv_message_payload_; in OnResponseReceivedLocked()1487 op->data.recv_message.recv_message = &recv_message_payload_; in LrsCallState()[all …]
275 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::XdsClient::ChannelState::AdsCallState372 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::XdsClient::ChannelState::LrsCallState744 op->data.recv_message.recv_message = &recv_message_payload_; in AdsCallState()777 grpc_byte_buffer_destroy(recv_message_payload_); in ~AdsCallState()1188 if (!IsCurrentCallOnChannel() || recv_message_payload_ == nullptr) { in OnResponseReceivedLocked()1194 grpc_byte_buffer_reader_init(&bbr, recv_message_payload_); in OnResponseReceivedLocked()1197 grpc_byte_buffer_destroy(recv_message_payload_); in OnResponseReceivedLocked()1198 recv_message_payload_ = nullptr; in OnResponseReceivedLocked()1275 op.data.recv_message.recv_message = &recv_message_payload_; in OnResponseReceivedLocked()1529 op->data.recv_message.recv_message = &recv_message_payload_; in LrsCallState()[all …]
215 grpc_byte_buffer* recv_message_payload_ = nullptr; member in grpc_core::__anone44b111d0111::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()