Searched refs:channels_ (Results 1 – 9 of 9) sorted by relevance
126 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl()231 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl()263 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl()290 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl()316 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl()340 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl()361 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl()387 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in InitThreadFuncImpl()
149 new CallbackClientRpcContext(channels_[ch].get_stub())); in CallbackUnaryClient()221 new CallbackClientRpcContext(channels_[ch].get_stub())); in CallbackStreamingClient()
431 channels_.emplace_back( in ClientImpl()464 for (auto& c : channels_) { in WaitForChannelsToConnect()560 std::vector<ClientChannelInfo> channels_; variable
158 using ClientImpl<StubType, RequestType>::channels_;188 setup_ctx(channels_[ch].get_stub(), next_issuers_[t], request_); in AsyncClient()
75 channels_ = audio_params.channels(); in CefAudioCapturer()92 audio_handler_->OnAudioStreamStarted(browser_, params_, channels_); in OnCaptureStarted()103 DCHECK(channels == channels_); in Capture()
47 int channels_ = 0; variable
451 channels_[session_id] = std::make_unique<ChannelImpl>(env_, in connectFrontend()461 auto it = channels_.find(session_id); in disconnectFrontend()462 if (it == channels_.end()) in disconnectFrontend()465 channels_.erase(it); in disconnectFrontend()467 for (const auto& id_channel : channels_) { in disconnectFrontend()478 channels_[session_id]->dispatchProtocolMessage(message); in dispatchMessageFromFrontend()560 for (const auto& id_channel : channels_) { in schedulePauseOnNextStatement()566 for (const auto& id_channel : channels_) { in hasConnectedSessions()576 for (const auto& id_channel : channels_) { in notifyWaitingForDisconnect()603 return !channels_.empty(); in IsActive()[all …]
432 GPR_DEBUG_ASSERT(channels_.empty()); in FillChannelsLocked()433 channels_ = std::move(channels); in FillChannelsLocked()438 for (grpc_channel* channel : channels_) { in BroadcastShutdown()442 channels_.clear(); // just for safety against double broadcast in BroadcastShutdown()479 std::vector<grpc_channel*> channels_; member in grpc_core::__anon77831d3a0511::ChannelBroadcaster637 return !channels_.empty(); in HasOpenConnections()722 if (!channels_.empty() || listeners_destroyed_ < listeners_.size()) { in MaybeFinishShutdown()730 channels_.size(), listeners_.size() - listeners_destroyed_, in MaybeFinishShutdown()757 channels.reserve(channels_.size()); in GetChannelsLocked()758 for (const ChannelData* chand : channels_) { in GetChannelsLocked()[all …]
392 std::list<ChannelData*> channels_; variable