| /third_party/libwebsockets/plugins/ssh-base/ |
| D | sshd.c | 93 write_task(struct per_session_data__sshd *pss, struct lws_ssh_channel *ch, in write_task() argument
96 pss->write_task[pss->wt_head] = (uint8_t)task; in write_task()
97 pss->write_channel[pss->wt_head] = ch; in write_task()
98 pss->wt_head = (pss->wt_head + 1) & 7; in write_task()
99 lws_callback_on_writable(pss->wsi); in write_task()
103 write_task_insert(struct per_session_data__sshd *pss, struct lws_ssh_channel *ch, in write_task_insert() argument
106 pss->wt_tail = (pss->wt_tail - 1) & 7; in write_task_insert()
107 pss->write_task[pss->wt_tail] = (uint8_t)task; in write_task_insert()
108 pss->write_channel[pss->wt_tail] = ch; in write_task_insert()
109 lws_callback_on_writable(pss->wsi); in write_task_insert()
[all …]
|
| D | telnet.c | 71 telnet_ld(struct per_session_data__telnet *pss, uint8_t c) in telnet_ld() argument
73 switch (pss->state) { in telnet_ld()
76 pss->state = LTST_GOT_IAC; in telnet_ld()
82 pss->state = LTST_WAIT_IAC; in telnet_ld()
91 pss->cmd = c; in telnet_ld()
92 pss->state = LTST_WAIT_OPT; in telnet_ld()
100 lwsl_notice(" tld: cmd %d: opt %d\n", pss->cmd, c); in telnet_ld()
101 pss->state = LTST_WAIT_IAC; in telnet_ld()
119 struct per_session_data__telnet *pss = in lws_callback_raw_telnet() local
153 pss->next = vhd->live_pss_list; in lws_callback_raw_telnet()
[all …]
|
| D | kex-25519.c | 284 get_gen_server_key_25519(struct per_session_data__sshd *pss, uint8_t *b, in get_gen_server_key_25519() argument
289 mylen = pss->vhd->ops->get_server_key(pss->wsi, b, len); in get_gen_server_key_25519()
295 s = lws_gen_server_key_ed25519(pss->vhd->context, b, len); in get_gen_server_key_25519()
300 if (!pss->vhd->ops->set_server_key(pss->wsi, b, s)) in get_gen_server_key_25519()
309 kex_ecdh(struct per_session_data__sshd *pss, uint8_t *reply, uint32_t *plen) in kex_ecdh() argument
312 struct lws_kex *kex = pss->kex; in kex_ecdh()
321 r = (int)get_gen_server_key_25519(pss, servkey, (int)sizeof(servkey)); in kex_ecdh()
329 pss->K_S /* public key */, pri_key); in kex_ecdh()
352 lws_get_random(pss->vhd->context, kex->eph_pri_key, LWS_SIZE_EC25519); in kex_ecdh()
383 crypto_scalarmult_curve25519(pss->K, kex->eph_pri_key, kex->Q_C); in kex_ecdh()
[all …]
|
| /third_party/libwebsockets/plugins/deaddrop/ |
| D | protocol_lws_deaddrop.c | 122 start_sending_dir(struct pss_deaddrop *pss) in start_sending_dir() argument
124 if (pss->vhd->lwsac_head) in start_sending_dir()
125 lwsac_reference(pss->vhd->lwsac_head); in start_sending_dir()
126 pss->lwsac_head = pss->vhd->lwsac_head; in start_sending_dir()
127 pss->dire = pss->vhd->dire_head; in start_sending_dir()
128 pss->filelist_version = pss->vhd->filelist_version; in start_sending_dir()
129 pss->first = 1; in start_sending_dir()
267 struct pss_deaddrop *pss = (struct pss_deaddrop *)data; in file_upload_cb() local
278 if (pss->user[0]) { in file_upload_cb()
279 lws_filename_purify_inplace(pss->user); in file_upload_cb()
[all …]
|
| /third_party/libwebsockets/plugins/ |
| D | protocol_fulltext_demo.c | 66 struct pss_fts_demo *pss = (struct pss_fts_demo *)user; in callback_fts() local
90 pss->first = 1; in callback_fts()
91 pss->ac_done = 0; in callback_fts()
125 pss->result = params.results_head; in callback_fts()
126 pss->ac = result->autocomplete_head; in callback_fts()
127 pss->fp = result->filepath_head; in callback_fts()
154 if (pss && pss->result) in callback_fts()
155 lwsac_free(&pss->result); in callback_fts()
160 if (!pss) in callback_fts()
164 if (pss->first) in callback_fts()
[all …]
|
| D | protocol_lws_status.c | 70 lws_start_foreach_ll(struct per_session_data__lws_status *, pss, in trigger_resend()
72 if (pss->walk == WALK_NONE) { in trigger_resend()
73 pss->subsequent = 0; in trigger_resend()
74 pss->walk_next = vhd->live_pss_list; in trigger_resend()
75 pss->walk = WALK_INITIAL; in trigger_resend()
77 pss->changed_partway = 1; in trigger_resend()
78 } lws_end_foreach_ll(pss, next); in trigger_resend()
89 struct per_session_data__lws_status *pss = in callback_lws_status() local
123 pss->next = vhd->live_pss_list; in callback_lws_status()
124 vhd->live_pss_list = pss; in callback_lws_status()
[all …]
|
| D | protocol_post_demo.c | 72 struct per_session_data__post_demo *pss = in file_upload_cb() local
82 lws_strncpy(pss->filename, filename, sizeof(pss->filename)); in file_upload_cb()
87 pss->fd = (lws_filefd_type)(lws_intptr_t)lws_open("/tmp/post-file", in file_upload_cb()
94 pss->file_length += len; in file_upload_cb()
97 if (pss->file_length > 100000) in file_upload_cb()
101 n = (int)write((int)(lws_intptr_t)pss->fd, buf, (unsigned int)len); in file_upload_cb()
110 close((int)(lws_intptr_t)pss->fd); in file_upload_cb()
111 pss->fd = LWS_INVALID_FILE; in file_upload_cb()
126 format_result(struct per_session_data__post_demo *pss) in format_result() argument
131 p = (unsigned char *)pss->result + LWS_PRE; in format_result()
[all …]
|
| D | protocol_lws_openmetrics_export.c | 108 struct pss { struct
249 lws_metrics_om_ac_stash(struct pss *pss, const char *buf, size_t len) in lws_metrics_om_ac_stash() argument
253 q = lwsac_use(&pss->ac, LWS_PRE + len + 2, LWS_PRE + len + 2); in lws_metrics_om_ac_stash()
255 lwsac_free(&pss->ac); in lws_metrics_om_ac_stash()
262 pss->tot += len; in lws_metrics_om_ac_stash()
273 lws_metrics_om_format(struct pss *pss, lws_metric_pub_t *pub, const char *nm) in lws_metrics_om_format() argument
294 lws_metrics_om_ac_stash(pss, buf, in lws_metrics_om_format()
324 return lws_metrics_om_ac_stash(pss, buf, lws_ptr_diff_size_t(p, buf)); in lws_metrics_om_format()
330 struct pss *pss = (struct pss *)user; in append_om_metric() local
347 return lws_metrics_om_format(pss, pub, nm); in append_om_metric()
[all …]
|
| D | protocol_lws_mirror.c | 85 pss, mi->same_mi_pss_list) { in __mirror_rxflow_instance()
86 lws_rx_flow_control(pss->wsi, enable); in __mirror_rxflow_instance()
87 } lws_end_foreach_ll(pss, same_mi_pss_list); in __mirror_rxflow_instance()
123 pss, mi->same_mi_pss_list) { in __mirror_update_worst_tail()
125 &pss->tail); in __mirror_update_worst_tail()
128 worst_tail = pss->tail; in __mirror_update_worst_tail()
129 worst_pss = pss; in __mirror_update_worst_tail()
131 } lws_end_foreach_ll(pss, same_mi_pss_list); in __mirror_update_worst_tail()
158 pss, mi->same_mi_pss_list) { in __mirror_update_worst_tail()
159 if (pss->tail == worst_tail) in __mirror_update_worst_tail()
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-form-post-file/ |
| D | minimal-http-server-form-post-file.c | 30 struct pss { struct
53 struct pss *pss = (struct pss *)data; in file_upload_cb() argument
58 lws_strncpy(pss->filename, filename, sizeof(pss->filename) - 1); in file_upload_cb()
60 lws_filename_purify_inplace(pss->filename); in file_upload_cb()
62 pss->fd = lws_open(pss->filename, O_CREAT | O_TRUNC | O_RDWR, 0600); in file_upload_cb()
63 if (pss->fd == -1) { in file_upload_cb()
65 pss->filename); in file_upload_cb()
74 pss->file_length += (unsigned int)len; in file_upload_cb()
76 n = (int)write(pss->fd, buf, (unsigned int)len); in file_upload_cb()
88 pss->file_length, pss->filename); in file_upload_cb()
[all …]
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-echo/ |
| D | protocol_lws_minimal_server_echo.c | 64 struct per_session_data__minimal_server_echo *pss = in callback_minimal_server_echo() local
98 pss->ring = lws_ring_create(sizeof(struct msg), RING_DEPTH, in callback_minimal_server_echo()
100 if (!pss->ring) in callback_minimal_server_echo()
102 pss->tail = 0; in callback_minimal_server_echo()
109 if (pss->write_consume_pending) { in callback_minimal_server_echo()
111 lws_ring_consume_single_tail(pss->ring, &pss->tail, 1); in callback_minimal_server_echo()
112 pss->write_consume_pending = 0; in callback_minimal_server_echo()
115 pmsg = lws_ring_get_element(pss->ring, &pss->tail); in callback_minimal_server_echo()
141 pss->write_consume_pending = 1; in callback_minimal_server_echo()
144 if (pss->flow_controlled && in callback_minimal_server_echo()
[all …]
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-pmd-bulk/ |
| D | protocol_lws_minimal_pmd_bulk.c | 85 struct per_session_data__minimal_pmd_bulk *pss = in callback_minimal_pmd_bulk() local
111 pss->rng_tx = 4; in callback_minimal_pmd_bulk()
112 pss->rng_rx = 4; in callback_minimal_pmd_bulk()
117 if (pss->position_tx == MESSAGE_SIZE) in callback_minimal_pmd_bulk()
130 if (n > MESSAGE_SIZE - pss->position_tx) in callback_minimal_pmd_bulk()
131 n = MESSAGE_SIZE - pss->position_tx; in callback_minimal_pmd_bulk()
133 flags = lws_write_ws_flags(LWS_WRITE_BINARY, !pss->position_tx, in callback_minimal_pmd_bulk()
134 pss->position_tx + n == MESSAGE_SIZE); in callback_minimal_pmd_bulk()
145 m = pss->position_tx % REPEAT_STRING_LEN; in callback_minimal_pmd_bulk()
150 pss->position_tx += (int)s; in callback_minimal_pmd_bulk()
[all …]
|
| /third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client-multi/ |
| D | minimal-mqtt-client-multi.c | 104 struct pss { struct
200 struct pss *pss = (struct pss *)user; in callback_mqtt() local
231 pss->state++; in callback_mqtt()
240 if (++pss->state == STATE_TEST_FINISH) { in callback_mqtt()
256 switch (pss->state) { in callback_mqtt()
265 pss->state++; in callback_mqtt()
273 pss->pub_param.topic = pss->state == STATE_PUBLISH_QOS0 ? in callback_mqtt()
275 pss->pub_param.topic_len = (uint16_t)strlen(pss->pub_param.topic); in callback_mqtt()
276 pss->pub_param.qos = in callback_mqtt()
277 pss->state == STATE_PUBLISH_QOS0 ? QOS0 : QOS1; in callback_mqtt()
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-dynamic/ |
| D | minimal-http-server-dynamic.c | 28 struct pss { struct
43 struct pss *pss = (struct pss *)user; in callback_dynamic_http() argument
70 lws_snprintf(pss->path, sizeof(pss->path), "%s", in callback_dynamic_http()
75 (const char *)buf, pss->path); in callback_dynamic_http()
116 pss->times = 0; in callback_dynamic_http()
117 pss->budget = atoi((char *)in + 1); in callback_dynamic_http()
118 pss->content_lines = 0; in callback_dynamic_http()
119 if (!pss->budget) in callback_dynamic_http()
120 pss->budget = 10; in callback_dynamic_http()
129 if (!pss || pss->times > pss->budget) in callback_dynamic_http()
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-form-post-lwsac/ |
| D | minimal-http-server-form-post.c | 23 struct pss { struct
44 struct pss *pss = (struct pss *)user; in callback_http() local
71 if (!pss->spa) { in callback_http()
77 i.ac = &pss->ac; in callback_http()
80 pss->spa = lws_spa_create_via_info(wsi, &i); /* no file upload */ in callback_http()
81 if (!pss->spa) in callback_http()
87 if (lws_spa_process(pss->spa, in, (int)len)) in callback_http()
96 lws_spa_finalize(pss->spa); in callback_http()
101 if (!lws_spa_get_string(pss->spa, n)) in callback_http()
106 lws_spa_get_length(pss->spa, n), in callback_http()
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-form-post/ |
| D | minimal-http-server-form-post.c | 23 struct pss { struct
43 struct pss *pss = (struct pss *)user; in callback_http() local
70 if (!pss->spa) { in callback_http()
71 pss->spa = lws_spa_create(wsi, param_names, in callback_http()
74 if (!pss->spa) in callback_http()
80 if (lws_spa_process(pss->spa, in, (int)len)) in callback_http()
85 if (pss->spa && lws_spa_destroy(pss->spa)) in callback_http()
94 lws_spa_finalize(pss->spa); in callback_http()
98 if (pss->spa) in callback_http()
100 if (!lws_spa_get_string(pss->spa, n)) in callback_http()
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-h2-long-poll/ |
| D | minimal-http-server.c | 30 struct pss { struct
44 struct pss *pss = (struct pss *)lws_container_of(sul, struct pss, sul); in sul_cb() local
46 pss->pending = 1; in sul_cb()
47 lws_callback_on_writable(pss->wsi); in sul_cb()
49 lws_sul_schedule(lws_get_context(pss->wsi), 0, &pss->sul, sul_cb, in sul_cb()
57 struct pss * pss = (struct pss *)user; in callback_http() local
66 pss->wsi = wsi; in callback_http()
76 sul_cb(&pss->sul); in callback_http()
80 if (!pss) in callback_http()
82 lws_sul_cancel(&pss->sul); in callback_http()
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-custom-headers/ |
| D | minimal-http-server-custom-headers.c | 25 struct pss { struct
41 struct pss *pss = (struct pss *)user; in callback_http() argument
42 char value[32], *pr = &pss->result[LWS_PRE]; in callback_http()
43 size_t e = sizeof(pss->result) - LWS_PRE; in callback_http()
56 pss->len = 0; in callback_http()
59 pss->len = lws_snprintf(pr, e, in callback_http()
63 pss->len = lws_snprintf(pr, e, in callback_http()
67 pss->len += lws_snprintf(pr + pss->len, e - (unsigned int)pss->len, in callback_http()
71 pss->len += lws_snprintf(pr + pss->len , e - (unsigned int)pss->len, in callback_http()
78 "text/html", (lws_filepos_t)pss->len, &p, end)) in callback_http()
[all …]
|
| /third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client/ |
| D | minimal-mqtt-client.c | 94 struct pss { struct
165 struct pss *pss = (struct pss *)user; in callback_mqtt() local
199 switch (pss->state) { in callback_mqtt()
208 pss->state++; in callback_mqtt()
218 pub_param.qos = pss->state == STATE_PUBLISH_QOS0 ? QOS0 : QOS1; in callback_mqtt()
225 if (chunk > TEST_STRING_LEN - pss->pos) in callback_mqtt()
226 chunk = TEST_STRING_LEN - pss->pos; in callback_mqtt()
229 test_string + pss->pos, (uint32_t)chunk, in callback_mqtt()
230 (pss->pos + chunk == TEST_STRING_LEN))) in callback_mqtt()
233 pss->pos += chunk; in callback_mqtt()
[all …]
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-pmd-bulk/ |
| D | protocol_lws_minimal_pmd_bulk.c | 112 struct per_session_data__minimal_pmd_bulk *pss = in callback_minimal_pmd_bulk() local
148 pss->rng_tx = 4; in callback_minimal_pmd_bulk()
149 pss->rng_rx = 4; in callback_minimal_pmd_bulk()
159 if (pss->position_tx == MESSAGE_SIZE) in callback_minimal_pmd_bulk()
166 if (n > MESSAGE_SIZE - pss->position_tx) in callback_minimal_pmd_bulk()
167 n = MESSAGE_SIZE - pss->position_tx; in callback_minimal_pmd_bulk()
169 flags = lws_write_ws_flags(LWS_WRITE_BINARY, !pss->position_tx, in callback_minimal_pmd_bulk()
170 pss->position_tx + n == MESSAGE_SIZE); in callback_minimal_pmd_bulk()
181 m = pss->position_tx % REPEAT_STRING_LEN; in callback_minimal_pmd_bulk()
186 pss->position_tx += (int)s; in callback_minimal_pmd_bulk()
[all …]
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-pmd-corner/ |
| D | protocol_lws_minimal.c | 218 struct per_session_data__minimal *pss = in callback_minimal() local
229 pss->last = atoi((char *)buf + 1); in callback_minimal()
231 if (pss->last > (int)LWS_ARRAY_SIZE(corner_lengths)) in callback_minimal()
232 pss->last = 0; in callback_minimal()
237 if (!pss->last) in callback_minimal()
240 lwsl_err("%s: writable %d, %d\n", __func__, pss->last, in callback_minimal()
241 corner_lengths[pss->last - 1]); in callback_minimal()
244 (unsigned int)corner_lengths[pss->last - 1]); in callback_minimal()
247 m = lws_write(wsi, buf + LWS_PRE, (unsigned int)corner_lengths[pss->last - 1], in callback_minimal()
249 if (m < corner_lengths[pss->last - 1]) { in callback_minimal()
[all …]
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-echo/ |
| D | protocol_lws_minimal_client_echo.c | 103 struct per_session_data__minimal_client_echo *pss = in callback_minimal_client_echo() local
153 pss->ring = lws_ring_create(sizeof(struct msg), RING_DEPTH, in callback_minimal_client_echo()
155 if (!pss->ring) in callback_minimal_client_echo()
157 pss->tail = 0; in callback_minimal_client_echo()
164 if (pss->write_consume_pending) { in callback_minimal_client_echo()
166 lws_ring_consume_single_tail(pss->ring, &pss->tail, 1); in callback_minimal_client_echo()
167 pss->write_consume_pending = 0; in callback_minimal_client_echo()
169 pmsg = lws_ring_get_element(pss->ring, &pss->tail); in callback_minimal_client_echo()
191 pss->completed = 1; in callback_minimal_client_echo()
199 pss->write_consume_pending = 1; in callback_minimal_client_echo()
[all …]
|
| /third_party/openssl/crypto/rsa/ |
| D | rsa_ameth.c | 42 if (rsa->pss == NULL) { in rsa_param_encode()
47 if (ASN1_item_pack(rsa->pss, ASN1_ITEM_rptr(RSA_PSS_PARAMS), pstr) == NULL) in rsa_param_encode()
69 rsa->pss = rsa_pss_decode(alg); in rsa_param_decode()
70 if (rsa->pss == NULL) in rsa_param_decode()
231 static int rsa_pss_param_print(BIO *bp, int pss_key, RSA_PSS_PARAMS *pss, in rsa_pss_param_print() argument
240 if (pss == NULL) { in rsa_pss_param_print()
248 } else if (pss == NULL) { in rsa_pss_param_print()
262 if (pss->hashAlgorithm) { in rsa_pss_param_print()
263 if (i2a_ASN1_OBJECT(bp, pss->hashAlgorithm->algorithm) <= 0) in rsa_pss_param_print()
277 if (pss->maskGenAlgorithm) { in rsa_pss_param_print()
[all …]
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | ev_epollex_linux.cc | 1314 static grpc_pollset_set* pss_lock_adam(grpc_pollset_set* pss) { argument
1315 gpr_mu_lock(&pss->mu);
1316 while (pss->parent != nullptr) {
1317 gpr_mu_unlock(&pss->mu);
1318 pss = pss->parent;
1319 gpr_mu_lock(&pss->mu);
1321 return pss;
1325 grpc_pollset_set* pss = local
1326 static_cast<grpc_pollset_set*>(gpr_zalloc(sizeof(*pss)));
1327 gpr_mu_init(&pss->mu);
[all …]
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-broker/ |
| D | protocol_lws_minimal.c | 80 struct per_session_data__minimal *pss = in callback_minimal() local
111 pss->tail = lws_ring_get_oldest_tail(vhd->ring); in callback_minimal()
112 pss->wsi = wsi; in callback_minimal()
114 pss->publishing = !strcmp(buf, "/publisher"); in callback_minimal()
115 if (!pss->publishing) in callback_minimal()
117 lws_ll_fwd_insert(pss, pss_list, vhd->pss_list); in callback_minimal()
123 pss, vhd->pss_list); in callback_minimal()
128 if (pss->publishing) in callback_minimal()
131 pmsg = lws_ring_get_element(vhd->ring, &pss->tail); in callback_minimal()
146 &pss->tail, /* tail of guy doing the consuming */ in callback_minimal()
[all …]
|