Home
last modified time | relevance | path

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

/third_party/grpc/test/cpp/qps/
Dclient_sync.cc64 virtual bool InitThreadFuncImpl(size_t thread_idx) = 0;
65 virtual bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) = 0;
67 void ThreadFunc(size_t thread_idx, Thread* t) override { in ThreadFunc() argument
68 if (!InitThreadFuncImpl(thread_idx)) { in ThreadFunc()
74 const bool thread_still_ok = ThreadFuncImpl(&entry, thread_idx); in ThreadFunc()
84 bool WaitToIssue(int thread_idx) { in WaitToIssue() argument
86 const gpr_timespec next_issue_time = NextIssueTime(thread_idx); in WaitToIssue()
122 bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) override { in ThreadFuncImpl() argument
123 if (!WaitToIssue(thread_idx)) { in ThreadFuncImpl()
126 auto* stub = channels_[thread_idx % channels_.size()].get_stub(); in ThreadFuncImpl()
[all …]
Dclient_callback.cc111 virtual void InitThreadFuncImpl(size_t thread_idx) = 0;
112 virtual bool ThreadFuncImpl(Thread* t, size_t thread_idx) = 0;
114 void ThreadFunc(size_t thread_idx, Thread* t) override { in ThreadFunc() argument
115 InitThreadFuncImpl(thread_idx); in ThreadFunc()
116 ThreadFuncImpl(t, thread_idx); in ThreadFunc()
157 bool ThreadFuncImpl(Thread* t, size_t thread_idx) override { in ThreadFuncImpl() argument
158 for (size_t vector_idx = thread_idx; vector_idx < total_outstanding_rpcs_; in ThreadFuncImpl()
351 bool ThreadFuncImpl(Client::Thread* t, size_t thread_idx) override { in ThreadFuncImpl() argument
352 for (size_t vector_idx = thread_idx; vector_idx < total_outstanding_rpcs_; in ThreadFuncImpl()
Dclient.h241 gpr_timespec NextIssueTime(int thread_idx) { in NextIssueTime() argument
242 const gpr_timespec result = next_time_[thread_idx]; in NextIssueTime()
243 next_time_[thread_idx] = in NextIssueTime()
244 gpr_time_add(next_time_[thread_idx], in NextIssueTime()
245 gpr_time_from_nanos(interarrival_timer_.next(thread_idx), in NextIssueTime()
385 std::function<gpr_timespec()> NextIssuer(int thread_idx) { in NextIssuer() argument
387 : std::bind(&Client::NextIssueTime, this, thread_idx); in NextIssuer()
390 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()
/third_party/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()