Searched defs:thread_idx (Results 1 – 6 of 6) sorted by relevance
67 void ThreadFunc(size_t thread_idx, Thread* t) override { in ThreadFunc()84 bool WaitToIssue(int thread_idx) { in WaitToIssue()122 bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) override { in ThreadFuncImpl()157 CleanupAllStreams([this](size_t thread_idx) { in ~SynchronousStreamingClient()177 void FinishStream(HistogramEntry* entry, size_t thread_idx) { in FinishStream()213 [this](size_t thread_idx) { context_[thread_idx].TryCancel(); }); in DestroyMultithreading()226 [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); }); in ~SynchronousStreamingPingPongClient()230 bool InitThreadFuncImpl(size_t thread_idx) override { in InitThreadFuncImpl()242 bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) override { in ThreadFuncImpl()283 [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); }); in ~SynchronousStreamingFromClientClient()[all …]
114 void ThreadFunc(size_t thread_idx, Thread* t) override { in ThreadFunc()157 bool ThreadFuncImpl(Thread* t, size_t thread_idx) override { in ThreadFuncImpl()351 bool ThreadFuncImpl(Client::Thread* t, size_t thread_idx) override { in ThreadFuncImpl()
241 gpr_timespec NextIssueTime(int thread_idx) { in NextIssueTime()385 std::function<gpr_timespec()> NextIssuer(int thread_idx) { in NextIssuer()
241 ClientRpcContext* ProcessTag(size_t thread_idx, void* tag) { in ProcessTag()257 void ThreadFunc(size_t thread_idx, Client::Thread* t) override final { in ThreadFunc()
202 void ThreadFunc(int thread_idx) { in ThreadFunc()
274 int thread_idx = 0; in main() local