Searched refs:service_thread (Results 1 – 6 of 6) sorted by relevance
46 ServiceThread service_thread(nullptr); in TEST() local47 service_thread.Start(); in TEST()49 service_thread.task_runner()->PostTask( in TEST()52 service_thread.FlushForTesting(); in TEST()
74 uint64_t service_start_ns = helper.service_thread()->GetThreadCPUTimeNs(); in BenchmarkProducer()84 helper.service_thread()->GetThreadCPUTimeNs() - service_start_ns; in BenchmarkProducer()152 static_cast<uint64_t>(helper.service_thread()->GetThreadCPUTimeNs()); in BenchmarkConsumer()194 helper.service_thread()->GetThreadCPUTimeNs() - service_start_ns; in BenchmarkConsumer()
82 TaskRunnerThread* service_thread() { return &service_thread_; } in service_thread() function
47 static void *service_thread(struct workorder *);202 if (pthread_create(&tdata, NULL, (void *)service_thread, work) < 0) { in create_thread()230 service_thread(struct workorder *work) in service_thread() function
55 thread.start_new_thread(service_thread, (conn, addr))58 def service_thread(conn, addr): function
77 service_thread = threading.Thread(84 service_thread.start()