| /dports/net/mDNSResponder/mDNSResponder-1310.140.1/mDNSMacOSX/mdns_objects/ |
| H A D | mdns_trust.c | 39 dispatch_queue_t user_queue; // Users serial queue. member
90 dispatch_release_null_safe(me->user_queue); in _mdns_trust_finalize()
132 dispatch_async(me->user_queue, in _mdns_trust_activate_internal()
161 if (me->user_activated && me->user_queue && !me->activated) { in _mdns_trust_activate_if_ready()
231 if (!me->user_activated || !me->user_queue) in mdns_trust_set_queue()
236 dispatch_release_null_safe(me->user_queue); in mdns_trust_set_queue()
237 me->user_queue = queue; in mdns_trust_set_queue()
|
| H A D | mdns_interface_monitor.c | 34 dispatch_queue_t user_queue; // User's queue for invoking handlers. member
179 if (me->user_queue) { in mdns_interface_monitor_activate()
209 dispatch_release_null_safe(me->user_queue); in mdns_interface_monitor_set_queue()
210 me->user_queue = queue; in mdns_interface_monitor_set_queue()
211 } else if (!me->user_queue) { in mdns_interface_monitor_set_queue()
212 me->user_queue = queue; in mdns_interface_monitor_set_queue()
213 dispatch_retain(me->user_queue); in mdns_interface_monitor_set_queue()
351 dispatch_forget(&me->user_queue); in _mdns_interface_monitor_finalize()
381 …me->update_source = dispatch_source_create(DISPATCH_SOURCE_TYPE_DATA_REPLACE, 0, 0, me->user_queue… in _mdns_interface_monitor_activate_internal()
464 dispatch_async(me->user_queue, in _mdns_interface_monitor_terminate()
|
| H A D | mdns_dns_service.c | 40 dispatch_queue_t user_queue; // User's queue for invoking user's event handler. member
244 mdns_dns_service_manager_create(const dispatch_queue_t user_queue, OSStatus * const out_error) in mdns_dns_service_manager_create() argument
269 obj->user_queue = user_queue; in mdns_dns_service_manager_create()
270 dispatch_retain(obj->user_queue); in mdns_dns_service_manager_create()
341 me->update_source = dispatch_source_create(DISPATCH_SOURCE_TYPE_DATA_OR, 0, 0, me->user_queue); in _mdns_dns_service_manager_activate_internal()
1294 dispatch_forget(&me->user_queue); in _mdns_dns_service_manager_finalize()
1417 dispatch_async(me->user_queue, in _mdns_dns_service_manager_terminate()
|
| H A D | mdns_resolver.c | 1058 dispatch_release_null_safe(me->user_queue); in mdns_resolver_set_queue()
1059 me->user_queue = queue; in mdns_resolver_set_queue()
1284 dispatch_async(me->user_queue, in _mdns_resolver_invalidate_internal()
1349 dispatch_forget(&me->user_queue); in _mdns_resolver_finalize()
2317 dispatch_async(me->user_queue, in _mdns_resolver_generate_event()
3771 if (!me->user_activated || !me->user_queue) in mdns_querier_set_queue()
3776 dispatch_release_null_safe(me->user_queue); in mdns_querier_set_queue()
3777 me->user_queue = queue; in mdns_querier_set_queue()
4090 dispatch_forget(&me->user_queue); in _mdns_querier_finalize()
4429 if (me->user_queue) { in _mdns_querier_conclude_ex()
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/replication/replicator/ |
| H A D | replicator-queue.c | 26 struct priorityq *user_queue; member
90 queue->user_queue = priorityq_init(user_priority_cmp, 1024); in replicator_queue_init()
106 while ((item = priorityq_pop(queue->user_queue)) != NULL) { in replicator_queue_deinit()
113 priorityq_deinit(&queue->user_queue); in replicator_queue_deinit()
173 priorityq_remove(queue->user_queue, &user->item); in replicator_queue_add_int()
179 priorityq_add(queue->user_queue, &user->item); in replicator_queue_add_int()
223 priorityq_remove(queue->user_queue, &user->item); in replicator_queue_remove()
260 item = priorityq_peek(queue->user_queue); in replicator_queue_pop()
271 priorityq_remove(queue->user_queue, &user->item); in replicator_queue_pop()
311 priorityq_add(queue->user_queue, &user->item); in replicator_queue_push()
|
| /dports/games/abstreet/winit-a87ae2661263ff241e8868cbf3ce65aab205863a/src/platform_impl/android/ |
| H A D | mod.rs | 46 user_queue: Arc<Mutex<VecDeque<T>>>, field
72 user_queue: Default::default(), in new()
204 let mut user_queue = self.user_queue.lock().unwrap(); in run_return() localVariable
205 while let Some(event) = user_queue.pop_front() { in run_return()
303 queue: self.user_queue.clone(), in create_proxy()
|
| /dports/x11/alacritty/alacritty-0.9.0/cargo-crates/winit-0.24.0/src/platform_impl/android/ |
| H A D | mod.rs | 46 user_queue: Arc<Mutex<VecDeque<T>>>, field
72 user_queue: Default::default(), in new()
246 let mut user_queue = self.user_queue.lock().unwrap(); in run_return() localVariable
247 while let Some(event) = user_queue.pop_front() { in run_return()
345 queue: self.user_queue.clone(), in create_proxy()
|
| /dports/net/mDNSResponder/mDNSResponder-1310.140.1/mDNSMacOSX/ |
| H A D | dnssd.c | 119 dispatch_queue_t user_queue; // User's dispatch queue for invoking result and event handlers. member
340 dispatch_release_null_safe(me->user_queue); in dnssd_getaddrinfo_set_queue()
341 me->user_queue = queue; in dnssd_getaddrinfo_set_queue()
342 } else if (!me->user_queue) { in dnssd_getaddrinfo_set_queue()
343 me->user_queue = queue; in dnssd_getaddrinfo_set_queue()
344 dispatch_retain(me->user_queue); in dnssd_getaddrinfo_set_queue()
499 if (me->user_queue) { in dnssd_getaddrinfo_activate()
557 if (me->user_queue) { in _dnssd_getaddrinfo_invalidate()
559 dispatch_async(me->user_queue, in _dnssd_getaddrinfo_invalidate()
624 dispatch_forget(&me->user_queue); in _dnssd_getaddrinfo_finalize()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/usrsctp/usrsctplib/usrsctplib/ |
| H A D | Makefile.am | 42 user_queue.h \
|
| H A D | Makefile.nmake | 76 user_queue.h \
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/third_party/usrsctp/usrsctplib/usrsctplib/ |
| H A D | Makefile.am | 42 user_queue.h \
|
| H A D | Makefile.nmake | 76 user_queue.h \
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/usrsctp/usrsctplib/usrsctplib/ |
| H A D | Makefile.am | 42 user_queue.h \
|
| H A D | Makefile.nmake | 76 user_queue.h \
|
| /dports/net/libusrsctp/usrsctp-0.9.5.0/usrsctplib/ |
| H A D | Makefile.am | 42 user_queue.h \
|
| H A D | Makefile.nmake | 76 user_queue.h \
|
| /dports/www/libdatachannel/libdatachannel-0.16.1/deps/usrsctp/usrsctplib/ |
| H A D | Makefile.am | 42 user_queue.h \
|
| H A D | Makefile.nmake | 76 user_queue.h \
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/usrsctp/ |
| H A D | BUILD.gn | 88 "usrsctplib/usrsctplib/user_queue.h",
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/third_party/usrsctp/ |
| H A D | BUILD.gn | 89 "usrsctplib/usrsctplib/user_queue.h",
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/usrsctp/ |
| H A D | BUILD.gn | 98 "usrsctplib/usrsctplib/user_queue.h",
|