| /dports/audio/gsequencer/gsequencer-3.10.4/ags/thread/ |
| H A D | ags_worker_thread.c | 127 worker_thread->do_poll = NULL; in ags_worker_thread_class_init()
169 worker_thread->worker_thread = NULL; in ags_worker_thread_init()
175 AgsWorkerThread *worker_thread; in ags_worker_thread_finalize() local
201 AgsWorkerThread *worker_thread; in ags_worker_thread_start() local
210 worker_thread->worker_thread = g_thread_new("Advanced Gtk+ Sequencer - worker", in ags_worker_thread_start()
212 worker_thread); in ags_worker_thread_start()
218 AgsWorkerThread *worker_thread; in ags_worker_thread_run() local
357 g_object_ref(worker_thread); in ags_worker_thread_do_poll()
358 g_signal_emit(worker_thread, in ags_worker_thread_do_poll()
360 g_object_unref(worker_thread); in ags_worker_thread_do_poll()
[all …]
|
| H A D | ags_destroy_worker.c | 86 AgsWorkerThreadClass *worker_thread; in ags_destroy_worker_class_init() local
103 worker_thread = (AgsWorkerThreadClass *) destroy_worker; in ags_destroy_worker_class_init()
105 worker_thread->do_poll = ags_destroy_worker_do_poll; in ags_destroy_worker_class_init()
141 AgsWorkerThread *worker_thread; in ags_destroy_worker_start() local
143 worker_thread = AGS_WORKER_THREAD(thread); in ags_destroy_worker_start()
147 worker_thread->worker_thread = g_thread_new("Advanced Gtk+ Sequencer - destroy worker", in ags_destroy_worker_start()
149 worker_thread); in ags_destroy_worker_start()
155 AgsWorkerThread *worker_thread; in ags_destroy_worker_stop() local
157 worker_thread = AGS_WORKER_THREAD(thread); in ags_destroy_worker_stop()
163 ags_destroy_worker_do_poll(AgsWorkerThread *worker_thread) in ags_destroy_worker_do_poll() argument
[all …]
|
| /dports/www/h2o-devel/h2o-dcc7134/t/00unit/lib/common/ |
| H A D | multithread.c | 45 } worker_thread; variable
65 if (++worker_thread.num_ping_received < 100) { in on_ping()
69 worker_thread.should_exit = 1; in on_ping()
110 while (!worker_thread.should_exit) { in worker_main()
112 uv_run(worker_thread.loop, UV_RUN_ONCE); in worker_main()
129 worker_thread.loop = create_loop(); in test_lib__common__multithread_c()
130 worker_thread.queue = h2o_multithread_create_queue(worker_thread.loop); in test_lib__common__multithread_c()
131 h2o_multithread_register_receiver(worker_thread.queue, &worker_thread.ping_receiver, on_ping); in test_lib__common__multithread_c()
136 send_empty_message(&worker_thread.ping_receiver); in test_lib__common__multithread_c()
148 h2o_multithread_unregister_receiver(worker_thread.queue, &worker_thread.ping_receiver); in test_lib__common__multithread_c()
[all …]
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/pc/ |
| H A D | channel.h | 108 BaseChannel(rtc::Thread* worker_thread,
196 RTC_DCHECK_RUN_ON(worker_thread()); in was_ever_writable()
200 RTC_DCHECK_RUN_ON(worker_thread()); in set_local_content_direction()
204 RTC_DCHECK_RUN_ON(worker_thread()); in set_remote_content_direction()
252 RTC_RUN_ON(worker_thread());
264 RTC_RUN_ON(worker_thread());
268 RTC_RUN_ON(worker_thread());
272 RTC_RUN_ON(worker_thread()) = 0;
276 RTC_RUN_ON(worker_thread()) = 0;
308 RTC_RUN_ON(worker_thread());
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/core/inspector/ |
| H A D | worker_thread_debugger.cc | 90 return worker_thread->GetWorkerThreadId(); in ContextGroupId()
94 int worker_context_group_id = ContextGroupId(worker_thread); in WorkerThreadCreated()
96 worker_threads_.insert(worker_context_group_id, worker_thread); in WorkerThreadCreated()
100 int worker_context_group_id = ContextGroupId(worker_thread); in WorkerThreadDestroyed()
111 int worker_context_group_id = ContextGroupId(worker_thread); in ContextCreated()
127 WorkerThread* worker_thread, in ContextWillBeDestroyed() argument
135 worker_thread->GetWorkerReportingProxy().ReportConsoleMessage( in ExceptionThrown()
167 DCHECK(!worker_thread->GlobalScope()->IsClosing()); in PauseWorkerOnStart()
169 runMessageLoopOnPause(ContextGroupId(worker_thread)); in PauseWorkerOnStart()
241 worker_thread->GetWorkerReportingProxy().ReportConsoleMessage( in consoleAPIMessage()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/core/inspector/ |
| H A D | worker_thread_debugger.cc | 90 return worker_thread->GetWorkerThreadId(); in ContextGroupId()
94 int worker_context_group_id = ContextGroupId(worker_thread); in WorkerThreadCreated()
96 worker_threads_.insert(worker_context_group_id, worker_thread); in WorkerThreadCreated()
100 int worker_context_group_id = ContextGroupId(worker_thread); in WorkerThreadDestroyed()
111 int worker_context_group_id = ContextGroupId(worker_thread); in ContextCreated()
127 WorkerThread* worker_thread, in ContextWillBeDestroyed() argument
135 worker_thread->GetWorkerReportingProxy().ReportConsoleMessage( in ExceptionThrown()
167 DCHECK(!worker_thread->GlobalScope()->IsClosing()); in PauseWorkerOnStart()
169 runMessageLoopOnPause(ContextGroupId(worker_thread)); in PauseWorkerOnStart()
241 worker_thread->GetWorkerReportingProxy().ReportConsoleMessage( in consoleAPIMessage()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/third_party/rust/rayon-core/src/join/ |
| H A D | mod.rs | 116 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
117 log!(Join { worker: worker_thread.index() }); in join_context()
125 worker_thread.push(job_b_ref); in join_context()
140 if let Some(job) = worker_thread.take_local_job() { in join_context()
145 log!(PoppedRhs { worker: worker_thread.index() }); in join_context()
149 log!(PoppedJob { worker: worker_thread.index() }); in join_context()
150 worker_thread.execute(job); in join_context()
155 log!(LostJob { worker: worker_thread.index() }); in join_context()
156 worker_thread.wait_until(&job_b.latch); in join_context()
170 unsafe fn join_recover_from_panic(worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/shells/ion/ion-a8872014dbce730ccd00aaa722397dc394a52bf4/cargo-crates/rayon-core-1.5.0/src/join/ |
| H A D | mod.rs | 118 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
120 worker: worker_thread.index() in join_context()
131 worker_thread.push(job_b_ref); in join_context()
146 if let Some(job) = worker_thread.take_local_job() { in join_context()
152 worker: worker_thread.index() in join_context()
158 worker: worker_thread.index() in join_context()
160 worker_thread.execute(job); in join_context()
166 worker: worker_thread.index() in join_context()
168 worker_thread.wait_until(&job_b.latch); in join_context()
183 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/games/dose-response/dose-response-179c326/cargo-crates/rayon-core-1.4.1/src/join/ |
| H A D | mod.rs | 116 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
117 log!(Join { worker: worker_thread.index() }); in join_context()
125 worker_thread.push(job_b_ref); in join_context()
140 if let Some(job) = worker_thread.take_local_job() { in join_context()
145 log!(PoppedRhs { worker: worker_thread.index() }); in join_context()
149 log!(PoppedJob { worker: worker_thread.index() }); in join_context()
150 worker_thread.execute(job); in join_context()
155 log!(LostJob { worker: worker_thread.index() }); in join_context()
156 worker_thread.wait_until(&job_b.latch); in join_context()
170 unsafe fn join_recover_from_panic(worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/multimedia/termplay/termplay-2.0.6/cargo-crates/rayon-core-1.7.0/src/join/ |
| H A D | mod.rs | 133 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
135 worker: worker_thread.index() in join_context()
143 worker_thread.push(job_b_ref); in join_context()
158 if let Some(job) = worker_thread.take_local_job() { in join_context()
164 worker: worker_thread.index() in join_context()
170 worker: worker_thread.index() in join_context()
172 worker_thread.execute(job); in join_context()
178 worker: worker_thread.index() in join_context()
180 worker_thread.wait_until(&job_b.latch); in join_context()
195 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rayon-core-1.7.0/src/join/ |
| H A D | mod.rs | 133 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
135 worker: worker_thread.index() in join_context()
143 worker_thread.push(job_b_ref); in join_context()
158 if let Some(job) = worker_thread.take_local_job() { in join_context()
164 worker: worker_thread.index() in join_context()
170 worker: worker_thread.index() in join_context()
172 worker_thread.execute(job); in join_context()
178 worker: worker_thread.index() in join_context()
180 worker_thread.wait_until(&job_b.latch); in join_context()
195 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/rayon-core-1.6.0/src/join/ |
| H A D | mod.rs | 133 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
135 worker: worker_thread.index() in join_context()
143 worker_thread.push(job_b_ref); in join_context()
158 if let Some(job) = worker_thread.take_local_job() { in join_context()
164 worker: worker_thread.index() in join_context()
170 worker: worker_thread.index() in join_context()
172 worker_thread.execute(job); in join_context()
178 worker: worker_thread.index() in join_context()
180 worker_thread.wait_until(&job_b.latch); in join_context()
195 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/sysutils/diskonaut/diskonaut-0.11.0/cargo-crates/rayon-core-1.7.1/src/join/ |
| H A D | mod.rs | 133 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
135 worker: worker_thread.index() in join_context()
143 worker_thread.push(job_b_ref); in join_context()
158 if let Some(job) = worker_thread.take_local_job() { in join_context()
164 worker: worker_thread.index() in join_context()
170 worker: worker_thread.index() in join_context()
172 worker_thread.execute(job); in join_context()
178 worker: worker_thread.index() in join_context()
180 worker_thread.wait_until(&job_b.latch); in join_context()
195 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/textproc/sd/sd-0.7.6/cargo-crates/rayon-core-1.7.1/src/join/ |
| H A D | mod.rs | 133 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
135 worker: worker_thread.index() in join_context()
143 worker_thread.push(job_b_ref); in join_context()
158 if let Some(job) = worker_thread.take_local_job() { in join_context()
164 worker: worker_thread.index() in join_context()
170 worker: worker_thread.index() in join_context()
172 worker_thread.execute(job); in join_context()
178 worker: worker_thread.index() in join_context()
180 worker_thread.wait_until(&job_b.latch); in join_context()
195 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/rayon-core-1.7.1/src/join/ |
| H A D | mod.rs | 133 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
135 worker: worker_thread.index() in join_context()
143 worker_thread.push(job_b_ref); in join_context()
158 if let Some(job) = worker_thread.take_local_job() { in join_context()
164 worker: worker_thread.index() in join_context()
170 worker: worker_thread.index() in join_context()
172 worker_thread.execute(job); in join_context()
178 worker: worker_thread.index() in join_context()
180 worker_thread.wait_until(&job_b.latch); in join_context()
195 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/rayon-core/src/join/ |
| H A D | mod.rs | 133 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
135 worker: worker_thread.index() in join_context()
143 worker_thread.push(job_b_ref); in join_context()
158 if let Some(job) = worker_thread.take_local_job() { in join_context()
164 worker: worker_thread.index() in join_context()
170 worker: worker_thread.index() in join_context()
172 worker_thread.execute(job); in join_context()
178 worker: worker_thread.index() in join_context()
180 worker_thread.wait_until(&job_b.latch); in join_context()
195 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/textproc/cast2gif/cast2gif-0.1.0/cargo-crates/rayon-core-1.7.0/src/join/ |
| H A D | mod.rs | 133 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
135 worker: worker_thread.index() in join_context()
143 worker_thread.push(job_b_ref); in join_context()
158 if let Some(job) = worker_thread.take_local_job() { in join_context()
164 worker: worker_thread.index() in join_context()
170 worker: worker_thread.index() in join_context()
172 worker_thread.execute(job); in join_context()
178 worker: worker_thread.index() in join_context()
180 worker_thread.wait_until(&job_b.latch); in join_context()
195 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/devel/racer/racer-2.1.48/cargo-crates/rustc-rayon-core-0.3.1/src/join/ |
| H A D | mod.rs | 134 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
136 worker: worker_thread.index() in join_context()
145 worker_thread.push(job_b_ref); in join_context()
160 if let Some(job) = worker_thread.take_local_job() { in join_context()
166 worker: worker_thread.index() in join_context()
175 worker: worker_thread.index() in join_context()
177 worker_thread.execute(job); in join_context()
183 worker: worker_thread.index() in join_context()
185 worker_thread.wait_until(&job_b.latch); in join_context()
203 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/rustc-rayon-core/src/join/ |
| H A D | mod.rs | 134 registry::in_worker(|worker_thread, injected| unsafe { in join_context()
136 worker: worker_thread.index() in join_context()
145 worker_thread.push(job_b_ref); in join_context()
160 if let Some(job) = worker_thread.take_local_job() { in join_context()
166 worker: worker_thread.index() in join_context()
175 worker: worker_thread.index() in join_context()
177 worker_thread.execute(job); in join_context()
183 worker: worker_thread.index() in join_context()
185 worker_thread.wait_until(&job_b.latch); in join_context()
203 worker_thread: &WorkerThread, in join_recover_from_panic()
[all …]
|
| /dports/audio/gsequencer/gsequencer-3.10.4/ags/test/thread/ |
| H A D | ags_worker_thread_test.c | 34 void ags_worker_thread_test_stub_do_poll(AgsWorkerThread *worker_thread);
61 AgsWorkerThread *worker_thread; in ags_worker_thread_test_do_poll() local
65 worker_thread = g_object_new(AGS_TYPE_WORKER_THREAD, in ags_worker_thread_test_do_poll()
68 ptr = AGS_WORKER_THREAD_GET_CLASS(worker_thread)->do_poll; in ags_worker_thread_test_do_poll()
69 AGS_WORKER_THREAD_GET_CLASS(worker_thread)->do_poll = ags_worker_thread_test_stub_do_poll; in ags_worker_thread_test_do_poll()
72 ags_worker_thread_do_poll(worker_thread); in ags_worker_thread_test_do_poll()
75 AGS_WORKER_THREAD_GET_CLASS(worker_thread)->do_poll = ptr; in ags_worker_thread_test_do_poll()
79 ags_worker_thread_test_stub_do_poll(AgsWorkerThread *worker_thread) in ags_worker_thread_test_stub_do_poll() argument
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/bindings/core/v8/serialization/ |
| H A D | serialized_script_value_threaded_test.cc | 28 WorkerThreadForTest worker_thread(proxy); in TEST() local
29 worker_thread.StartWithSourceCode(scope.GetDocument().GetSecurityOrigin(), in TEST()
50 worker_thread.GetWorkerBackingThread().BackingThread().GetTaskRunner(); in TEST()
55 [](WorkerThread* worker_thread, in TEST()
58 worker_thread->GlobalScope()->ScriptController(); in TEST()
62 ->Deserialize(worker_thread->GetIsolate()); in TEST()
68 CrossThreadUnretained(&worker_thread), serialized)); in TEST()
83 worker_thread.Terminate(); in TEST()
84 worker_thread.WaitForShutdownForTesting(); in TEST()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/bindings/core/v8/serialization/ |
| H A D | serialized_script_value_threaded_test.cc | 28 WorkerThreadForTest worker_thread(proxy); in TEST() local
29 worker_thread.StartWithSourceCode(scope.GetWindow().GetSecurityOrigin(), in TEST()
50 worker_thread.GetWorkerBackingThread().BackingThread().GetTaskRunner(); in TEST()
55 [](WorkerThread* worker_thread, in TEST()
58 worker_thread->GlobalScope()->ScriptController(); in TEST()
62 ->Deserialize(worker_thread->GetIsolate()); in TEST()
68 CrossThreadUnretained(&worker_thread), serialized)); in TEST()
83 worker_thread.Terminate(); in TEST()
84 worker_thread.WaitForShutdownForTesting(); in TEST()
|
| /dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/session/phone/ |
| H A D | audiomonitor.cc | 47 voice_channel_->worker_thread()->Clear(this); in ~AudioMonitor()
55 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_START); in Start()
59 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_STOP); in Stop()
67 assert(talk_base::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
75 assert(talk_base::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
78 voice_channel_->worker_thread()->Clear(this); in OnMessage()
83 assert(talk_base::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
101 assert(talk_base::Thread::Current() == voice_channel_->worker_thread()); in PollVoiceChannel()
110 voice_channel_->worker_thread()->PostDelayed(rate_, this, MSG_MONITOR_POLL); in PollVoiceChannel()
|
| /dports/security/nitrokey-app/nitrokey-app-1.4.2/src/core/ |
| H A D | ThreadWorker.cpp | 53 worker_thread(new QThread(this)), in ThreadWorker()
61 connect(worker_thread, SIGNAL(started()), worker.get(), SLOT(fetch_data()), Qt::QueuedConnection); in ThreadWorker()
64 worker->moveToThread(worker_thread); in ThreadWorker()
65 worker_thread->start(); in ThreadWorker()
83 if (worker_thread == nullptr) return; in stop_thread()
84 worker_thread->requestInterruption(); in stop_thread()
85 worker_thread->quit(); in stop_thread()
86 for (int i=0; i<5 && !worker_thread->wait(1000);i++){ in stop_thread()
87 qDebug() << "Worker has not finished yet: " << QString::fromStdString(name) << worker_thread; in stop_thread()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/pc/ |
| H A D | audiomonitor.cc | 30 voice_channel_->worker_thread()->Clear(this); in ~AudioMonitor()
38 voice_channel_->worker_thread()->Post(RTC_FROM_HERE, this, MSG_MONITOR_START); in Start()
42 voice_channel_->worker_thread()->Post(RTC_FROM_HERE, this, MSG_MONITOR_STOP); in Stop()
50 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
58 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
61 voice_channel_->worker_thread()->Clear(this); in OnMessage()
66 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
84 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in PollVoiceChannel()
93 voice_channel_->worker_thread()->PostDelayed(RTC_FROM_HERE, rate_, this, in PollVoiceChannel()
|