/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/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-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/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-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/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/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-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/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/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/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/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/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/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()
|