Home
last modified time | relevance | path

Searched refs:subscription (Results 1 - 22 of 22) sorted by relevance

/third_party/wpa_supplicant/wpa_supplicant-2.9/src/wps/
H A Dwps_upnp_i.h79 struct subscription { struct
82 time_t timeout_time; /* when to age out the subscription */
85 * This uuid identifies the subscription and is randomly generated by
86 * us and given to the subscriber when the subscription is accepted;
152 struct subscription * subscription_start(struct upnp_wps_device_sm *sm,
154 struct subscription * subscription_renew(struct upnp_wps_device_sm *sm,
156 void subscription_destroy(struct subscription *s);
157 struct subscription * subscription_find(struct upnp_wps_device_sm *sm,
180 int event_add(struct subscription *s, const struct wpabuf *data, int probereq);
181 void event_delete_all(struct subscription *
[all...]
H A Dwps_upnp_event.c34 #define MAX_FAILURES 10 /* Drop subscription after this many failures */
50 struct subscription *s; /* parent */
51 unsigned subscriber_sequence; /* which event for this subscription*/
86 static struct wps_event_ *event_dequeue(struct subscription *s) in event_dequeue()
92 "subscription %p", e, s); in event_dequeue()
100 void event_delete_all(struct subscription *s) in event_delete_all()
119 struct subscription *s = e->s; in event_retry()
122 wpa_printf(MSG_DEBUG, "WPS UPnP: Retry event %p for subscription %p", in event_retry()
175 struct subscription *s = e->s; in event_addr_failure()
192 wpa_printf(MSG_DEBUG, "WPS UPnP: Deleting subscription in event_addr_failure()
[all...]
H A Dwps_upnp.c295 static void subscr_addr_free_all(struct subscription *s) in subscr_addr_free_all()
306 /* subscr_addr_add_url -- add address(es) for one url to subscription */
307 static void subscr_addr_add_url(struct subscription *s, const char *url, in subscr_addr_add_url()
420 static void subscr_addr_list_create(struct subscription *s, in subscr_addr_list_create()
465 struct subscription *s, *tmp; in upnp_wps_device_send_event()
520 dl_list_for_each_safe(s, tmp, &sm->subscriptions, struct subscription, in upnp_wps_device_send_event()
531 * Event subscription (subscriber machines register with us to receive event
536 /* subscription_destroy -- destroy an unlinked subscription
539 void subscription_destroy(struct subscription *s) in subscription_destroy()
542 wpa_printf(MSG_DEBUG, "WPS UPnP: Destroy subscription in subscription_destroy()
964 dl_list_for_each_safe(s, tmp, head, struct subscription, list) upnp_wps_free_subscriptions() argument
[all...]
H A Dwps_upnp_ap.c21 struct subscription *s = eloop_ctx; in upnp_er_set_selected_timeout()
30 struct subscription *s, in upnp_er_set_selected_registrar()
77 struct subscription *s) in upnp_er_remove_notification()
H A Dwps_upnp_web.c675 static int find_er_addr(struct subscription *s, struct sockaddr_in *cli) in find_er_addr()
687 static struct subscription * find_er(struct upnp_wps_device_sm *sm, in find_er()
690 struct subscription *s; in find_er()
691 dl_list_for_each(s, &sm->subscriptions, struct subscription, list) in find_er()
706 struct subscription *s; in web_process_set_selected_registrar()
999 struct subscription *s = NULL; in web_connection_parse_subscribe()
1030 /* NT assures that it is our type of subscription; in web_connection_parse_subscribe()
1060 * to be sent as a result of the subscription. in web_connection_parse_subscribe()
1125 wpa_printf(MSG_DEBUG, "WPS UPnP: New subscription"); in web_connection_parse_subscribe()
1146 /* subscription i in web_connection_parse_subscribe()
[all...]
H A Dwps_registrar.c3490 struct subscription *s) in wps_registrar_sel_reg_add()
3525 struct subscription *s; in wps_registrar_sel_reg_union()
3531 struct subscription, list) { in wps_registrar_sel_reg_union()
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/wps/
H A Dwps_upnp_i.h79 struct subscription { struct
82 time_t timeout_time; /* when to age out the subscription */
85 * This uuid identifies the subscription and is randomly generated by
86 * us and given to the subscriber when the subscription is accepted;
153 struct subscription * subscription_start(struct upnp_wps_device_sm *sm,
155 struct subscription * subscription_renew(struct upnp_wps_device_sm *sm,
157 void subscription_destroy(struct subscription *s);
158 struct subscription * subscription_find(struct upnp_wps_device_sm *sm,
181 int wps_upnp_event_add(struct subscription *s, const struct wpabuf *data,
183 void wps_upnp_event_delete_all(struct subscription *
[all...]
H A Dwps_upnp_event.c34 #define MAX_FAILURES 10 /* Drop subscription after this many failures */
50 struct subscription *s; /* parent */
51 unsigned subscriber_sequence; /* which event for this subscription*/
86 static struct wps_event_ *event_dequeue(struct subscription *s) in event_dequeue()
92 "subscription %p", e, s); in event_dequeue()
100 void wps_upnp_event_delete_all(struct subscription *s) in wps_upnp_event_delete_all()
119 struct subscription *s = e->s; in event_retry()
122 wpa_printf(MSG_DEBUG, "WPS UPnP: Retry event %p for subscription %p", in event_retry()
176 struct subscription *s = e->s; in event_addr_failure()
193 wpa_printf(MSG_DEBUG, "WPS UPnP: Deleting subscription in event_addr_failure()
[all...]
H A Dwps_upnp.c295 static void subscr_addr_free_all(struct subscription *s) in subscr_addr_free_all()
314 /* subscr_addr_add_url -- add address(es) for one url to subscription */
315 static void subscr_addr_add_url(struct subscription *s, const char *url, in subscr_addr_add_url()
441 static void subscr_addr_list_create(struct subscription *s, in subscr_addr_list_create()
486 struct subscription *s, *tmp; in upnp_wps_device_send_event()
541 dl_list_for_each_safe(s, tmp, &sm->subscriptions, struct subscription, in upnp_wps_device_send_event()
553 * Event subscription (subscriber machines register with us to receive event
558 /* subscription_destroy -- destroy an unlinked subscription
561 void subscription_destroy(struct subscription *s) in subscription_destroy()
564 wpa_printf(MSG_DEBUG, "WPS UPnP: Destroy subscription in subscription_destroy()
1000 dl_list_for_each_safe(s, tmp, head, struct subscription, list) upnp_wps_free_subscriptions() argument
[all...]
H A Dwps_upnp_ap.c21 struct subscription *s = eloop_ctx; in upnp_er_set_selected_timeout()
30 struct subscription *s, in upnp_er_set_selected_registrar()
77 struct subscription *s) in upnp_er_remove_notification()
H A Dwps_upnp_web.c675 static int find_er_addr(struct subscription *s, struct sockaddr_in *cli) in find_er_addr()
687 static struct subscription * find_er(struct upnp_wps_device_sm *sm, in find_er()
690 struct subscription *s; in find_er()
691 dl_list_for_each(s, &sm->subscriptions, struct subscription, list) in find_er()
706 struct subscription *s; in web_process_set_selected_registrar()
999 struct subscription *s = NULL; in web_connection_parse_subscribe()
1030 /* NT assures that it is our type of subscription; in web_connection_parse_subscribe()
1060 * to be sent as a result of the subscription. in web_connection_parse_subscribe()
1125 wpa_printf(MSG_DEBUG, "WPS UPnP: New subscription"); in web_connection_parse_subscribe()
1146 /* subscription i in web_connection_parse_subscribe()
[all...]
H A Dwps_registrar.c3482 struct subscription *s) in wps_registrar_sel_reg_add()
3517 struct subscription *s; in wps_registrar_sel_reg_union()
3523 struct subscription, list) { in wps_registrar_sel_reg_union()
/third_party/node/lib/
H A Ddiagnostics_channel.js96 subscribe(subscription) {
97 validateFunction(subscription, 'subscription');
98 ArrayPrototypePush(this._subscribers, subscription);
102 unsubscribe(subscription) {
103 const index = ArrayPrototypeIndexOf(this._subscribers, subscription);
181 subscribe(subscription) {
183 this.subscribe(subscription);
223 function subscribe(name, subscription) {
224 return channel(name).subscribe(subscription);
[all...]
/third_party/pulseaudio/src/modules/
H A Dmodule-default-device-restore.c46 pa_subscription *subscription; member
164 u->subscription = pa_subscription_new(u->core, PA_SUBSCRIPTION_MASK_SERVER, subscribe_cb, u); in pa__init()
184 if (u->subscription) in pa__done()
185 pa_subscription_free(u->subscription); in pa__done()
H A Dmodule-device-restore.c78 pa_subscription *subscription; member
1244 u->subscription = pa_subscription_new(m->core, PA_SUBSCRIPTION_MASK_SINK|PA_SUBSCRIPTION_MASK_SOURCE, subscribe_callback, u); in pa__init()
1298 if (u->subscription) in pa__done()
1299 pa_subscription_free(u->subscription); in pa__done()
H A Dmodule-device-manager.c102 pa_subscription *subscription; member
855 by changing the description here, we retrigger this subscription callback. The only thing stopping us from in subscribe_callback()
885 by changing the description here, we retrigger this subscription callback. The only thing stopping us from in subscribe_callback()
1581 u->subscription = pa_subscription_new(m->core, PA_SUBSCRIPTION_MASK_SINK|PA_SUBSCRIPTION_MASK_SOURCE|PA_SUBSCRIPTION_MASK_SINK_INPUT|PA_SUBSCRIPTION_MASK_SOURCE_OUTPUT, subscribe_callback, u); in pa__init()
1700 if (u->subscription) in pa__done()
1701 pa_subscription_free(u->subscription); in pa__done()
H A Dmodule-stream-restore.c92 pa_subscription *subscription; member
2365 u->subscription = pa_subscription_new(m->core, PA_SUBSCRIPTION_MASK_SINK_INPUT|PA_SUBSCRIPTION_MASK_SOURCE_OUTPUT, subscribe_callback, u); in pa__init()
2462 if (u->subscription) in pa__done()
2463 pa_subscription_free(u->subscription); in pa__done()
/third_party/node/deps/uvwasi/src/
H A Dpoll_oneoff.c159 uvwasi_subscription_t* subscription in uvwasi__poll_oneoff_state_add_fdevent()
175 fd = subscription->u.fd_readwrite.fd; in uvwasi__poll_oneoff_state_add_fdevent()
176 type = subscription->type; in uvwasi__poll_oneoff_state_add_fdevent()
242 event->userdata = subscription->userdata; in uvwasi__poll_oneoff_state_add_fdevent()
H A Dpoll_oneoff.h52 uvwasi_subscription_t* subscription
/third_party/pulseaudio/src/pulsecore/
H A Dprotocol-native.h176 pa_subscription *subscription; member
H A Dprotocol-native.c1030 if (c->subscription) in native_connection_unlink()
1031 pa_subscription_free(c->subscription); in native_connection_unlink()
3619 if (c->subscription) in command_subscribe()
3620 pa_subscription_free(c->subscription); in command_subscribe()
3623 c->subscription = pa_subscription_new(c->protocol->core, m, subscription_cb, c); in command_subscribe()
3624 pa_assert(c->subscription); in command_subscribe()
3626 c->subscription = NULL; in command_subscribe()
5154 c->subscription = NULL; in pa_native_protocol_connect()
/third_party/libcoap/src/
H A Dcoap_net.c3113 coap_subscription_t *subscription; in handle_request() local
3129 subscription = coap_add_observer(resource, session, &pdu->actual_token, in handle_request()
3131 if (subscription) { in handle_request()
3741 /* Need to check is there is a subscription active and delete it */ in coap_dispatch()

Completed in 38 milliseconds