| /Zephyr-latest/subsys/shell/backends/ |
| D | shell_websocket.c | 32 static void ws_end_client_connection(struct shell_websocket *ws) in ws_end_client_connection() argument
36 LOG_DBG("Closing connection to #%d", ws->fds[0].fd); in ws_end_client_connection()
38 (void)log_backend_ws_unregister(ws->fds[0].fd); in ws_end_client_connection()
40 (void)websocket_unregister(ws->fds[0].fd); in ws_end_client_connection()
42 ws->fds[0].fd = -1; in ws_end_client_connection()
43 ws->output_lock = false; in ws_end_client_connection()
45 k_work_cancel_delayable_sync(&ws->send_work, &ws->work_sync); in ws_end_client_connection()
47 ret = net_socket_service_register(&websocket_server, ws->fds, in ws_end_client_connection()
48 ARRAY_SIZE(ws->fds), NULL); in ws_end_client_connection()
54 static int ws_send(struct shell_websocket *ws, bool block) in ws_send() argument
[all …]
|
| D | shell_mqtt.c | 732 struct k_work_sync ws; in write_data() local
747 (void)k_work_cancel_delayable_sync(&sh_mqtt->publish_dwork, &ws); in write_data()
|
| /Zephyr-latest/lib/utils/ |
| D | winstream.c | 29 static uint32_t idx_mod(struct sys_winstream *ws, uint32_t idx) in idx_mod() argument
31 return idx >= ws->len ? idx - ws->len : idx; in idx_mod()
35 static uint32_t idx_sub(struct sys_winstream *ws, uint32_t a, uint32_t b) in idx_sub() argument
37 return idx_mod(ws, a + (ws->len - b)); in idx_sub()
40 void sys_winstream_write(struct sys_winstream *ws, in sys_winstream_write() argument
44 uint32_t start = ws->start, end = ws->end, seq = ws->seq; in sys_winstream_write()
50 if (len > ws->len - 1) { in sys_winstream_write()
52 len = ws->len - 1; in sys_winstream_write()
58 len = MIN(len, ws->len); in sys_winstream_write()
60 uint32_t avail = (ws->len - 1) - idx_sub(ws, end, start); in sys_winstream_write()
[all …]
|
| /Zephyr-latest/tests/unit/winstream/ |
| D | main.c | 20 struct sys_winstream *ws = sys_winstream_init(wsmem, BUFLEN); in ZTEST() local
23 sys_winstream_write(ws, "a", 1); in ZTEST()
29 uint32_t bytes = sys_winstream_read(ws, &seq, &c, 1); in ZTEST()
36 bytes = sys_winstream_read(ws, &seq, &c, 1); in ZTEST()
41 sys_winstream_write(ws, msg, strlen(msg)); in ZTEST()
42 zassert_true(ws->seq == 1 + strlen(msg), ""); in ZTEST()
43 zassert_true(ws->start == 1, ""); in ZTEST()
44 zassert_true(ws->end == 0, ""); in ZTEST()
52 bytes = sys_winstream_read(ws, &seq, readback, sizeof(readback)); in ZTEST()
53 zassert_true(seq == ws->seq, ""); in ZTEST()
[all …]
|
| /Zephyr-latest/include/zephyr/sys/ |
| D | winstream.h | 50 struct sys_winstream *ws = buf, tmp = { .len = buflen - sizeof(*ws) }; in sys_winstream_init() local
52 *ws = tmp; in sys_winstream_init()
53 return ws; in sys_winstream_init()
69 void sys_winstream_write(struct sys_winstream *ws,
92 uint32_t sys_winstream_read(struct sys_winstream *ws,
|
| /Zephyr-latest/subsys/bluetooth/crypto/ |
| D | bt_crypto.c | 70 uint8_t t[16], ws[32]; in bt_crypto_f5() local
77 sys_memcpy_swap(ws, w, 32); in bt_crypto_f5()
79 err = bt_crypto_aes_cmac(salt, ws, 32, t); in bt_crypto_f5()
121 uint8_t ws[16]; in bt_crypto_f6() local
146 sys_memcpy_swap(ws, w, 16); in bt_crypto_f6()
148 err = bt_crypto_aes_cmac(ws, m, sizeof(m), check); in bt_crypto_f6()
194 uint8_t ws[16]; in bt_crypto_h6() local
201 sys_memcpy_swap(ws, w, 16); in bt_crypto_h6()
204 err = bt_crypto_aes_cmac(ws, key_id_s, 4, res); in bt_crypto_h6()
218 uint8_t ws[16]; in bt_crypto_h7() local
[all …]
|
| /Zephyr-latest/samples/net/sockets/http_server/src/static_web_resources/ |
| D | main.js | 59 const ws = new WebSocket("/");
61 ws.onmessage = (event) => {
|
| /Zephyr-latest/samples/net/sockets/http_server/ |
| D | README.rst | 127 ws = websocket.WebSocket()
128 ws.connect("ws://192.0.2.1/ws_echo")
129 ws.send("Hello, Server")
130 print(ws.recv())
135 ws.send(line)
136 print(ws.recv())
137 ws.close()
|
| D | CMakeLists.txt | 43 target_sources_ifdef(CONFIG_NET_SAMPLE_WEBSOCKET_SERVICE app PRIVATE src/ws.c)
|
| /Zephyr-latest/scripts/footprint/ |
| D | upload_data.py | 70 ws = find(root, lambda node: node.name == 'WORKSPACE')
73 if zr and ws:
74 trees = [zr, ws]
|
| /Zephyr-latest/subsys/logging/backends/ |
| D | Kconfig | 13 rsource "Kconfig.ws"
|
| /Zephyr-latest/samples/net/sockets/echo_server/ |
| D | CMakeLists.txt | 56 target_sources(app PRIVATE src/ws_console/ws.c)
|
| D | Kconfig | 95 You can use the overlay-ws-console.conf to set websocket options.
|
| /Zephyr-latest/tests/unit/cbprintf/ |
| D | main.c | 413 static wchar_t ws[] = L"abc"; in ZTEST() local
430 TEST_PRF(&rc, "%ls", ws); in ZTEST()
|
| /Zephyr-latest/doc/releases/ |
| D | release-notes-1.12.rst | 471 …github:`6679` - [Coverity CID: 183053] Memory - corruptions in /samples/net/ws_echo_server/src/ws.c
|
