| /external/libiio/src/iiod/ |
| D | ops.c | 57 static void thd_entry_event_signal(struct ThdEntry *thd) in thd_entry_event_signal() argument
63 ret = write(thd->eventfd, &e, sizeof(e)); in thd_entry_event_signal()
67 static int thd_entry_event_wait(struct ThdEntry *thd, pthread_mutex_t *mutex, in thd_entry_event_wait() argument
76 pfd[0].fd = thd->eventfd; in thd_entry_event_wait()
80 pfd[2].fd = thread_pool_get_poll_fd(thd->pdata->pool); in thd_entry_event_wait()
92 ret = read(thd->eventfd, &e, sizeof(e)); in thd_entry_event_wait()
415 static ssize_t send_data(struct DevEntry *dev, struct ThdEntry *thd, size_t len) in send_data() argument
417 struct parser_pdata *pdata = thd->pdata; in send_data()
418 bool demux = server_demux && dev->sample_size != thd->sample_size; in send_data()
421 len = (len / dev->sample_size) * thd->sample_size; in send_data()
[all …]
|
| D | thread-pool.c | 85 pthread_t thd; in thread_pool_add_thread() local
108 ret = pthread_create(&thd, &attr, thread_body, pdata); in thread_pool_add_thread()
114 pthread_setname_np(thd, name); in thread_pool_add_thread()
|
| /external/oss-fuzz/projects/mysql-server/targets/ |
| D | fuzz_mysqld.cc | 56 THD *thd = new (std::nothrow) THD(); in create_thd() local
57 if (thd == NULL) { in create_thd()
61 thd->get_protocol_classic()->init_net(vio_tmp); in create_thd()
62 thd->set_admin_connection(m_is_admin_conn); in create_thd()
63 init_net_server_extension(thd); in create_thd()
64 return thd; in create_thd()
76 THD *thd = channel_info->create_thd(); in try_connection() local
77 if (thd == NULL) { in try_connection()
82 thd->set_new_thread_id(); in try_connection()
92 thd_set_thread_stack(thd, (char *)&thd); in try_connection()
[all …]
|
| D | fuzz_docommand.cc | 91 THD *thd = new (std::nothrow) THD(); in create_thd() local
92 if (thd == NULL) { in create_thd()
96 thd->get_protocol_classic()->init_net(vio_tmp); in create_thd()
97 thd->set_admin_connection(m_is_admin_conn); in create_thd()
98 init_net_server_extension(thd); in create_thd()
99 return thd; in create_thd()
|
| /external/jemalloc_new/test/src/ |
| D | thd.c | 5 thd_create(thd_t *thd, void *(*proc)(void *), void *arg) { in thd_create() argument
7 *thd = CreateThread(NULL, 0, routine, arg, 0, NULL); in thd_create()
8 if (*thd == NULL) { in thd_create()
14 thd_join(thd_t thd, void **ret) { in thd_join() argument
15 if (WaitForSingleObject(thd, INFINITE) == WAIT_OBJECT_0 && ret) { in thd_join()
17 GetExitCodeThread(thd, (LPDWORD) &exit_code); in thd_join()
24 thd_create(thd_t *thd, void *(*proc)(void *), void *arg) { in thd_create() argument
25 if (pthread_create(thd, NULL, proc, arg) != 0) { in thd_create()
31 thd_join(thd_t thd, void **ret) { in thd_join() argument
32 pthread_join(thd, ret); in thd_join()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | wakeup_fd_cv_test.cc | 137 grpc_core::Thread thd("grpc_background_poll", &background_poll, &pargs); in test_poll_cv_trigger() local
138 thd.Start(); in test_poll_cv_trigger()
141 thd.Join(); in test_poll_cv_trigger()
155 grpc_core::Thread thd("grpc_background_poll", &background_poll, &pargs); in test_poll_cv_trigger() local
156 thd.Start(); in test_poll_cv_trigger()
158 thd.Join(); in test_poll_cv_trigger()
172 grpc_core::Thread thd("grpc_background_poll", &background_poll, &pargs); in test_poll_cv_trigger() local
173 thd.Start(); in test_poll_cv_trigger()
175 thd.Join(); in test_poll_cv_trigger()
189 grpc_core::Thread thd("grpc_background_poll", &background_poll, &pargs); in test_poll_cv_trigger() local
[all …]
|
| D | resolve_address_posix_test.cc | 41 grpc_core::Thread thd; member
63 args->thd.Join(); in args_finish()
108 args->thd = grpc_core::Thread("grpc_poll_pollset", actually_poll, args); in poll_pollset_until_request_done()
109 args->thd.Start(); in poll_pollset_until_request_done()
|
| /external/jemalloc_new/test/unit/ |
| D | tsd.c | 73 thd_t thd; in TEST_BEGIN() local
76 thd_create(&thd, thd_start, (void *)MALLOC_TSD_TEST_DATA_INIT); in TEST_BEGIN()
77 thd_join(thd, NULL); in TEST_BEGIN()
121 thd_t thd; in TEST_BEGIN() local
122 thd_create(&thd, thd_start_reincarnated, NULL); in TEST_BEGIN()
123 thd_join(thd, NULL); in TEST_BEGIN()
|
| /external/grpc-grpc/test/core/gpr/ |
| D | cpu_test.cc | 116 grpc_core::Thread* thd = in cpu_test() local
117 static_cast<grpc_core::Thread*>(gpr_malloc(sizeof(*thd) * nthreads)); in cpu_test()
120 thd[i] = grpc_core::Thread("grpc_cpu_test", &worker_thread, &ct); in cpu_test()
121 thd[i].Start(); in cpu_test()
129 thd[i].Join(); in cpu_test()
131 gpr_free(thd); in cpu_test()
|
| /external/perfetto/test/stress_test/ |
| D | stress_test.cc | 257 const auto& thd = it.second; in RunConfig() local
258 if (!thd.last_seen) { in RunConfig()
261 if (thd.seq_errors > 0) { in RunConfig()
263 thd.seq_errors); in RunConfig()
265 if (thd.counter_errors > 0) { in RunConfig()
267 thd.counter_errors); in RunConfig()
331 ParsedTraceStats::WriterThread& thd = t_it->second; in ParseTracePacket() local
333 ++thd.packets_seen; in ParseTracePacket()
335 if (thd.last_seen) { in ParseTracePacket()
339 thd.last_seen = true; in ParseTracePacket()
[all …]
|
| /external/grpc-grpc/test/core/gprpp/ |
| D | fork_test.cc | 83 for (auto& thd : thds) { in test_thd_count() local
84 thd.Join(); in test_thd_count()
118 grpc_core::Thread thd = in test_exec_count() local
123 thd.Start(); in test_exec_count()
128 thd.Join(); // This ensure that the call got un-blocked in test_exec_count()
|
| /external/ltp/testcases/misc/math/float/ |
| D | main.c | 325 int thd; in handle_signals() local
377 for (thd = 0; thd < indice; thd++) { in handle_signals()
382 "%d)", thd, indice); in handle_signals()
384 pthread_cancel(threads[thd]); in handle_signals()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 97 void ThreadManager::MarkAsCompleted(WorkerThread* thd) { in MarkAsCompleted() argument
100 completed_threads_.push_back(thd); in MarkAsCompleted()
123 for (auto thd : completed_threads) delete thd; in CleanupCompletedThreads() local
|
| /external/grpc-grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 96 void ThreadManager::MarkAsCompleted(WorkerThread* thd) { in MarkAsCompleted() argument
99 completed_threads_.push_back(thd); in MarkAsCompleted()
122 for (auto thd : completed_threads) delete thd; in CleanupCompletedThreads() local
|
| /external/jemalloc_new/test/integration/ |
| D | thread_tcache_enabled.c | 71 thd_t thd; in TEST_BEGIN() local
73 thd_create(&thd, thd_start, NULL); in TEST_BEGIN()
74 thd_join(thd, NULL); in TEST_BEGIN()
|
| D | allocated.c | 108 thd_t thd; in TEST_BEGIN() local
110 thd_create(&thd, thd_start, NULL); in TEST_BEGIN()
111 thd_join(thd, NULL); in TEST_BEGIN()
|
| /external/jemalloc_new/test/include/test/ |
| D | thd.h | 8 void thd_create(thd_t *thd, void *(*proc)(void *), void *arg);
9 void thd_join(thd_t thd, void **ret);
|
| /external/grpc-grpc/src/ruby/end2end/ |
| D | killed_client_thread_client.rb | 33 thd = Thread.new do
40 thd.join
|
| D | sig_int_during_channel_watch_client.rb | 36 thd = Thread.new do
54 thd.join
|
| D | multiple_killed_watching_threads_driver.rb | 24 thd = Thread.new do
32 thd.kill
|
| D | channel_closing_client.rb | 48 thd = Thread.new do
66 thd.join
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | timer_manager.cc | 33 grpc_core::Thread thd; member
73 to_gc->thd.Join(); in gc_completed_threads()
92 ct->thd = grpc_core::Thread("grpc_global_timer", timer_thread, ct); in start_timer_thread_and_unlock()
93 ct->thd.Start(); in start_timer_thread_and_unlock()
|
| D | executor.cc | 160 thd_state_[i].thd = grpc_core::Thread(); in SetThreading()
164 thd_state_[0].thd = in SetThreading()
166 thd_state_[0].thd.Start(); in SetThreading()
187 thd_state_[i].thd.Join(); in SetThreading()
370 thd_state_[cur_thread_count].thd = grpc_core::Thread( in Enqueue()
372 thd_state_[cur_thread_count].thd.Start(); in Enqueue()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | timer_manager.cc | 32 grpc_core::Thread thd; member
70 to_gc->thd.Join(); in gc_completed_threads()
89 ct->thd = grpc_core::Thread("grpc_global_timer", timer_thread, ct); in start_timer_thread_and_unlock()
90 ct->thd.Start(); in start_timer_thread_and_unlock()
|
| D | executor.cc | 110 thd_state_[i].thd = grpc_core::Thread(); in SetThreading()
114 thd_state_[0].thd = in SetThreading()
116 thd_state_[0].thd.Start(); in SetThreading()
137 thd_state_[i].thd.Join(); in SetThreading()
306 thd_state_[cur_thread_count].thd = grpc_core::Thread( in Enqueue()
308 thd_state_[cur_thread_count].thd.Start(); in Enqueue()
|