| /third_party/grpc/test/cpp/qps/ |
| D | client_sync.cc | 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()
|
| D | client_callback.cc | 149 new CallbackClientRpcContext(channels_[ch].get_stub())); in CallbackUnaryClient()
221 new CallbackClientRpcContext(channels_[ch].get_stub())); in CallbackStreamingClient()
|
| D | client.h | 431 channels_.emplace_back( in ClientImpl()
464 for (auto& c : channels_) { in WaitForChannelsToConnect()
560 std::vector<ClientChannelInfo> channels_; variable
|
| D | client_async.cc | 158 using ClientImpl<StubType, RequestType>::channels_;
188 setup_ctx(channels_[ch].get_stub(), next_issuers_[t], request_); in AsyncClient()
|
| /third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/gpu/nn/ |
| D | roi_align_gpu_kernel.h | 39 channels_(0), in ROIAlignGpuFwdKernel()
61 …is, roi_rows_, roi_cols_, out_data, spatial_scale_, sample_num_, roi_end_mode_, channels_, height_, in Launch()
99 channels_ = x_shape[1]; in Init()
102 x_shape_ = {batch_N_, channels_, height_, width_}; in Init()
103 x_size_ = batch_N_ * channels_ * height_ * width_ * sizeof(T); in Init()
123 output_shape_ = {roi_rows_, channels_, pooled_height_, pooled_width_}; in Init()
151 int channels_; variable
|
| D | roi_align_grad_gpu_kernel.h | 39 channels_(0), in ROIAlignGradGpuFwdKernel()
60 …rois, batch_size_, roi_rows_, roi_cols_, dx, spatial_scale_, sample_num_, roi_end_mode_, channels_, in Launch()
128 channels_ = xdiff_shape_[1]; in Init()
133 output_shape_ = {batch_size_, channels_, height_, width_}; in Init()
134 output_size_ = batch_size_ * channels_ * height_ * width_ * sizeof(T); in Init()
158 int channels_; variable
|
| /third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/cpu/nnacl/fp32/ |
| D | roi_pooling_fp32.c | 39 int channels_ = param->input_c_; in ROIPooling() local
74 for (int j = 0; j < channels_; ++j) { in ROIPooling()
82 for (int c = 0; c < channels_; ++c) { in ROIPooling()
89 for (int j = 0; j < channels_; ++j) { in ROIPooling()
|
| /third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/cpu/ |
| D | roi_align_grad_cpu_kernel.cc | 103 channels_ = xdiff_shape_[CHANNEL]; in InitKernel()
116 int size_init = batch_size_ * channels_ * height_ * width_; in Launch()
125 int elem_num = roi_rows_ * channels_ * pooled_height_ * pooled_width_; in Launch()
129 int n = SizeToInt(thread_idx) / pooled_width_ / pooled_height_ / channels_; in Launch()
138 …_box(SizeToInt(thread_idx), rois, roi_cols_, spatial_scale_, sample_num_, roi_end_mode_, channels_, in Launch()
145 int top_offset = (n * channels_ + c) * pooled_height_ * pooled_width_; in Launch()
|
| D | roi_align_cpu_kernel.cc | 40 channels_ = SizeToInt(x_shape[CHANNEL]); in InitKernel()
62 size_t elem_num = IntToSize(roi_rows_ * channels_ * pooled_height_ * pooled_width_); in Launch()
67 int n = SizeToInt(thread_idx) / pooled_width_ / pooled_height_ / channels_; in Launch()
76 …_box(SizeToInt(thread_idx), rois, roi_cols_, spatial_scale_, sample_num_, roi_end_mode_, channels_, in Launch()
|
| D | roi_align_cpu_kernel.h | 46 int channels_{0};
|
| D | roi_align_grad_cpu_kernel.h | 54 int channels_{0};
|
| /third_party/cef/libcef/browser/ |
| D | audio_capturer.cc | 75 channels_ = audio_params.channels(); in CefAudioCapturer()
92 audio_handler_->OnAudioStreamStarted(browser_, params_, channels_); in OnCaptureStarted()
103 DCHECK(channels == channels_); in Capture()
|
| D | audio_capturer.h | 48 int channels_ = 0; variable
|
| /third_party/node/src/ |
| D | inspector_agent.cc | 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 …]
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.cc | 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::__anonc9509c770511::ChannelBroadcaster
637 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 …]
|
| D | server.h | 392 std::list<ChannelData*> channels_; variable
|