| /dports/emulators/yuzu/yuzu-0b47f7a46/src/core/hle/kernel/ |
| H A D | synchronization_object.cpp | 27 auto itr = std::find(waiting_threads.begin(), waiting_threads.end(), thread); in AddWaitingThread()
28 if (itr == waiting_threads.end()) in AddWaitingThread()
29 waiting_threads.push_back(std::move(thread)); in AddWaitingThread()
33 auto itr = std::find(waiting_threads.begin(), waiting_threads.end(), thread); in RemoveWaitingThread()
37 if (itr != waiting_threads.end()) in RemoveWaitingThread()
38 waiting_threads.erase(itr); in RemoveWaitingThread()
42 waiting_threads.clear(); in ClearWaitingThreads()
46 return waiting_threads; in GetWaitingThreads()
|
| H A D | address_arbiter.cpp | 29 std::size_t last = waiting_threads.size(); in WakeThreads()
36 waiting_threads[i]->SetSynchronizationResults(nullptr, RESULT_SUCCESS); in WakeThreads()
37 RemoveThread(waiting_threads[i]); in WakeThreads()
38 waiting_threads[i]->WaitForArbitration(false); in WakeThreads()
39 waiting_threads[i]->ResumeFromWait(); in WakeThreads()
62 const std::vector<std::shared_ptr<Thread>> waiting_threads = in SignalToAddressOnly() local
64 WakeThreads(waiting_threads, num_to_wake); in SignalToAddressOnly()
104 const std::vector<std::shared_ptr<Thread>> waiting_threads = in ModifyByWaitingCountAndSignalToAddressIfEqual() local
118 if (waiting_threads.empty()) { in ModifyByWaitingCountAndSignalToAddressIfEqual()
124 if (waiting_threads.empty()) { in ModifyByWaitingCountAndSignalToAddressIfEqual()
[all …]
|
| /dports/emulators/citra/citra-ac98458e0/src/core/hle/kernel/ |
| H A D | wait_object.cpp | 23 ar& waiting_threads; in serialize() local
30 auto itr = std::find(waiting_threads.begin(), waiting_threads.end(), thread); in SERIALIZE_IMPL()
31 if (itr == waiting_threads.end()) in SERIALIZE_IMPL()
32 waiting_threads.push_back(std::move(thread)); in SERIALIZE_IMPL()
36 auto itr = std::find_if(waiting_threads.begin(), waiting_threads.end(), in RemoveWaitingThread()
41 if (itr != waiting_threads.end()) in RemoveWaitingThread()
42 waiting_threads.erase(itr); in RemoveWaitingThread()
49 for (const auto& thread : waiting_threads) { in GetHighestPriorityReadyThread()
107 return waiting_threads; in GetWaitingThreads()
|
| H A D | address_arbiter.cpp | 24 waiting_threads.emplace_back(std::move(thread)); in WaitThread()
29 auto itr = std::stable_partition(waiting_threads.begin(), waiting_threads.end(), in ResumeAllThreads()
37 std::for_each(itr, waiting_threads.end(), [](auto& thread) { thread->ResumeFromWait(); }); in ResumeAllThreads()
40 waiting_threads.erase(itr, waiting_threads.end()); in ResumeAllThreads()
46 waiting_threads.begin(), waiting_threads.end(), [address](const auto& thread) { in ResumeHighestPriorityThread()
55 auto itr = std::min_element(matches_start, waiting_threads.end(), in ResumeHighestPriorityThread()
60 if (itr == waiting_threads.end()) in ResumeHighestPriorityThread()
66 waiting_threads.erase(itr); in ResumeHighestPriorityThread()
104 waiting_threads.erase(std::remove(waiting_threads.begin(), waiting_threads.end(), thread), in WakeUp()
105 waiting_threads.end()); in WakeUp()
|
| /dports/emulators/citra-qt5/citra-ac98458e0/src/core/hle/kernel/ |
| H A D | wait_object.cpp | 23 ar& waiting_threads; in serialize() local
30 auto itr = std::find(waiting_threads.begin(), waiting_threads.end(), thread); in SERIALIZE_IMPL()
31 if (itr == waiting_threads.end()) in SERIALIZE_IMPL()
32 waiting_threads.push_back(std::move(thread)); in SERIALIZE_IMPL()
36 auto itr = std::find_if(waiting_threads.begin(), waiting_threads.end(), in RemoveWaitingThread()
41 if (itr != waiting_threads.end()) in RemoveWaitingThread()
42 waiting_threads.erase(itr); in RemoveWaitingThread()
49 for (const auto& thread : waiting_threads) { in GetHighestPriorityReadyThread()
107 return waiting_threads; in GetWaitingThreads()
|
| H A D | address_arbiter.cpp | 24 waiting_threads.emplace_back(std::move(thread)); in WaitThread()
29 auto itr = std::stable_partition(waiting_threads.begin(), waiting_threads.end(), in ResumeAllThreads()
37 std::for_each(itr, waiting_threads.end(), [](auto& thread) { thread->ResumeFromWait(); }); in ResumeAllThreads()
40 waiting_threads.erase(itr, waiting_threads.end()); in ResumeAllThreads()
46 waiting_threads.begin(), waiting_threads.end(), [address](const auto& thread) { in ResumeHighestPriorityThread()
55 auto itr = std::min_element(matches_start, waiting_threads.end(), in ResumeHighestPriorityThread()
60 if (itr == waiting_threads.end()) in ResumeHighestPriorityThread()
66 waiting_threads.erase(itr); in ResumeHighestPriorityThread()
104 waiting_threads.erase(std::remove(waiting_threads.begin(), waiting_threads.end(), thread), in WakeUp()
105 waiting_threads.end()); in WakeUp()
|
| /dports/devel/concurrencykit/ck-0.6.0/include/ |
| H A D | ck_cohort.h | 61 unsigned int waiting_threads; \
73 cohort->waiting_threads = 0; \
85 ck_pr_inc_uint(&cohort->waiting_threads); \
87 ck_pr_dec_uint(&cohort->waiting_threads); \
102 if (ck_pr_load_uint(&cohort->waiting_threads) > 0 \
135 ck_pr_inc_uint(&cohort->waiting_threads); \
137 ck_pr_dec_uint(&cohort->waiting_threads); \
156 .waiting_threads = 0, \
|
| /dports/benchmarks/sysbench/sysbench-1.0.20/third_party/concurrency_kit/ck/include/ |
| H A D | ck_cohort.h | 61 unsigned int waiting_threads; \
73 cohort->waiting_threads = 0; \
85 ck_pr_inc_uint(&cohort->waiting_threads); \
87 ck_pr_dec_uint(&cohort->waiting_threads); \
102 if (ck_pr_load_uint(&cohort->waiting_threads) > 0 \
135 ck_pr_inc_uint(&cohort->waiting_threads); \
137 ck_pr_dec_uint(&cohort->waiting_threads); \
156 .waiting_threads = 0, \
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/src/ |
| H A D | plugin_utils.cc | 41 vector<my_thread_id> waiting_threads; in unblock_waiting_transactions() local
42 certification_latch->get_all_waiting_keys(waiting_threads); in unblock_waiting_transactions()
44 if (!waiting_threads.empty()) in unblock_waiting_transactions()
52 for (it= waiting_threads.begin(); it != waiting_threads.end(); it++) in unblock_waiting_transactions()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/src/ |
| H A D | plugin_utils.cc | 41 vector<my_thread_id> waiting_threads; in unblock_waiting_transactions() local
42 certification_latch->get_all_waiting_keys(waiting_threads); in unblock_waiting_transactions()
44 if (!waiting_threads.empty()) in unblock_waiting_transactions()
52 for (it= waiting_threads.begin(); it != waiting_threads.end(); it++) in unblock_waiting_transactions()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/src/ |
| H A D | plugin_utils.cc | 41 vector<my_thread_id> waiting_threads; in unblock_waiting_transactions() local
42 certification_latch->get_all_waiting_keys(waiting_threads); in unblock_waiting_transactions()
44 if (!waiting_threads.empty()) in unblock_waiting_transactions()
52 for (it= waiting_threads.begin(); it != waiting_threads.end(); it++) in unblock_waiting_transactions()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/src/ |
| H A D | plugin_utils.cc | 41 vector<my_thread_id> waiting_threads; in unblock_waiting_transactions() local
42 certification_latch->get_all_waiting_keys(waiting_threads); in unblock_waiting_transactions()
44 if (!waiting_threads.empty()) in unblock_waiting_transactions()
52 for (it= waiting_threads.begin(); it != waiting_threads.end(); it++) in unblock_waiting_transactions()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/src/ |
| H A D | plugin_utils.cc | 41 vector<my_thread_id> waiting_threads; in unblock_waiting_transactions() local
42 certification_latch->get_all_waiting_keys(waiting_threads); in unblock_waiting_transactions()
44 if (!waiting_threads.empty()) in unblock_waiting_transactions()
52 for (it= waiting_threads.begin(); it != waiting_threads.end(); it++) in unblock_waiting_transactions()
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/src/ |
| H A D | plugin_utils.cc | 41 vector<my_thread_id> waiting_threads; in unblock_waiting_transactions() local
42 certification_latch->get_all_waiting_keys(waiting_threads); in unblock_waiting_transactions()
44 if (!waiting_threads.empty()) in unblock_waiting_transactions()
52 for (it= waiting_threads.begin(); it != waiting_threads.end(); it++) in unblock_waiting_transactions()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/group_replication/src/ |
| H A D | plugin_utils.cc | 43 vector<my_thread_id> waiting_threads; in unblock_waiting_transactions() local
44 transactions_latch->get_all_waiting_keys(waiting_threads); in unblock_waiting_transactions()
46 if (!waiting_threads.empty()) { in unblock_waiting_transactions()
51 for (it = waiting_threads.begin(); it != waiting_threads.end(); it++) { in unblock_waiting_transactions()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/innobase/lock/ |
| H A D | lock0wait.cc | 55 const srv_slot_t* slot = lock_sys->waiting_threads; in lock_wait_table_print()
81 srv_slot_t* upper = lock_sys->waiting_threads + OS_THREAD_MAX_N; in lock_wait_table_release_slot()
92 ut_ad(slot >= lock_sys->waiting_threads); in lock_wait_table_release_slot()
112 slot > lock_sys->waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
118 ut_ad(slot->in_use || slot == lock_sys->waiting_threads); in lock_wait_table_release_slot()
126 ut_ad(lock_sys->last_slot >= lock_sys->waiting_threads); in lock_wait_table_release_slot()
149 slot = lock_sys->waiting_threads; in lock_wait_table_reserve_slot()
172 <= lock_sys->waiting_threads + OS_THREAD_MAX_N); in lock_wait_table_reserve_slot()
509 for (slot = lock_sys->waiting_threads; in DECLARE_THREAD()
|
| /dports/databases/mysql57-client/mysql-5.7.36/storage/innobase/lock/ |
| H A D | lock0wait.cc | 55 const srv_slot_t* slot = lock_sys->waiting_threads; in lock_wait_table_print()
81 srv_slot_t* upper = lock_sys->waiting_threads + OS_THREAD_MAX_N; in lock_wait_table_release_slot()
92 ut_ad(slot >= lock_sys->waiting_threads); in lock_wait_table_release_slot()
112 slot > lock_sys->waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
118 ut_ad(slot->in_use || slot == lock_sys->waiting_threads); in lock_wait_table_release_slot()
126 ut_ad(lock_sys->last_slot >= lock_sys->waiting_threads); in lock_wait_table_release_slot()
149 slot = lock_sys->waiting_threads; in lock_wait_table_reserve_slot()
172 <= lock_sys->waiting_threads + OS_THREAD_MAX_N); in lock_wait_table_reserve_slot()
509 for (slot = lock_sys->waiting_threads; in DECLARE_THREAD()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/innobase/lock/ |
| H A D | lock0wait.cc | 50 const srv_slot_t* slot = lock_sys.waiting_threads; in lock_wait_table_print()
74 srv_slot_t* upper = lock_sys.waiting_threads + srv_max_n_threads; in lock_wait_table_release_slot()
85 ut_ad(slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
105 slot > lock_sys.waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
111 ut_ad(slot->in_use || slot == lock_sys.waiting_threads); in lock_wait_table_release_slot()
119 ut_ad(lock_sys.last_slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
142 slot = lock_sys.waiting_threads; in lock_wait_table_reserve_slot()
164 <= lock_sys.waiting_threads + srv_max_n_threads); in lock_wait_table_reserve_slot()
483 for (srv_slot_t *slot= lock_sys.waiting_threads; in lock_wait_timeout_task()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/innobase/lock/ |
| H A D | lock0wait.cc | 50 const srv_slot_t* slot = lock_sys.waiting_threads; in lock_wait_table_print()
74 srv_slot_t* upper = lock_sys.waiting_threads + srv_max_n_threads; in lock_wait_table_release_slot()
85 ut_ad(slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
105 slot > lock_sys.waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
111 ut_ad(slot->in_use || slot == lock_sys.waiting_threads); in lock_wait_table_release_slot()
119 ut_ad(lock_sys.last_slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
142 slot = lock_sys.waiting_threads; in lock_wait_table_reserve_slot()
164 <= lock_sys.waiting_threads + srv_max_n_threads); in lock_wait_table_reserve_slot()
483 for (srv_slot_t *slot= lock_sys.waiting_threads; in lock_wait_timeout_task()
|
| /dports/devel/glib20/glib-2.70.4/glib/ |
| H A D | gasyncqueue.c | 101 guint waiting_threads; member
145 queue->waiting_threads = 0; in g_async_queue_new_full()
229 g_return_if_fail (queue->waiting_threads == 0); in g_async_queue_unref()
315 if (queue->waiting_threads > 0) in g_async_queue_push_unlocked()
402 if (queue->waiting_threads > 0) in g_async_queue_push_sorted_unlocked()
415 queue->waiting_threads++; in g_async_queue_pop_intern_unlocked()
426 queue->waiting_threads--; in g_async_queue_pop_intern_unlocked()
685 retval = queue->queue.length - queue->waiting_threads; in g_async_queue_length()
713 return queue->queue.length - queue->waiting_threads; in g_async_queue_length_unlocked()
892 if (queue->waiting_threads > 0) in g_async_queue_push_front_unlocked()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/innobase/lock/ |
| H A D | lock0wait.cc | 55 const srv_slot_t* slot = lock_sys->waiting_threads; in lock_wait_table_print()
81 srv_slot_t* upper = lock_sys->waiting_threads + OS_THREAD_MAX_N; in lock_wait_table_release_slot()
92 ut_ad(slot >= lock_sys->waiting_threads); in lock_wait_table_release_slot()
112 slot > lock_sys->waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
118 ut_ad(slot->in_use || slot == lock_sys->waiting_threads); in lock_wait_table_release_slot()
126 ut_ad(lock_sys->last_slot >= lock_sys->waiting_threads); in lock_wait_table_release_slot()
149 slot = lock_sys->waiting_threads; in lock_wait_table_reserve_slot()
172 <= lock_sys->waiting_threads + OS_THREAD_MAX_N); in lock_wait_table_reserve_slot()
541 for (slot = lock_sys->waiting_threads; in DECLARE_THREAD()
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/innobase/lock/ |
| H A D | lock0wait.cc | 56 slot = lock_sys->waiting_threads; in lock_wait_table_print()
82 srv_slot_t* upper = lock_sys->waiting_threads + OS_THREAD_MAX_N; in lock_wait_table_release_slot()
93 ut_ad(slot >= lock_sys->waiting_threads); in lock_wait_table_release_slot()
113 slot > lock_sys->waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
119 ut_ad(slot->in_use || slot == lock_sys->waiting_threads); in lock_wait_table_release_slot()
127 ut_ad(lock_sys->last_slot >= lock_sys->waiting_threads); in lock_wait_table_release_slot()
150 slot = lock_sys->waiting_threads; in lock_wait_table_reserve_slot()
173 <= lock_sys->waiting_threads + OS_THREAD_MAX_N); in lock_wait_table_reserve_slot()
559 for (slot = lock_sys->waiting_threads; in DECLARE_THREAD()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/innobase/lock/ |
| H A D | lock0wait.cc | 49 const srv_slot_t* slot = lock_sys.waiting_threads; in lock_wait_table_print()
75 srv_slot_t* upper = lock_sys.waiting_threads + srv_max_n_threads; in lock_wait_table_release_slot()
86 ut_ad(slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
106 slot > lock_sys.waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
112 ut_ad(slot->in_use || slot == lock_sys.waiting_threads); in lock_wait_table_release_slot()
120 ut_ad(lock_sys.last_slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
143 slot = lock_sys.waiting_threads; in lock_wait_table_reserve_slot()
166 <= lock_sys.waiting_threads + srv_max_n_threads); in lock_wait_table_reserve_slot()
526 for (slot = lock_sys.waiting_threads; in DECLARE_THREAD()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/innobase/lock/ |
| H A D | lock0wait.cc | 49 const srv_slot_t* slot = lock_sys.waiting_threads; in lock_wait_table_print()
75 srv_slot_t* upper = lock_sys.waiting_threads + srv_max_n_threads; in lock_wait_table_release_slot()
86 ut_ad(slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
106 slot > lock_sys.waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
112 ut_ad(slot->in_use || slot == lock_sys.waiting_threads); in lock_wait_table_release_slot()
120 ut_ad(lock_sys.last_slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
143 slot = lock_sys.waiting_threads; in lock_wait_table_reserve_slot()
166 <= lock_sys.waiting_threads + srv_max_n_threads); in lock_wait_table_reserve_slot()
526 for (slot = lock_sys.waiting_threads; in DECLARE_THREAD()
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/innobase/lock/ |
| H A D | lock0wait.cc | 49 const srv_slot_t* slot = lock_sys.waiting_threads; in lock_wait_table_print()
75 srv_slot_t* upper = lock_sys.waiting_threads + srv_max_n_threads; in lock_wait_table_release_slot()
86 ut_ad(slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
106 slot > lock_sys.waiting_threads && !slot->in_use; in lock_wait_table_release_slot()
112 ut_ad(slot->in_use || slot == lock_sys.waiting_threads); in lock_wait_table_release_slot()
120 ut_ad(lock_sys.last_slot >= lock_sys.waiting_threads); in lock_wait_table_release_slot()
143 slot = lock_sys.waiting_threads; in lock_wait_table_reserve_slot()
166 <= lock_sys.waiting_threads + srv_max_n_threads); in lock_wait_table_reserve_slot()
525 for (slot = lock_sys.waiting_threads; in DECLARE_THREAD()
|