Home
last modified time | relevance | path

Searched refs:sul (Results 1 - 25 of 93) sorted by relevance

1234

/third_party/libwebsockets/lib/core-net/
H A Dsorted-usec-list.c47 * notice owner was chosen already, and sul->us was already computed
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()
84 assert(sul in lws_sul2_schedule()
77 lws_sul2_schedule(struct lws_context *context, int tsi, int flags, lws_sorted_usec_list_t *sul) lws_sul2_schedule() argument
129 lws_sorted_usec_list_t *sul; __lws_sul_service_ripe() local
215 lws_sorted_usec_list_t *sul = lws_container_of( lws_sul_nonmonotonic_adjust() local
254 lws_sorted_usec_list_t *sul = (lws_sorted_usec_list_t *) lws_sul_earliest_wakeable_event() local
278 lws_sul_schedule(struct lws_context *ctx, int tsi, lws_sorted_usec_list_t *sul, sul_cb_t _cb, lws_usec_t _us) lws_sul_schedule() argument
299 lws_sul_schedule_wakesuspend(struct lws_context *ctx, int tsi, lws_sorted_usec_list_t *sul, sul_cb_t _cb, lws_usec_t _us) lws_sul_schedule_wakesuspend() argument
345 lws_sorted_usec_list_t *sul = lws_sul_debug_zombies() local
[all...]
H A Dwsi-timeout.c43 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()
H A Dsequencer.c63 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()
305 /* list is always at the very top of the sul */ in lws_seq_timeout_us()
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-server-raw/
H A Dss-server.c20 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/
H A Dprotocol_lws_minimal.c44 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/secure-streams/minimal-secure-streams-client-tx/
H A Dminimal-secure-streams-client-tx.c32 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/
H A Dminimal-ws-client.c23 lws_sorted_usec_list_t sul; /* schedule connection retry */ member
51 * Scheduled sul callback that starts the connection attempt
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/minimal-examples/http-server/minimal-http-server-h2-long-poll/
H A Dminimal-http-server.c32 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/
H A Dss-server.c53 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-pmd-bulk/
H A Dprotocol_lws_minimal_pmd_bulk.c68 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/ws-client/minimal-ws-client-tx/
H A Dminimal-ws-client.c47 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-server/minimal-ws-server-threadpool/
H A Dprotocol_lws_minimal_threadpool.c38 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/
H A Dminimal-raw-file.c28 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/include/libwebsockets/
H A Dlws-timeout-timer.h155 typedef void (*sul_cb_t)(struct lws_sorted_usec_list *sul);
165 * There are multiple sul owners to allow accounting for, a) events that must
179 * \param sul: pointer to the sul element
190 * on a sul owner list that, if the system has entered low power suspend mode,
201 lws_sorted_usec_list_t *sul);
206 * \param sul: pointer to the sul element
208 * If it's scheduled, remove the sul from its owning sorted list.
212 lws_sul_cancel(lws_sorted_usec_list_t *sul);
[all...]
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-smd/
H A Dminimal-secure-streams-smd.c67 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
H A Dmulti.c45 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-binance/
H A Dmain.c32 lws_sorted_usec_list_t sul; /* schedule connection retry */ member
117 * Scheduled sul callback that starts the connection attempt
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_clien in main()
[all...]
/third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-echo/
H A Dprotocol_lws_minimal_client_echo.c46 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/
H A Dminimal-http-client.c28 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/lib/system/async-dns/
H A Dasync-dns.c39 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()
316 if (//lws_dll2_is_detached(&q->sul.list) && in callback_async_dns()
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
475 sul_cb_write(struct lws_sorted_usec_list *sul) sul_cb_write() argument
[all...]
/third_party/libwebsockets/lib/plat/windows/
H A Dwindows-spawn.c32 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/lib/secure-streams/system/fetch-policy/
H A Dfetch-policy.c34 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-avs/
H A Davs.c46 * We simulate a ringbuffer that is used up by a sul at 64Kbit/sec
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/minimal-examples/secure-streams/minimal-secure-streams-alexa/
H A Dalexa.c51 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()
350 * run a sul that allows an additional 2KB tx credit in ss_avs_metadata_rx()
357 lws_sul_schedule(context, 0, &m->sul, in ss_avs_metadata_rx()
[all...]
/third_party/libwebsockets/lib/plat/unix/
H A Dunix-spawn.c38 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()
[all...]

Completed in 12 milliseconds

1234