Home
last modified time | relevance | path

Searched refs:main_queue (Results 1 – 20 of 20) sorted by relevance

/dports/x11/xpra/xpra-4.3/xpra/
H A Dqueue_scheduler.py21 self.main_queue = Queue()
36 self.main_queue.put((self.idle_repeat_call, (tid, fn, args, kwargs), {}))
64 self.main_queue.put((self.timeout_repeat_call, mqargs, {}))
84 log("run() queue has %s items already in it", self.main_queue.qsize())
87 log("run() size=%s", self.main_queue.qsize())
88 v = self.main_queue.get()
98 self.main_queue.put(v)
108 self.main_queue.put(None)
112 self.main_queue = q
/dports/net/mDNSResponder/mDNSResponder-1310.140.1/Clients/srputil/
H A Dsrputil.c42 dispatch_queue_t main_queue; variable
206 main_queue = dispatch_get_main_queue(); in main()
207 dispatch_retain(main_queue); in main()
210 dispatch_async(main_queue, ^{ in main()
215 err = advertising_proxy_enable(&cref, main_queue, started_callback); in main()
218 err = advertising_proxy_flush_entries(&cref, main_queue, flushed_callback); in main()
221 err = advertising_proxy_get_service_list(&cref, main_queue, services_callback); in main()
224 err = advertising_proxy_block_service(&cref, main_queue, block_callback); in main()
227 err = advertising_proxy_unblock_service(&cref, main_queue, unblock_callback); in main()
230 err = advertising_proxy_regenerate_ula(&cref, main_queue, regenerate_callback); in main()
/dports/www/uwsgi/uwsgi-2.0.20/core/
H A Dloop.c127 int main_queue = event_queue_init(); in simple_loop_run() local
129 uwsgi_add_sockets_to_queue(main_queue, core_id); in simple_loop_run()
132 event_queue_add_fd_read(main_queue, uwsgi.signal_socket); in simple_loop_run()
133 event_queue_add_fd_read(main_queue, uwsgi.my_signal_socket); in simple_loop_run()
142 if (wsgi_req_accept(main_queue, wsgi_req)) { in simple_loop_run()
146 if (wsgi_req_recv(main_queue, wsgi_req)) { in simple_loop_run()
/dports/deskutils/calibre/calibre-src-5.34.0/src/calibre/gui2/tweak_book/completion/
H A Dworker.py30 self.main_queue = Queue()
103 obj = self.main_queue.get()
130 self.main_queue.put((CLEAR_REQUEST, Request(None, 'clear_caches', cache_type, None)))
136 self.main_queue.put((COMPLETION_REQUEST, ccr))
140 self.main_queue.put(None)
/dports/devel/efl/efl-1.25.1/src/lib/evas/common/
H A Devas_scale_sample.c42 static Eina_Thread_Queue *main_queue = NULL; variable
703 msg = eina_thread_queue_wait(main_queue, &ref); in scale_rgba_in_to_out_clip_sample_internal()
704 if (msg) eina_thread_queue_wait_done(main_queue, ref); in scale_rgba_in_to_out_clip_sample_internal()
785 eina_thread_queue_send_done(main_queue, ref); in _evas_common_scale_sample_thread()
796 eina_thread_queue_free(main_queue); in evas_common_scale_sample_fork_reset()
799 main_queue = eina_thread_queue_new(); in evas_common_scale_sample_fork_reset()
827 main_queue = eina_thread_queue_new(); in evas_common_scale_sample_init()
846 if (main_queue) eina_thread_queue_free(main_queue); in evas_common_scale_sample_init()
865 msg = eina_thread_queue_wait(main_queue, &ref); in evas_common_scale_sample_shutdown()
866 if (msg) eina_thread_queue_wait_done(main_queue, ref); in evas_common_scale_sample_shutdown()
[all …]
/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0058-log.cpp71 static void test_log (std::string what, bool main_queue) { in test_log() argument
91 if (!main_queue) { in test_log()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0058-log.cpp71 static void test_log (std::string what, bool main_queue) { in test_log() argument
91 if (!main_queue) { in test_log()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0058-log.cpp71 static void test_log (std::string what, bool main_queue) {
91 if (!main_queue) {
/dports/net-im/tg_owt/tg_owt-d578c76/src/video/
H A Drtp_streams_synchronizer2.cc40 RtpStreamsSynchronizer::RtpStreamsSynchronizer(TaskQueueBase* main_queue, in RtpStreamsSynchronizer() argument
42 : task_queue_(main_queue), in RtpStreamsSynchronizer()
H A Drtp_streams_synchronizer2.h32 RtpStreamsSynchronizer(TaskQueueBase* main_queue, Syncable* syncable_video);
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/video/
H A Drtp_streams_synchronizer2.cc40 RtpStreamsSynchronizer::RtpStreamsSynchronizer(TaskQueueBase* main_queue, in RtpStreamsSynchronizer() argument
42 : task_queue_(main_queue), in RtpStreamsSynchronizer()
H A Drtp_streams_synchronizer2.h31 RtpStreamsSynchronizer(TaskQueueBase* main_queue, Syncable* syncable_video);
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/video/
H A Drtp_streams_synchronizer2.cc40 RtpStreamsSynchronizer::RtpStreamsSynchronizer(TaskQueueBase* main_queue, in RtpStreamsSynchronizer() argument
42 : task_queue_(main_queue), in RtpStreamsSynchronizer()
H A Drtp_streams_synchronizer2.h31 RtpStreamsSynchronizer(TaskQueueBase* main_queue, Syncable* syncable_video);
/dports/net/mDNSResponder/mDNSResponder-1310.140.1/Clients/
H A Ddns-sd.c245 dispatch_queue_t main_queue; variable
257 …if (main_queue && (E) == kDNSServiceErr_ServiceNotRunning) { fprintf(stderr, "Error code %d\n", (E…
1317 main_queue = dispatch_get_main_queue(); in HandleEvents()
1318 if (client) DNSServiceSetDispatchQueue(client, main_queue); in HandleEvents()
1319 if (client_pa) DNSServiceSetDispatchQueue(client_pa, main_queue); in HandleEvents()
1322 timer_source = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, main_queue); in HandleEvents()
1334 … dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (uint64_t)exitTimeout * NSEC_PER_SEC), main_queue, in HandleEvents()
/dports/multimedia/v4l_compat/linux-5.13-rc2/kernel/
H A Daudit.c828 goto main_queue; in kauditd_thread()
842 goto main_queue; in kauditd_thread()
852 goto main_queue; in kauditd_thread()
855 main_queue: in kauditd_thread()
/dports/multimedia/libv4l/linux-5.13-rc2/kernel/
H A Daudit.c828 goto main_queue; in kauditd_thread()
842 goto main_queue; in kauditd_thread()
852 goto main_queue; in kauditd_thread()
855 main_queue: in kauditd_thread()
/dports/multimedia/v4l-utils/linux-5.13-rc2/kernel/
H A Daudit.c828 goto main_queue; in kauditd_thread()
842 goto main_queue; in kauditd_thread()
852 goto main_queue; in kauditd_thread()
855 main_queue: in kauditd_thread()
/dports/x11/xpra/xpra-4.3/xpra/server/proxy/
H A Dproxy_instance_process.py171 self.main_queue = Queue()
/dports/sysutils/rsyslog8/rsyslog-8.2112.0/
H A DChangeLog7135 - add main_queue() configuration object to configure main message queue