Home
last modified time | relevance | path

Searched refs:thread_idx (Results 1 – 9 of 9) sorted by relevance

/external/grpc-grpc/test/cpp/qps/
Dclient_sync.cc65 virtual bool InitThreadFuncImpl(size_t thread_idx) = 0;
66 virtual bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) = 0;
68 void ThreadFunc(size_t thread_idx, Thread* t) override { in ThreadFunc() argument
69 if (!InitThreadFuncImpl(thread_idx)) { in ThreadFunc()
75 const bool thread_still_ok = ThreadFuncImpl(&entry, thread_idx); in ThreadFunc()
85 bool WaitToIssue(int thread_idx) { in WaitToIssue() argument
87 const gpr_timespec next_issue_time = NextIssueTime(thread_idx); in WaitToIssue()
121 bool InitThreadFuncImpl(size_t thread_idx) override { return true; } in InitThreadFuncImpl() argument
123 bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) override { in ThreadFuncImpl() argument
124 if (!WaitToIssue(thread_idx)) { in ThreadFuncImpl()
[all …]
Dclient.h290 gpr_timespec NextIssueTime(int thread_idx) { in NextIssueTime() argument
291 const gpr_timespec result = next_time_[thread_idx]; in NextIssueTime()
292 next_time_[thread_idx] = in NextIssueTime()
293 gpr_time_add(next_time_[thread_idx], in NextIssueTime()
294 gpr_time_from_nanos(interarrival_timer_.next(thread_idx), in NextIssueTime()
298 std::function<gpr_timespec()> NextIssuer(int thread_idx) { in NextIssuer() argument
300 : std::bind(&Client::NextIssueTime, this, thread_idx); in NextIssuer()
385 virtual void ThreadFunc(size_t thread_idx, Client::Thread* t) = 0;
Dclient_async.cc241 ClientRpcContext* ProcessTag(size_t thread_idx, void* tag) { in ProcessTag() argument
243 if (shutdown_state_[thread_idx]->shutdown) { in ProcessTag()
247 while (cli_cqs_[cq_[thread_idx]]->Next(&tag, &ok)) { in ProcessTag()
257 void ThreadFunc(size_t thread_idx, Client::Thread* t) override final { in ThreadFunc() argument
263 if (!cli_cqs_[cq_[thread_idx]]->Next(&got_tag, &ok)) { in ThreadFunc()
266 std::mutex* shutdown_mu = &shutdown_state_[thread_idx]->mutex; in ThreadFunc()
268 ClientRpcContext* ctx = ProcessTag(thread_idx, got_tag); in ThreadFunc()
273 while (cli_cqs_[cq_[thread_idx]]->DoThenAsyncNext( in ThreadFunc()
278 ctx->StartNewClone(cli_cqs_[cq_[thread_idx]].get()); in ThreadFunc()
287 ctx = ProcessTag(thread_idx, got_tag); in ThreadFunc()
Dserver_async.cc202 void ThreadFunc(int thread_idx) { in ThreadFunc() argument
206 if (!srv_cqs_[cq_[thread_idx]]->Next(&got_tag, &ok)) { in ThreadFunc()
210 std::mutex* mu_ptr = &shutdown_state_[thread_idx]->mutex; in ThreadFunc()
217 if (shutdown_state_[thread_idx]->shutdown) { in ThreadFunc()
221 } while (srv_cqs_[cq_[thread_idx]]->DoThenAsyncNext( in ThreadFunc()
/external/tensorflow/tensorflow/core/kernels/
Ddepthtospace_op_gpu.cu.cc108 CUDA_1D_KERNEL_LOOP(thread_idx, nthreads) { in D2S_NCHW_LOOP()
120 const int n_oC_iY = thread_idx / input_width; in D2S_NCHW_LOOP()
121 const int iX = thread_idx - n_oC_iY * input_width; in D2S_NCHW_LOOP()
123 const int n = thread_idx / output_depth_by_input_area; in D2S_NCHW_LOOP()
124 const int oC_iY_iX = thread_idx - n * output_depth_by_input_area; in D2S_NCHW_LOOP()
Dspacetodepth_op_gpu.cu.cc108 CUDA_1D_KERNEL_LOOP(thread_idx, nthreads) { in S2D_NCHW_LOOP()
120 const int n_iC_oY = thread_idx / output_width; in S2D_NCHW_LOOP()
121 const int oX = thread_idx - n_iC_oY * output_width; in S2D_NCHW_LOOP()
122 const int n = thread_idx / input_depth_by_output_area; in S2D_NCHW_LOOP()
123 const int iC_oY_oX = thread_idx - n * input_depth_by_output_area; in S2D_NCHW_LOOP()
Ddepthwise_conv_op_gpu.h224 const int thread_idx = thread_pix * kBlockDepth + thread_depth; in DepthwiseConv2dGPUKernelNHWCSmall() local
227 for (int i = thread_idx; i < tile_size; i += block_size) { in DepthwiseConv2dGPUKernelNHWCSmall()
245 thread_pix < filter_pixels ? tile_size + thread_idx : 0; in DepthwiseConv2dGPUKernelNHWCSmall()
507 const int thread_idx = thread_depth * block_pixels + thread_pix; in DepthwiseConv2dGPUKernelNCHWSmall() local
510 for (int i = thread_idx; i < tile_size; i += block_size) { in DepthwiseConv2dGPUKernelNCHWSmall()
526 const int filter_pix = thread_idx / kBlockDepth; in DepthwiseConv2dGPUKernelNCHWSmall()
527 const int filter_channel = thread_idx % kBlockDepth; in DepthwiseConv2dGPUKernelNCHWSmall()
532 filter_pix < filter_pixels ? tile_size + thread_idx : 0; in DepthwiseConv2dGPUKernelNCHWSmall()
1220 const int thread_idx = thread_pix * kBlockDepth + thread_depth;
1223 for (int i = thread_idx; i < tile_size + accum_size; i += block_size) {
[all …]
/external/grpc-grpc/test/cpp/interop/
Dstress_test.cc274 int thread_idx = 0; in main() local
297 ++thread_idx, *it, channel_creation_func, test_selector, in main()
/external/google-breakpad/src/client/mac/handler/
Dminidump_generator.cc993 int thread_idx = 0; in WriteThreadListStream() local
1002 list.CopyIndexAfterObject(thread_idx++, &thread, sizeof(MDRawThread)); in WriteThreadListStream()