| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscription.hpp | 67 class subscription : public subscription_base class
109 friend bool operator<(const subscription&, const subscription&);
110 friend bool operator==(const subscription&, const subscription&);
113 subscription(weak_state_type w) in subscription() function in rxcpp::subscription
121 explicit subscription(std::shared_ptr<base_subscription_state> s) in subscription() function in rxcpp::subscription
130 subscription() in subscription() function in rxcpp::subscription
138 …explicit subscription(U u, typename std::enable_if<!is_subscription<U>::value, void**>::type = nul… in subscription() function in rxcpp::subscription
146 …explicit subscription(U u, typename std::enable_if<!std::is_same<subscription, U>::value && is_sub… in subscription() argument
148 : state(std::move((*static_cast<subscription*>(&u)).state)) in subscription()
154 subscription(const subscription& o) in subscription() function in rxcpp::subscription
[all …]
|
| D | rx-notification.hpp | 14 class subscription class
20 explicit inline subscription(long s) in subscription() function in rxcpp::notifications::subscription
23 inline subscription(long s, long u) in subscription() function in rxcpp::notifications::subscription
34 inline bool operator == (subscription lhs, subscription rhs) { in operator ==()
38 inline std::ostream& operator<< (std::ostream& out, const subscription& s) { in operator <<()
271 …stream& operator<< (std::ostream& out, const std::vector<rxcpp::notifications::subscription>& vs) { in operator <<()
|
| D | rx-test.hpp | 24 virtual std::vector<rxn::subscription> subscriptions() const =0;
101 std::vector<rxn::subscription> subscriptions() const { in subscriptions()
|
| /external/wpa_supplicant_8/src/wps/ |
| D | wps_upnp_i.h | 79 struct subscription { struct
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 *s);
187 struct subscription *s,
190 struct subscription *s);
|
| D | wps_upnp_event.c | 50 struct subscription *s; /* parent */
86 static struct wps_event_ *event_dequeue(struct subscription *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()
175 struct subscription *s = e->s; in event_addr_failure()
216 struct subscription *s = e->s; in event_http_cb()
269 static int event_send_start(struct subscription *s) in event_send_start()
316 struct subscription *s, *tmp; in event_send_all_later_handler()
320 dl_list_for_each_safe(s, tmp, &sm->subscriptions, struct subscription, in event_send_all_later_handler()
373 int event_add(struct subscription *s, const struct wpabuf *data, int probereq) in event_add()
|
| D | wps_upnp.c | 295 static void subscr_addr_free_all(struct subscription *s) in subscr_addr_free_all()
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()
539 void subscription_destroy(struct subscription *s) in subscription_destroy()
555 struct subscription *s, *tmp; in subscription_list_age()
557 struct subscription, list) { in subscription_list_age()
570 struct subscription * subscription_find(struct upnp_wps_device_sm *sm, in subscription_find()
573 struct subscription *s; in subscription_find()
[all …]
|
| D | wps_upnp_ap.c | 21 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()
|
| D | wps_upnp_web.c | 675 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()
1217 struct subscription *s = NULL; in web_connection_parse_unsubscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | create.cpp | 24 auto subscription = rxcpp::composite_subscription(); variable
26 subscription,
30 subscription.unsubscribe(); in __anonfb3350bc0402()
49 auto subscription = rxcpp::composite_subscription(); variable
51 subscription,
55 subscription.unsubscribe(); in __anonfb3350bc0702()
|
| D | subscribe.cpp | 62 auto subscription = rxcpp::composite_subscription(); variable
65 subscription,
66 [&subscription](int v){ in __anon7d8cc7aa0a02()
69 subscription.unsubscribe(); in __anon7d8cc7aa0a02()
96 auto subscription = values.subscribe( variable
99 subscription.unsubscribe();
|
| /external/wpa_supplicant_8/hs20/server/ |
| D | sql-example.txt | 3 …(realm,field,value) VALUES('example.com','spp_http_auth_url','https://subscription-server.osu.exam…
9 INSERT INTO osu_config(realm,field,value) VALUES('example.com','policy_url','https://subscription-s…
10 …ig(realm,field,value) VALUES('example.com','remediation_url','https://subscription-server.osu.exam…
11 …alm,field,value) VALUES('example.com','free_remediation_url','https://subscription-server.osu.exam…
12 INSERT INTO osu_config(realm,field,value) VALUES('example.com','signup_url','https://subscription-s…
|
| D | hs20-osu-server.txt | 120 # Configure subscription policies
158 subscr_remediation_url=https://subscription-server.osu.example.com/hs20/spp.php
238 To support subscription remediation using client certificates, set
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-test.hpp | 178 virtual std::vector<rxn::subscription> subscriptions() const { in subscriptions()
224 mutable std::vector<rxn::subscription> sv;
245 sv.push_back(rxn::subscription(sc->clock())); in on_subscribe()
261 …sharedThis->sv[index] = rxn::subscription(sharedThis->sv[index].subscribe(), sharedThis->sc->clock… in on_subscribe()
265 virtual std::vector<rxn::subscription> subscriptions() const { in subscriptions()
290 mutable std::vector<rxn::subscription> sv;
321 sv.push_back(rxn::subscription(sc->clock())); in on_subscribe()
326 …sharedThis->sv[index] = rxn::subscription(sharedThis->sv[index].subscribe(), sharedThis->sc->clock… in on_subscribe()
331 virtual std::vector<rxn::subscription> subscriptions() const { in subscriptions()
384 typedef rxn::subscription subscription_type;
[all …]
|
| /external/autotest/client/site_tests/cellular_OutOfCreditsSubscriptionState/ |
| D | control.pseudomodem | 7 PURPOSE = "Verify shill out-of-credits behavior using subscription state."
12 - Shill does not clear the out-of-credits flag when the subscription state
22 modem subscription state by using a pseudomodem.
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/stop/ |
| D | main.cpp | 29 auto subscription = published_observable.connect(); in main() local
31 subscription.unsubscribe(); in main()
|
| /external/grpc-grpc/examples/ruby/pubsub/ |
| D | pubsub_demo.rb | 142 batch = @sub.pull_batch(PullBatchRequest.new(subscription: sub_name,
146 @sub.acknowledge(AcknowledgeRequest.new(subscription: sub_name,
149 del_req = DeleteSubscriptionRequest.new(subscription: sub_name)
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | switch_if_empty.cpp | 49 auto required = std::vector<rxn::subscription>();
153 auto required = std::vector<rxn::subscription>();
207 auto required = std::vector<rxn::subscription>();
|
| D | on_error_resume_next.cpp | 63 auto required = std::vector<rxcpp::notifications::subscription>();
134 auto required = std::vector<rxcpp::notifications::subscription>();
|
| D | retry.cpp | 110 auto required = std::vector<rxcpp::notifications::subscription>();
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | rostermoduleimpl.cc | 69 StringToSubscriptionState(const std::string& subscription, in StringToSubscriptionState() argument
75 if (subscription == "none") { in StringToSubscriptionState()
79 if (subscription == "from") { in StringToSubscriptionState()
85 if (subscription == "none") { in StringToSubscriptionState()
89 if (subscription == "from") { in StringToSubscriptionState()
93 if (subscription == "to") { in StringToSubscriptionState()
97 if (subscription == "both") { in StringToSubscriptionState()
|
| /external/libpng/ |
| D | ANNOUNCE | 30 (subscription required; visit
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/base/ |
| D | base.py | 280 subscription, argument
|
| /external/libchrome/base/ |
| D | callback_list_unittest.cc | 312 std::unique_ptr<CallbackList<void(void)>::Subscription> subscription = in TEST() local
317 subscription.reset(); in TEST()
|
| /external/deqp/doc/testspecs/GLES31/ |
| D | functional.shaders.implicit_conversions.txt | 30 + Array subscription
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | subscribe_test.py | 378 for tensor, subscription in zip(tensors, subscriptions):
379 self.assertIs(context(tensor), context(subscription))
|