| /third_party/libwebsockets/lib/core-net/ |
| D | sorted-usec-list.c | 51 __lws_sul_insert(lws_dll2_owner_t *own, lws_sorted_usec_list_t *sul) in __lws_sul_insert() argument
53 lws_dll2_remove(&sul->list); in __lws_sul_insert()
55 assert(sul->cb); in __lws_sul_insert()
62 lws_dll2_add_sorted(&sul->list, own, sul_compare); in __lws_sul_insert()
68 lws_sul_cancel(lws_sorted_usec_list_t *sul) in lws_sul_cancel() argument
70 lws_dll2_remove(&sul->list); in lws_sul_cancel()
73 sul->us = 0; in lws_sul_cancel()
78 lws_sorted_usec_list_t *sul) in lws_sul2_schedule() argument
84 assert(sul->cb); in lws_sul2_schedule()
87 &pt->pt_sul_owner[!!(flags & LWSSULLI_WAKE_IF_SUSPENDED)], sul); in lws_sul2_schedule()
[all …]
|
| D | sequencer.c | 63 lws_sul_seq_heartbeat_cb(lws_sorted_usec_list_t *sul) in lws_sul_seq_heartbeat_cb() argument
65 struct lws_context_per_thread *pt = lws_container_of(sul, in lws_sul_seq_heartbeat_cb()
186 lws_seq_sul_pending_cb(lws_sorted_usec_list_t *sul) in lws_seq_sul_pending_cb() argument
188 lws_seq_t *seq = lws_container_of(sul, lws_seq_t, sul_pending); in lws_seq_sul_pending_cb()
292 lws_seq_sul_timeout_cb(lws_sorted_usec_list_t *sul) in lws_seq_sul_timeout_cb() argument
294 lws_seq_t *s = lws_container_of(sul, lws_seq_t, sul_timeout); in lws_seq_sul_timeout_cb()
|
| D | wsi-timeout.c | 43 lws_sul_hrtimer_cb(lws_sorted_usec_list_t *sul) in lws_sul_hrtimer_cb() argument
45 struct lws *wsi = lws_container_of(sul, struct lws, sul_hrtimer); in lws_sul_hrtimer_cb()
75 lws_sul_wsitimeout_cb(lws_sorted_usec_list_t *sul) in lws_sul_wsitimeout_cb() argument
77 struct lws *wsi = lws_container_of(sul, struct lws, sul_timeout); in lws_sul_wsitimeout_cb()
199 lws_validity_cb(lws_sorted_usec_list_t *sul) in lws_validity_cb() argument
201 struct lws *wsi = lws_container_of(sul, struct lws, sul_validity); in lws_validity_cb()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-server-raw/ |
| D | ss-server.c | 20 lws_sorted_usec_list_t sul; member
53 spam_sul_cb(struct lws_sorted_usec_list *sul) in spam_sul_cb() argument
55 myss_srv_t *m = lws_container_of(sul, myss_srv_t, sul); in spam_sul_cb()
58 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, spam_sul_cb, in spam_sul_cb()
72 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, spam_sul_cb, in myss_raw_tx()
89 lws_sul_cancel(&m->sul); in myss_raw_state()
|
| /third_party/libwebsockets/minimal-examples/client-server/minimal-ws-proxy/ |
| D | protocol_lws_minimal.c | 44 lws_sorted_usec_list_t sul; member
66 sul_connect_attempt(struct lws_sorted_usec_list *sul) in sul_connect_attempt() argument
69 lws_container_of(sul, struct per_vhost_data__minimal, sul); in sul_connect_attempt()
84 lws_sul_schedule(vhd->context, 0, &vhd->sul, in sul_connect_attempt()
119 sul_connect_attempt(&vhd->sul); in callback_minimal()
124 lws_sul_cancel(&vhd->sul); in callback_minimal()
177 lws_sul_schedule(vhd->context, 0, &vhd->sul, in callback_minimal()
222 lws_sul_schedule(vhd->context, 0, &vhd->sul, in callback_minimal()
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-h2-long-poll/ |
| D | minimal-http-server.c | 32 lws_sorted_usec_list_t sul; member
42 sul_cb(lws_sorted_usec_list_t *sul) in sul_cb() argument
44 struct pss *pss = (struct pss *)lws_container_of(sul, struct pss, sul); in sul_cb()
49 lws_sul_schedule(lws_get_context(pss->wsi), 0, &pss->sul, sul_cb, in sul_cb()
76 sul_cb(&pss->sul); in callback_http()
82 lws_sul_cancel(&pss->sul); in callback_http()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-client-tx/ |
| D | minimal-secure-streams-client-tx.c | 32 lws_sorted_usec_list_t sul; member
48 txcb(struct lws_sorted_usec_list *sul) in txcb() argument
50 myss_t *m = lws_container_of(sul, myss_t, sul); in txcb()
65 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, txcb, RATE_US); in txcb()
87 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, txcb, RATE_US); in myss_tx()
109 lws_sul_schedule(context, 0, &m->sul, txcb, RATE_US); in myss_state()
112 lws_sul_cancel(&m->sul); in myss_state()
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-pmd-bulk/ |
| D | protocol_lws_minimal_pmd_bulk.c | 68 lws_sorted_usec_list_t sul; member
84 sul_connect_attempt(struct lws_sorted_usec_list *sul) in sul_connect_attempt() argument
87 lws_container_of(sul, struct vhd_minimal_pmd_bulk, sul); in sul_connect_attempt()
104 lws_sul_schedule(vhd->context, 0, &vhd->sul, in sul_connect_attempt()
140 sul_connect_attempt(&vhd->sul); in callback_minimal_pmd_bulk()
144 lws_sul_cancel(&vhd->sul); in callback_minimal_pmd_bulk()
258 lws_sul_schedule(vhd->context, 0, &vhd->sul, in callback_minimal_pmd_bulk()
264 lws_sul_schedule(vhd->context, 0, &vhd->sul, in callback_minimal_pmd_bulk()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-server/ |
| D | ss-server.c | 53 lws_sorted_usec_list_t sul; member
133 spam_sul_cb(struct lws_sorted_usec_list *sul) in spam_sul_cb() argument
135 myss_srv_t *m = lws_container_of(sul, myss_srv_t, sul); in spam_sul_cb()
138 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, spam_sul_cb, in spam_sul_cb()
152 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, spam_sul_cb, in myss_ws_tx()
169 lws_sul_cancel(&m->sul); in myss_srv_state()
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client/ |
| D | minimal-ws-client.c | 23 lws_sorted_usec_list_t sul; /* schedule connection retry */ member
55 connect_client(lws_sorted_usec_list_t *sul) in connect_client() argument
57 struct my_conn *mco = lws_container_of(sul, struct my_conn, sul); in connect_client()
81 if (lws_retry_sul_schedule(context, 0, sul, &retry, in connect_client()
130 if (lws_retry_sul_schedule_retry_wsi(wsi, &mco->sul, connect_client, in callback_minimal()
207 lws_sul_schedule(context, 0, &mco.sul, connect_client, 1); in main()
|
| /third_party/libwebsockets/include/libwebsockets/ |
| D | lws-timeout-timer.h | 155 typedef void (*sul_cb_t)(struct lws_sorted_usec_list *sul);
201 lws_sorted_usec_list_t *sul);
212 lws_sul_cancel(lws_sorted_usec_list_t *sul);
234 lws_sul_schedule(struct lws_context *ctx, int tsi, lws_sorted_usec_list_t *sul,
238 lws_sorted_usec_list_t *sul, sul_cb_t _cb,
299 __lws_sul_insert(lws_dll2_owner_t *own, lws_sorted_usec_list_t *sul);
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-smd/ |
| D | minimal-secure-streams-smd.c | 67 lws_sorted_usec_list_t sul; member
92 sul_tx_periodic_cb(lws_sorted_usec_list_t *sul) in sul_tx_periodic_cb() argument
94 myss_t *m = lws_container_of(sul, myss_t, sul); in sul_tx_periodic_cb()
143 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, in myss_tx()
159 lws_sul_cancel(&m->sul); in myss_state()
165 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, in myss_state()
239 sul_timeout_cb(lws_sorted_usec_list_t *sul) in sul_timeout_cb() argument
|
| D | multi.c | 45 lws_sorted_usec_list_t sul; member
125 sul_multi_tx_periodic_cb(lws_sorted_usec_list_t *sul) in sul_multi_tx_periodic_cb() argument
127 myss_t *m = lws_container_of(sul, myss_t, sul); in sul_multi_tx_periodic_cb()
175 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, in multi_myss_tx()
193 lws_sul_cancel(&m->sul); in multi_myss_state()
206 lws_sul_schedule(lws_ss_get_context(m->ss), 0, &m->sul, in multi_myss_state()
325 sul_timeout_cb(lws_sorted_usec_list_t *sul) in sul_timeout_cb() argument
|
| /third_party/libwebsockets/minimal-examples/raw/minimal-raw-serial/ |
| D | minimal-raw-file.c | 28 lws_sorted_usec_list_t sul; member
36 sul_cb(lws_sorted_usec_list_t *sul) in sul_cb() argument
38 struct raw_vhd *v = lws_container_of(sul, struct raw_vhd, sul); in sul_cb()
42 lws_sul_schedule(lws_get_context(v->wsi), 0, &v->sul, sul_cb, in sul_cb()
144 lws_sul_schedule(lws_get_context(wsi), 0, &vhd->sul, sul_cb, 1); in callback_raw_test()
160 lws_sul_cancel(&vhd->sul); in callback_raw_test()
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threadpool/ |
| D | protocol_lws_minimal_threadpool.c | 38 lws_sorted_usec_list_t sul; member
140 sul_tp_dump(struct lws_sorted_usec_list *sul) in sul_tp_dump() argument
143 lws_container_of(sul, struct per_vhost_data__minimal, sul); in sul_tp_dump()
149 lws_sul_schedule(vhd->context, 0, &vhd->sul, in sul_tp_dump()
202 lws_sul_schedule(vhd->context, 0, &vhd->sul, in callback_minimal()
209 lws_sul_cancel(&vhd->sul); in callback_minimal()
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-binance/ |
| D | main.c | 32 lws_sorted_usec_list_t sul; /* schedule connection retry */ member
121 connect_client(lws_sorted_usec_list_t *sul) in connect_client() argument
123 struct my_conn *mco = lws_container_of(sul, struct my_conn, sul); in connect_client()
148 if (lws_retry_sul_schedule(context, 0, sul, &retry, in connect_client()
174 sul_hz_cb(lws_sorted_usec_list_t *sul) in sul_hz_cb() argument
176 struct my_conn *mco = lws_container_of(sul, struct my_conn, sul_hz); in sul_hz_cb()
319 if (lws_retry_sul_schedule_retry_wsi(wsi, &mco->sul, connect_client, in callback_minimal()
372 lws_sul_schedule(context, 0, &mco.sul, connect_client, 1); in main()
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-tx/ |
| D | minimal-ws-client.c | 47 lws_sorted_usec_list_t sul; member
136 sul_connect_attempt(struct lws_sorted_usec_list *sul) in sul_connect_attempt() argument
139 lws_container_of(sul, struct per_vhost_data__minimal, sul); in sul_connect_attempt()
153 lws_sul_schedule(vhd->context, 0, &vhd->sul, in sul_connect_attempt()
198 sul_connect_attempt(&vhd->sul); in callback_minimal_broker()
210 lws_sul_cancel(&vhd->sul); in callback_minimal_broker()
219 lws_sul_schedule(vhd->context, 0, &vhd->sul, in callback_minimal_broker()
259 lws_sul_schedule(vhd->context, 0, &vhd->sul, in callback_minimal_broker()
|
| /third_party/libwebsockets/lib/secure-streams/system/fetch-policy/ |
| D | fetch-policy.c | 34 lws_sorted_usec_list_t sul; member
70 policy_set(lws_sorted_usec_list_t *sul) in policy_set() argument
72 ss_fetch_policy_t *m = lws_container_of(sul, ss_fetch_policy_t, sul); in policy_set()
113 lws_sul_schedule(context, 0, &m->sul, policy_set, 1); in ss_fetch_policy_state()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-alexa/ |
| D | alexa.c | 51 lws_sorted_usec_list_t sul; member
101 use_buffer_250ms(lws_sorted_usec_list_t *sul) in use_buffer_250ms() argument
103 ss_avs_metadata_t *m = lws_container_of(sul, ss_avs_metadata_t, sul); in use_buffer_250ms()
114 lws_sul_schedule(context, 0, &m->sul, use_buffer_250ms, in use_buffer_250ms()
189 lws_sul_schedule(context, 0, &m->sul, use_buffer_250ms, 1); in drain_end_cb()
237 lws_sul_cancel(&m->sul); in drain_end_cb()
326 lws_sul_schedule(context, 0, &m->sul, use_buffer_250ms, 1); in ss_avs_metadata_rx()
357 lws_sul_schedule(context, 0, &m->sul, in ss_avs_metadata_rx()
393 lws_sul_cancel(&m->sul); in ss_avs_metadata_rx()
550 lws_sul_cancel(&m->sul); in ss_avs_metadata_state()
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-echo/ |
| D | protocol_lws_minimal_client_echo.c | 46 lws_sorted_usec_list_t sul; member
57 sul_connect_attempt(struct lws_sorted_usec_list *sul) in sul_connect_attempt() argument
60 lws_container_of(sul, struct vhd_minimal_client_echo, sul); in sul_connect_attempt()
85 lws_sul_schedule(vhd->context, 0, &vhd->sul, in sul_connect_attempt()
144 sul_connect_attempt(&vhd->sul); in callback_minimal_client_echo()
148 lws_sul_cancel(&vhd->sul); in callback_minimal_client_echo()
|
| /third_party/libwebsockets/lib/plat/windows/ |
| D | windows-spawn.c | 32 lws_spawn_timeout(struct lws_sorted_usec_list *sul) in lws_spawn_timeout() argument
34 struct lws_spawn_piped *lsp = lws_container_of(sul, in lws_spawn_timeout()
35 struct lws_spawn_piped, sul); in lws_spawn_timeout()
43 lws_spawn_sul_reap(struct lws_sorted_usec_list *sul) in lws_spawn_sul_reap() argument
45 struct lws_spawn_piped *lsp = lws_container_of(sul, in lws_spawn_sul_reap()
139 lws_sul_cancel(&lsp->sul); in lws_spawn_piped_destroy()
183 &lsp->sul, lws_spawn_timeout, in lws_spawn_reap()
201 lws_sul_cancel(&lsp->sul); in lws_spawn_reap()
250 windows_pipe_poll_hack(lws_sorted_usec_list_t *sul) in windows_pipe_poll_hack() argument
252 struct lws_spawn_piped *lsp = lws_container_of(sul, in windows_pipe_poll_hack()
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-client/minimal-http-client-h2-rxflow/ |
| D | minimal-http-client.c | 28 lws_sorted_usec_list_t sul; member
38 drain_cb(lws_sorted_usec_list_t *sul) in drain_cb() argument
40 struct pss *pss = lws_container_of(sul, struct pss, sul); in drain_cb()
44 lws_sul_schedule(lws_get_context(pss->wsi), 0, &pss->sul, drain_cb, in drain_cb()
75 lws_sul_schedule(lws_get_context(wsi), 0, &pss->sul, drain_cb, in callback_http()
118 lws_sul_cancel(&pss->sul); in callback_http()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-avs/ |
| D | avs.c | 50 lws_sorted_usec_list_t sul; member
79 use_buffer_50ms(lws_sorted_usec_list_t *sul) in use_buffer_50ms() argument
81 ss_avs_metadata_t *m = lws_container_of(sul, ss_avs_metadata_t, sul); in use_buffer_50ms()
110 lws_sul_schedule(context, 0, &m->sul, use_buffer_50ms, in use_buffer_50ms()
151 lws_sul_schedule(context, 0, &m->sul, use_buffer_50ms, in ss_avs_metadata_rx()
248 lws_sul_cancel(&m->sul); in ss_avs_metadata_state()
252 lws_sul_cancel(&m->sul); in ss_avs_metadata_state()
|
| /third_party/libwebsockets/lib/system/async-dns/ |
| D | async-dns.c | 39 lws_sul_cancel(&q->sul); in lws_adns_q_destroy()
129 lws_async_dns_sul_cb_retry(struct lws_sorted_usec_list *sul) in lws_async_dns_sul_cb_retry() argument
131 lws_adns_q_t *q = lws_container_of(sul, lws_adns_q_t, sul); in lws_async_dns_sul_cb_retry()
176 if (lws_dll2_is_detached(&q->sul.list) && in lws_async_dns_writeable()
177 lws_retry_sul_schedule_retry_wsi(wsi, &q->sul, in lws_async_dns_writeable()
433 (long long)(c->sul.us - lws_now_usecs()), in lws_adns_dump()
451 lws_dll2_remove(&c->sul.list); in lws_adns_cache_destroy()
467 sul_cb_expire(struct lws_sorted_usec_list *sul) in sul_cb_expire() argument
469 lws_adns_cache_t *c = lws_container_of(sul, lws_adns_cache_t, sul); in sul_cb_expire()
475 sul_cb_write(struct lws_sorted_usec_list *sul) in sul_cb_write() argument
[all …]
|
| /third_party/libwebsockets/lib/plat/unix/ |
| D | unix-spawn.c | 38 lws_spawn_timeout(struct lws_sorted_usec_list *sul) in lws_spawn_timeout() argument
40 struct lws_spawn_piped *lsp = lws_container_of(sul, in lws_spawn_timeout()
41 struct lws_spawn_piped, sul); in lws_spawn_timeout()
49 lws_spawn_sul_reap(struct lws_sorted_usec_list *sul) in lws_spawn_sul_reap() argument
51 struct lws_spawn_piped *lsp = lws_container_of(sul, in lws_spawn_sul_reap()
124 lws_sul_cancel(&lsp->sul); in lws_spawn_piped_destroy()
194 &lsp->sul, lws_spawn_timeout, in lws_spawn_reap()
213 lws_sul_cancel(&lsp->sul); in lws_spawn_reap()
487 lws_sul_schedule(context, i->tsi, &lsp->sul, lws_spawn_timeout, in lws_spawn_piped()
495 lws_sul_schedule(context, i->tsi, &lsp->sul, in lws_spawn_piped()
|