| /third_party/pulseaudio/src/pulsecore/ |
| D | core-subscribe.c | 77 PA_LLIST_PREPEND(pa_subscription, c->subscriptions, s); in pa_subscription_new()
94 PA_LLIST_REMOVE(pa_subscription, s->core->subscriptions, s); in free_subscription()
113 while (c->subscriptions) in pa_subscription_free_all()
114 free_subscription(c->subscriptions); in pa_subscription_free_all()
170 for (s = c->subscriptions; s; s = s->next) { in defer_cb()
184 s = c->subscriptions; in defer_cb()
211 if (!c->subscriptions) in pa_subscription_post()
|
| D | core.h | 197 PA_LLIST_HEAD(pa_subscription, subscriptions);
|
| D | core.c | 125 PA_LLIST_HEAD_INIT(pa_subscription, c->subscriptions); in pa_core_new()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/wps/ |
| D | wps_upnp.c | 494 if (dl_list_empty(&sm->subscriptions)) { in upnp_wps_device_send_event()
541 dl_list_for_each_safe(s, tmp, &sm->subscriptions, struct subscription, in upnp_wps_device_send_event()
578 dl_list_for_each_safe(s, tmp, &sm->subscriptions, in subscription_list_age()
596 dl_list_for_each(s, &sm->subscriptions, struct subscription, list) { in subscription_find()
726 if (dl_list_len(&sm->subscriptions) >= MAX_SUBSCRIPTIONS) { in subscription_start()
727 s = dl_list_first(&sm->subscriptions, struct subscription, in subscription_start()
758 dl_list_add_tail(&sm->subscriptions, &s->list); in subscription_start()
792 dl_list_add_tail(&sm->subscriptions, &s->list); in subscription_renew()
1022 upnp_wps_free_subscriptions(&sm->subscriptions, NULL); in upnp_wps_device_stop()
1142 upnp_wps_free_subscriptions(&sm->subscriptions, in upnp_wps_device_deinit()
[all …]
|
| D | wps_upnp_i.h | 141 struct dl_list subscriptions; member
|
| D | wps_upnp_event.c | 321 dl_list_for_each_safe(s, tmp, &sm->subscriptions, struct subscription, in event_send_all_later_handler()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/wps/ |
| D | wps_upnp.c | 473 if (dl_list_empty(&sm->subscriptions)) { in upnp_wps_device_send_event()
520 dl_list_for_each_safe(s, tmp, &sm->subscriptions, struct subscription, in upnp_wps_device_send_event()
556 dl_list_for_each_safe(s, tmp, &sm->subscriptions, in subscription_list_age()
574 dl_list_for_each(s, &sm->subscriptions, struct subscription, list) { in subscription_find()
704 if (dl_list_len(&sm->subscriptions) >= MAX_SUBSCRIPTIONS) { in subscription_start()
705 s = dl_list_first(&sm->subscriptions, struct subscription, in subscription_start()
736 dl_list_add_tail(&sm->subscriptions, &s->list); in subscription_start()
770 dl_list_add_tail(&sm->subscriptions, &s->list); in subscription_renew()
986 upnp_wps_free_subscriptions(&sm->subscriptions, NULL); in upnp_wps_device_stop()
1102 upnp_wps_free_subscriptions(&sm->subscriptions, in upnp_wps_device_deinit()
[all …]
|
| D | wps_upnp_i.h | 140 struct dl_list subscriptions; member
|
| D | wps_upnp_event.c | 320 dl_list_for_each_safe(s, tmp, &sm->subscriptions, struct subscription, in event_send_all_later_handler()
|
| /third_party/boost/libs/fiber/examples/asio/ps/ |
| D | server.cpp | 30 class subscriptions { class
32 ~subscriptions();
55 typedef std::map< std::string, std::shared_ptr< subscriptions > > queues_cont;
65 queues_[queue] = std::make_shared< subscriptions >(); in register_queue_()
220 subscriptions::~subscriptions() { in ~subscriptions()
227 subscriptions::publish( std::string const& msg) { in publish()
|
| /third_party/alsa-utils/seq/aconnect/ |
| D | README.aconnect | 2 aconnect - control subscriptions
7 aconnect is a utility to control subscriptions of two ports as the
|
| /third_party/flutter/flutter/dev/bots/test/ |
| D | fake_process_manager.dart | 160 List<StreamSubscription<List<int>>> subscriptions = <StreamSubscription<List<int>>>[];
170 subscriptions.add(
175 subscriptions.last.onDone(() => completers.last.complete(null));
186 subscriptions.clear();
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/ |
| D | extension.js | 52 context.subscriptions.push(disposable);
|
| /third_party/skia/third_party/externals/spirv-tools/utils/vscode/ |
| D | extension.js | 52 context.subscriptions.push(disposable);
|
| /third_party/spirv-tools/utils/vscode/ |
| D | extension.js | 52 context.subscriptions.push(disposable);
|
| /third_party/curl/tests/data/ |
| D | test230 | 82 <subscriptions>323</subscriptions>
|
| D | test1123 | 82 <subscriptions>323</subscriptions>
|
| D | test314 | 77 <subscriptions>323</subscriptions>
|
| D | test222 | 81 <subscriptions>323</subscriptions>
|
| D | test1277 | 85 <subscriptions>323</subscriptions>
|
| D | test396 | 81 <subscriptions>323</subscriptions>
|
| D | test232 | 81 <subscriptions>323</subscriptions>
|
| /third_party/libcoap/ |
| D | coap_config.h.contiki | 59 * Maximum number of subscriptions. Every additional subscriber costs
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/dart/ |
| D | analysis.dart | 60 'subscriptions': <String>['STATUS'],
|
| /third_party/grpc/src/proto/grpc/testing/xds/v3/ |
| D | discovery.proto | 113 // For gRPC based subscriptions, the nonce provides a way to explicitly ack a
|