Searched refs:lrs_calld (Results 1 – 4 of 4) sorted by relevance
500 XdsClient::ChannelState::LrsCallState* XdsClient::ChannelState::lrs_calld() in lrs_calld() function in grpc_core::XdsClient::ChannelState1209 LrsCallState* lrs_calld = lrs_call->calld(); in OnResponseReceivedLocked() local1210 if (lrs_calld != nullptr) lrs_calld->MaybeStartReportingLocked(); in OnResponseReceivedLocked()1561 LrsCallState* lrs_calld = static_cast<LrsCallState*>(arg); in OnInitialRequestSent() local1563 MutexLock lock(&lrs_calld->xds_client()->mu_); in OnInitialRequestSent()1564 lrs_calld->OnInitialRequestSentLocked(); in OnInitialRequestSent()1566 lrs_calld->Unref(DEBUG_LOCATION, "LRS+OnInitialRequestSentLocked"); in OnInitialRequestSent()1578 LrsCallState* lrs_calld = static_cast<LrsCallState*>(arg); in OnResponseReceived() local1581 MutexLock lock(&lrs_calld->xds_client()->mu_); in OnResponseReceived()1582 done = lrs_calld->OnResponseReceivedLocked(); in OnResponseReceived()[all …]
213 LrsCallState* lrs_calld() const;
510 XdsClient::ChannelState::LrsCallState* XdsClient::ChannelState::lrs_calld() in lrs_calld() function in grpc_core::XdsClient::ChannelState1262 LrsCallState* lrs_calld = lrs_call->calld(); in OnResponseReceivedLocked() local1263 if (lrs_calld != nullptr) lrs_calld->MaybeStartReportingLocked(); in OnResponseReceivedLocked()1603 LrsCallState* lrs_calld = static_cast<LrsCallState*>(arg); in OnInitialRequestSent() local1604 lrs_calld->xds_client()->work_serializer_->Run( in OnInitialRequestSent()1605 [lrs_calld]() { lrs_calld->OnInitialRequestSentLocked(); }, in OnInitialRequestSent()1619 LrsCallState* lrs_calld = static_cast<LrsCallState*>(arg); in OnResponseReceived() local1620 lrs_calld->xds_client()->work_serializer_->Run( in OnResponseReceived()1621 [lrs_calld]() { lrs_calld->OnResponseReceivedLocked(); }, DEBUG_LOCATION); in OnResponseReceived()1721 LrsCallState* lrs_calld = static_cast<LrsCallState*>(arg); in OnStatusReceived() local[all …]
175 LrsCallState* lrs_calld() const;