| /Zephyr-latest/tests/net/lib/http_server/crime/src/ |
| D | main.c | 65 int ret, recv_len; in test_crime() local
105 recv_len = zsock_recv(client_fd, buf, sizeof(buf), 0); in test_crime()
106 zassert_not_equal(recv_len, -1, "recv() failed (%d)", errno); in test_crime()
110 while (recv_len < len) { in test_crime()
111 ret = zsock_recv(client_fd, buf + recv_len, sizeof(buf) - recv_len, 0); in test_crime()
114 recv_len += ret; in test_crime()
|
| /Zephyr-latest/samples/subsys/usb/cdc_acm/src/ |
| D | main.c | 117 int recv_len, rb_len; in interrupt_handler() local
129 recv_len = uart_fifo_read(dev, buffer, len); in interrupt_handler()
130 if (recv_len < 0) { in interrupt_handler()
132 recv_len = 0; in interrupt_handler()
135 rb_len = ring_buf_put(&ringbuf, buffer, recv_len); in interrupt_handler()
136 if (rb_len < recv_len) { in interrupt_handler()
137 LOG_ERR("Drop %u bytes", recv_len - rb_len); in interrupt_handler()
|
| /Zephyr-latest/tests/net/lib/http_server/tls/src/ |
| D | main.c | 129 int ret, recv_len; in test_tls() local
196 recv_len = zsock_recv(client_fd, buf, sizeof(buf), 0); in test_tls()
197 zassert_not_equal(recv_len, -1, "recv() failed (%d)", errno); in test_tls()
201 while (recv_len < len) { in test_tls()
202 ret = zsock_recv(client_fd, buf + recv_len, sizeof(buf) - recv_len, 0); in test_tls()
205 recv_len += ret; in test_tls()
|
| /Zephyr-latest/subsys/net/lib/sockets/ |
| D | sockets_packet.c | 301 size_t recv_len = 0; in zpacket_recvfrom_ctx() local
334 recv_len = net_pkt_get_len(pkt); in zpacket_recvfrom_ctx()
335 if (recv_len > max_len) { in zpacket_recvfrom_ctx()
336 recv_len = max_len; in zpacket_recvfrom_ctx()
339 if (net_pkt_read(pkt, buf, recv_len)) { in zpacket_recvfrom_ctx()
360 return recv_len; in zpacket_recvfrom_ctx()
|
| D | sockets_can.c | 281 size_t recv_len = 0; in zcan_recvfrom_ctx() local
326 recv_len = net_pkt_get_len(pkt); in zcan_recvfrom_ctx()
327 if (recv_len > max_len) { in zcan_recvfrom_ctx()
328 recv_len = max_len; in zcan_recvfrom_ctx()
338 NET_ASSERT(recv_len == sizeof(struct socketcan_frame)); in zcan_recvfrom_ctx()
344 return recv_len; in zcan_recvfrom_ctx()
|
| D | sockets_inet.c | 1064 size_t recv_len = 0; in zsock_recv_dgram() local
1151 recv_len = net_pkt_remaining_data(pkt); in zsock_recv_dgram()
1152 tmp_read_len = read_len = MIN(recv_len, max_len); in zsock_recv_dgram()
1179 if (recv_len != read_len) { in zsock_recv_dgram()
1184 recv_len = net_pkt_remaining_data(pkt); in zsock_recv_dgram()
1185 read_len = MIN(recv_len, max_len); in zsock_recv_dgram()
1234 return (flags & ZSOCK_MSG_TRUNC) ? recv_len : read_len; in zsock_recv_dgram()
1249 size_t recv_len = 0; in zsock_recv_stream_immediate() local
1271 recv_len += len; in zsock_recv_stream_immediate()
1314 return recv_len; in zsock_recv_stream_immediate()
[all …]
|
| D | sockets_tls.c | 2572 size_t recv_len = 0; in recv_tls() local
2597 size_t read_len = max_len - recv_len; in recv_tls()
2599 ret = mbedtls_ssl_read(&ctx->ssl, (uint8_t *)buf + recv_len, in recv_tls()
2663 recv_len += ret; in recv_tls()
2664 } while ((recv_len == 0) || (waitall && (recv_len < max_len))); in recv_tls()
2666 return recv_len; in recv_tls()
|
| /Zephyr-latest/subsys/bluetooth/services/ots/ |
| D | ots_oacp.c | 313 ots->cur_obj->state.write_op.recv_len = 0; in oacp_write_proc_validate()
563 offset = write_op->oacp_params.offset + write_op->recv_len; in oacp_write_proc_cb()
565 if (write_op->recv_len + len > write_op->oacp_params.len) { in oacp_write_proc_cb()
567 len = write_op->oacp_params.len - write_op->recv_len; in oacp_write_proc_cb()
569 rem = write_op->oacp_params.len - (write_op->recv_len + len); in oacp_write_proc_cb()
595 write_op->recv_len += len; in oacp_write_proc_cb()
596 if (write_op->recv_len == write_op->oacp_params.len) { in oacp_write_proc_cb()
|
| D | ots_internal.h | 109 uint32_t recv_len; member
|
| /Zephyr-latest/tests/bluetooth/tester/src/audio/btp/ |
| D | btp_tbs.h | 18 uint8_t recv_len; member
|
| /Zephyr-latest/tests/net/ppp/driver/src/ |
| D | main.c | 226 uint8_t *recv, size_t recv_len, in send_iface() argument
233 NET_DBG("Feeding %zd bytes data", recv_len); in send_iface()
237 ppp_driver_feed_data(recv, recv_len); in send_iface()
|
| /Zephyr-latest/drivers/mfd/ |
| D | mfd_max22017.c | 37 size_t recv_len = 3; in max22017_reg_read() local
43 recv_len += 1; in max22017_reg_read()
55 .len = recv_len, in max22017_reg_read()
|
| /Zephyr-latest/tests/subsys/canbus/isotp/conformance/src/ |
| D | main.c | 233 int ret, recv_len; in receive_test_data() local
238 recv_len = isotp_recv(&recv_ctx, data_buf, sizeof(data_buf), in receive_test_data()
240 zassert_true(recv_len >= 0, "recv error: %d", recv_len); in receive_test_data()
242 zassert_true(remaining_len >= recv_len, in receive_test_data()
244 ret = check_data(data_buf, data_ptr, recv_len); in receive_test_data()
246 data_ptr += recv_len; in receive_test_data()
247 remaining_len -= recv_len; in receive_test_data()
|
| /Zephyr-latest/tests/net/socket/websocket/src/ |
| D | main.c | 51 uint8_t *recv_buffer, size_t recv_len) in test_recv_buf() argument
63 ret = websocket_recv_msg(fd, recv_buffer, recv_len, in test_recv_buf()
|
| /Zephyr-latest/tests/bluetooth/tester/src/audio/ |
| D | btp_ccp.c | 918 if ((cp->recv_len >= sizeof(recv_uri) || cp->caller_len >= sizeof(caller_uri)) || in tbs_remote_incoming()
923 memcpy(recv_uri, cp->data, cp->recv_len); in tbs_remote_incoming()
924 memcpy(caller_uri, cp->data + cp->recv_len, cp->caller_len); in tbs_remote_incoming()
925 memcpy(friendly_name, cp->data + cp->recv_len + cp->caller_len, cp->fn_len); in tbs_remote_incoming()
927 recv_uri[cp->recv_len] = '\0'; in tbs_remote_incoming()
|
| /Zephyr-latest/subsys/bluetooth/host/classic/ |
| D | sdp.c | 98 uint32_t recv_len; member
1685 session->recv_len = 0; in sdp_client_params_iterator()
2081 session->recv_len += frame_len; in sdp_client_receive_ssa_sa()
2108 if (session->total_len && (session->recv_len != session->total_len)) { in sdp_client_receive_ssa_sa()
2109 LOG_WRN("The received len %d is mismatched with total len %d", session->recv_len, in sdp_client_receive_ssa_sa()
|
