Lines Matching defs:thread_idx
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()
289 bool InitThreadFuncImpl(size_t thread_idx) override { in InitThreadFuncImpl()
302 bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) override { in ThreadFuncImpl()
339 bool InitThreadFuncImpl(size_t thread_idx) override { in InitThreadFuncImpl()
352 bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) override { in ThreadFuncImpl()
382 [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); }); in ~SynchronousStreamingBothWaysClient()
386 bool InitThreadFuncImpl(size_t thread_idx) override { in InitThreadFuncImpl()