| /external/grpc-grpc/test/cpp/qps/ |
| D | client_sync.cc | 65 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 …]
|
| D | client.h | 290 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;
|
| D | client_async.cc | 241 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()
|
| D | server_async.cc | 202 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/perfetto/tools/ |
| D | multithreaded_alloc.cc | 63 uint64_t ScrambleAllocId(uint64_t alloc_id, uint32_t thread_idx) { in ScrambleAllocId() argument
64 return thread_idx | (~alloc_id << 24); in ScrambleAllocId()
67 void Thread(uint32_t thread_idx, uint64_t pending_allocs) { in Thread() argument
68 PERFETTO_CHECK(thread_idx < 1 << 24); in Thread()
73 ScrambleAllocId(alloc_id, thread_idx), 1); in Thread()
76 g_heap_id, ScrambleAllocId(alloc_id - pending_allocs, thread_idx)); in Thread()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | depthtospace_op_gpu.cu.cc | 107 GPU_1D_KERNEL_LOOP(thread_idx, nthreads) { in D2S_NCHW_LOOP()
119 const int n_oC_iY = thread_idx / input_width; in D2S_NCHW_LOOP()
120 const int iX = thread_idx - n_oC_iY * input_width; in D2S_NCHW_LOOP()
122 const int n = thread_idx / output_depth_by_input_area; in D2S_NCHW_LOOP()
123 const int oC_iY_iX = thread_idx - n * output_depth_by_input_area; in D2S_NCHW_LOOP()
|
| D | spacetodepth_op_gpu.cu.cc | 108 GPU_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()
|
| D | depthwise_conv_op_gpu.h | 241 const int thread_idx = thread_pix * kBlockDepth + thread_depth;
244 for (int i = thread_idx; i < tile_size; i += block_size) {
262 thread_pix < filter_pixels ? tile_size + thread_idx : 0;
531 const int thread_idx = thread_depth * block_pixels + thread_pix;
534 for (int i = thread_idx; i < tile_size; i += block_size) {
550 const int filter_pix = thread_idx / kBlockDepth;
551 const int filter_channel = thread_idx % kBlockDepth;
556 filter_pix < filter_pixels ? tile_size + thread_idx : 0;
1216 const int thread_idx = thread_pix * kBlockDepth + thread_depth;
1219 for (int i = thread_idx; i < tile_size + accum_size; i += block_size) {
[all …]
|
| /external/llvm-project/lldb/source/Commands/ |
| D | CommandObjectThreadUtil.cpp | 57 uint32_t thread_idx; in DoExecute() local
58 if (!llvm::to_integer(command.GetArgumentAtIndex(i), thread_idx)) { in DoExecute()
66 process->GetThreadList().FindThreadByIndexID(thread_idx); in DoExecute()
|
| D | CommandObjectThread.cpp | 669 uint32_t thread_idx; in DoExecute() local
670 if (entry.ref().getAsInteger(0, thread_idx)) { in DoExecute()
677 process->GetThreadList().FindThreadByIndexID(thread_idx).get(); in DoExecute()
683 thread_idx); in DoExecute()
|
| /external/llvm-project/lldb/tools/lldb-vscode/ |
| D | lldb-vscode.cpp | 203 for (uint32_t thread_idx = 0; thread_idx < num_threads; ++thread_idx) { in SendThreadStoppedEvent() local
204 lldb::SBThread thread = process.GetThreadAtIndex(thread_idx); in SendThreadStoppedEvent()
229 for (uint32_t thread_idx = 0; thread_idx < num_threads; ++thread_idx) { in SendThreadStoppedEvent() local
230 lldb::SBThread thread = process.GetThreadAtIndex(thread_idx); in SendThreadStoppedEvent()
2528 for (uint32_t thread_idx = 0; thread_idx < num_threads; ++thread_idx) { in request_threads() local
2529 lldb::SBThread thread = process.GetThreadAtIndex(thread_idx); in request_threads()
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | stress_test.cc | 274 int thread_idx = 0; in main() local
297 ++thread_idx, *it, channel_creation_func, test_selector, in main()
|
| /external/llvm-project/lldb/examples/python/ |
| D | crashlog.py | 644 thread_idx = int(thread_state_match.group(1))
646 self.thread = self.crashlog.threads[thread_idx]
656 thread_idx = int(thread_match.group(1))
657 self.thread = self.crashlog.Thread(thread_idx, False)
912 for thread_idx in range(process.num_threads):
913 thread = process.thread[thread_idx]
914 out_file.write('\nThread %u:\n' % (thread_idx))
|
| /external/llvm-project/lldb/source/API/ |
| D | SBBreakpointLocation.cpp | 345 uint32_t thread_idx = UINT32_MAX; in GetThreadIndex() local
352 return thread_idx; in GetThreadIndex()
|
| D | SBBreakpoint.cpp | 394 uint32_t thread_idx = UINT32_MAX; in GetThreadIndex() local
402 thread_idx = thread_spec->GetIndex(); in GetThreadIndex()
405 return thread_idx; in GetThreadIndex()
|
| /external/mesa3d/src/broadcom/vulkan/ |
| D | v3dv_queue.c | 909 const uint32_t thread_idx = (*wait_info)->wait_thread_count; in add_wait_thread_to_list() local
910 assert(thread_idx < 16); in add_wait_thread_to_list()
911 (*wait_info)->wait_threads[thread_idx].thread = thread; in add_wait_thread_to_list()
912 (*wait_info)->wait_threads[thread_idx].finished = false; in add_wait_thread_to_list()
|
| /external/llvm-project/lldb/tools/debugserver/source/ |
| D | DNB.h | 127 nub_size_t thread_idx) DNB_EXPORT;
|
| D | DNB.cpp | 1394 nub_thread_t DNBProcessGetThreadAtIndex(nub_process_t pid, size_t thread_idx) { in DNBProcessGetThreadAtIndex() argument
1397 return procSP->GetThreadAtIndex(thread_idx); in DNBProcessGetThreadAtIndex()
|
| /external/llvm-project/lldb/tools/debugserver/source/MacOSX/ |
| D | MachProcess.h | 274 nub_thread_t GetThreadAtIndex(nub_size_t thread_idx) const;
|
| D | MachProcess.mm | 570 nub_thread_t MachProcess::GetThreadAtIndex(nub_size_t thread_idx) const {
571 return m_thread_list.ThreadIDAtIndex(thread_idx);
1551 uint32_t thread_idx =
1554 *thread_idx_ptr = thread_idx;
1555 if (thread_idx != UINT32_MAX)
1589 uint32_t thread_idx =
1592 *thread_idx_ptr = thread_idx;
1599 uint32_t thread_idx = UINT32_MAX;
1600 nub_state_t state = DoSIGSTOP(true, true, &thread_idx);
1608 thread_action.tid = m_thread_list.ThreadIDAtIndex(thread_idx);
|
| /external/google-breakpad/src/client/mac/handler/ |
| D | minidump_generator.cc | 1013 int thread_idx = 0; in WriteThreadListStream() local
1022 list.CopyIndexAfterObject(thread_idx++, &thread, sizeof(MDRawThread)); in WriteThreadListStream()
|
| /external/llvm-project/lldb/source/Plugins/ObjectFile/Mach-O/ |
| D | ObjectFileMachO.cpp | 6264 for (uint32_t thread_idx = 0; thread_idx < num_threads; ++thread_idx) { in SaveCore() local
6265 ThreadSP thread_sp(thread_list.GetThreadAtIndex(thread_idx)); in SaveCore()
6271 thread_sp.get(), LC_THREAD_datas[thread_idx]); in SaveCore()
6276 thread_sp.get(), LC_THREAD_datas[thread_idx]); in SaveCore()
6281 thread_sp.get(), LC_THREAD_datas[thread_idx]); in SaveCore()
6286 thread_sp.get(), LC_THREAD_datas[thread_idx]); in SaveCore()
|
| /external/llvm-project/lldb/source/Plugins/Process/gdb-remote/ |
| D | GDBRemoteCommunicationServerLLGS.cpp | 590 uint32_t thread_idx = 0; in GetJSONThreadsInfo() local
592 (thread = process.GetThreadAtIndex(thread_idx)) != nullptr; in GetJSONThreadsInfo()
593 ++thread_idx) { in GetJSONThreadsInfo()
|