Home
last modified time | relevance | path

Searched refs:rx_buf (Results 1 – 25 of 28) sorted by relevance

12

/subsys/mgmt/mcumgr/transport/src/
A Dsmp_uart.c41 static void smp_uart_process_frag(struct uart_mcumgr_rx_buf *rx_buf) in smp_uart_process_frag() argument
49 rx_buf->data, rx_buf->length); in smp_uart_process_frag()
52 uart_mcumgr_free_rx_buf(rx_buf); in smp_uart_process_frag()
64 struct uart_mcumgr_rx_buf *rx_buf; in smp_uart_process_rx_queue() local
66 while ((rx_buf = k_fifo_get(&smp_uart_rx_fifo, K_NO_WAIT)) != NULL) { in smp_uart_process_rx_queue()
67 smp_uart_process_frag(rx_buf); in smp_uart_process_rx_queue()
75 static void smp_uart_rx_frag(struct uart_mcumgr_rx_buf *rx_buf) in smp_uart_rx_frag() argument
77 k_fifo_put(&smp_uart_rx_fifo, rx_buf); in smp_uart_rx_frag()
A Dsmp_dummy.c98 rx_buf->data, rx_buf->length); in smp_dummy_process_frag()
134 smp_dummy_process_frag(rx_buf); in smp_dummy_process_rx_queue()
219 rx_buf = block; in dummy_mcumgr_alloc_rx_buf()
220 rx_buf->length = 0; in dummy_mcumgr_alloc_rx_buf()
221 return rx_buf; in dummy_mcumgr_alloc_rx_buf()
228 block = rx_buf; in dummy_mcumgr_free_rx_buf()
249 rx_buf = dummy_mcumgr_cur_buf; in dummy_mcumgr_rx_byte()
251 if (rx_buf->length >= sizeof(rx_buf->data)) { in dummy_mcumgr_rx_byte()
257 rx_buf->data[rx_buf->length++] = byte; in dummy_mcumgr_rx_byte()
267 return rx_buf; in dummy_mcumgr_rx_byte()
[all …]
/subsys/lorawan/services/
A Dmulticast.c111 uint8_t len, const uint8_t *rx_buf) in multicast_package_callback() argument
120 uint8_t command_id = rx_buf[rx_pos++]; in multicast_package_callback()
138 uint8_t id = rx_buf[rx_pos++] & 0x03; in multicast_package_callback()
146 channel.Address = sys_get_le32(rx_buf + rx_pos); in multicast_package_callback()
150 channel.McKeys.McKeyE = (uint8_t *)rx_buf + rx_pos; in multicast_package_callback()
153 channel.FCountMin = sys_get_le32(rx_buf + rx_pos); in multicast_package_callback()
156 channel.FCountMax = sys_get_le32(rx_buf + rx_pos); in multicast_package_callback()
177 uint8_t id = rx_buf[rx_pos++] & 0x03; in multicast_package_callback()
199 uint8_t id = rx_buf[rx_pos++] & 0x03; in multicast_package_callback()
202 session_time = sys_get_le32(rx_buf + rx_pos); in multicast_package_callback()
[all …]
A Dfrag_transport.c108 uint8_t len, const uint8_t *rx_buf) in frag_transport_package_callback() argument
119 uint8_t command_id = rx_buf[rx_pos++]; in frag_transport_package_callback()
133 uint8_t frag_status = rx_buf[rx_pos++] & 0x07; in frag_transport_package_callback()
166 uint8_t frag_session = rx_buf[rx_pos++] & 0x3F; in frag_transport_package_callback()
174 ctx.nb_frag = sys_get_le16(rx_buf + rx_pos); in frag_transport_package_callback()
177 ctx.frag_size = rx_buf[rx_pos++]; in frag_transport_package_callback()
178 ctx.control = rx_buf[rx_pos++]; in frag_transport_package_callback()
179 ctx.padding = rx_buf[rx_pos++]; in frag_transport_package_callback()
181 ctx.descriptor = sys_get_le32(rx_buf + rx_pos); in frag_transport_package_callback()
248 uint8_t index = rx_buf[rx_pos++] & 0x03; in frag_transport_package_callback()
[all …]
A Dclock_sync.c94 uint8_t len, const uint8_t *rx_buf) in clock_sync_package_callback() argument
103 uint8_t command_id = rx_buf[rx_pos++]; in clock_sync_package_callback()
123 time_correction = rx_buf[rx_pos++]; in clock_sync_package_callback()
124 time_correction += rx_buf[rx_pos++] << 8; in clock_sync_package_callback()
125 time_correction += rx_buf[rx_pos++] << 16; in clock_sync_package_callback()
126 time_correction += rx_buf[rx_pos++] << 24; in clock_sync_package_callback()
128 uint8_t token = rx_buf[rx_pos++] & 0x0F; in clock_sync_package_callback()
143 uint8_t period = rx_buf[rx_pos++] & 0x0F; in clock_sync_package_callback()
160 uint8_t nb_transmissions = rx_buf[rx_pos++] & 0x07; in clock_sync_package_callback()
/subsys/mgmt/osdp/src/
A Dosdp.c29 struct ring_buf rx_buf; member
55 ring_buf_put(&p->rx_buf, buf, 1); /* put last byte */ in osdp_handle_in_byte()
57 ring_buf_put(&p->rx_buf, buf, len); /* put rest */ in osdp_handle_in_byte()
63 ring_buf_put(&p->rx_buf, buf, len); in osdp_handle_in_byte()
102 return (int)ring_buf_get(&p->rx_buf, buf, len); in osdp_uart_receive()
121 ring_buf_reset(&p->rx_buf); in osdp_uart_flush()
196 ring_buf_init(&p->rx_buf, sizeof(p->rx_fbuf), p->rx_fbuf); in osdp_init()
A Dosdp_pd.c812 len = osdp_phy_packet_init(pd, pd->rx_buf, sizeof(pd->rx_buf)); in pd_send_reply()
818 ret = pd_build_reply(pd, pd->rx_buf, sizeof(pd->rx_buf)); in pd_send_reply()
825 len = osdp_phy_packet_finalize(pd, pd->rx_buf, len, sizeof(pd->rx_buf)); in pd_send_reply()
835 ret = pd->channel.send(pd->channel.data, pd->rx_buf, len); in pd_send_reply()
843 osdp_dump("PD sent", pd->rx_buf, len); in pd_send_reply()
889 buf = pd->rx_buf + pd->rx_buf_len; in pd_receive_and_process_command()
890 remaining = sizeof(pd->rx_buf) - pd->rx_buf_len; in pd_receive_and_process_command()
913 pd->rx_buf[6] != CMD_POLL && pd->rx_buf[8] != CMD_POLL) { in pd_receive_and_process_command()
914 osdp_dump("PD received", pd->rx_buf, pd->rx_buf_len); in pd_receive_and_process_command()
927 memmove(pd->rx_buf, pd->rx_buf + len, remaining); in pd_receive_and_process_command()
[all …]
A Dosdp_cp.c568 len = osdp_phy_packet_init(pd, pd->rx_buf, sizeof(pd->rx_buf)); in cp_build_packet()
574 ret = cp_build_command(pd, pd->rx_buf, sizeof(pd->rx_buf)); in cp_build_packet()
581 len = osdp_phy_packet_finalize(pd, pd->rx_buf, len, sizeof(pd->rx_buf)); in cp_build_packet()
600 ret = pd->channel.send(pd->channel.data, pd->rx_buf, pd->rx_buf_len); in cp_send_command()
610 osdp_dump(NULL, pd->rx_buf, pd->rx_buf_len); in cp_send_command()
622 buf = pd->rx_buf + pd->rx_buf_len; in cp_process_reply()
623 remaining = sizeof(pd->rx_buf) - pd->rx_buf_len; in cp_process_reply()
634 osdp_dump(NULL, pd->rx_buf, pd->rx_buf_len); in cp_process_reply()
638 err = osdp_phy_check_packet(pd, pd->rx_buf, pd->rx_buf_len, &len); in cp_process_reply()
655 len = osdp_phy_decode_packet(pd, pd->rx_buf, len, &buf); in cp_process_reply()
[all …]
/subsys/pmci/mctp/
A Dmctp_uart.c236 uart_rx_buf_rsp(dev, binding->rx_buf[i], in mctp_uart_callback()
237 sizeof(binding->rx_buf[i])); in mctp_uart_callback()
244 if (binding->rx_buf[i] == evt->data.rx_buf.buf) { in mctp_uart_callback()
263 res = uart_rx_enable(uart->dev, uart->rx_buf[0], sizeof(uart->rx_buf[0]), 1000); in mctp_uart_start_rx()
A Dmctp_i2c_gpio_controller.c35 memcpy(pkt->data, b->rx_buf, b->rx_buf_len); in rx_completion()
71 rtio_sqe_prep_read(read_msg_sqe, iodev, RTIO_PRIO_NORM, b->rx_buf, b->rx_buf_len, NULL); in rx_len_completion()
/subsys/usb/device/class/netusb/
A Dfunction_ecm.c31 static uint8_t tx_buf[NET_ETH_MAX_FRAME_SIZE], rx_buf[NET_ETH_MAX_FRAME_SIZE]; variable
288 if (rx_buf[size - 1] == 0U) { /* last byte is null */ in ecm_read_cb()
289 if (ecm_eth_size(rx_buf, size) == (size - 1)) { in ecm_read_cb()
302 if (net_pkt_write(pkt, rx_buf, size)) { in ecm_read_cb()
315 usb_transfer(ecm_ep_data[ECM_OUT_EP_IDX].ep_addr, rx_buf, in ecm_read_cb()
316 sizeof(rx_buf), USB_TRANS_READ, ecm_read_cb, NULL); in ecm_read_cb()
A Dfunction_eem.c24 static uint8_t tx_buf[EEM_FRAME_SIZE], rx_buf[EEM_FRAME_SIZE]; variable
143 uint8_t *ptr = rx_buf; in eem_read_cb()
200 usb_transfer(eem_ep_data[EEM_OUT_EP_IDX].ep_addr, rx_buf, in eem_read_cb()
201 sizeof(rx_buf), USB_TRANS_READ, eem_read_cb, NULL); in eem_read_cb()
A Dfunction_rndis.c177 static uint8_t rx_buf[RNDIS_BUF_SIZE]; variable
294 if (len > sizeof(rx_buf)) { in rndis_bulk_out()
300 usb_read(ep, rx_buf, len, &read); in rndis_bulk_out()
311 if (len == 1U && !rx_buf[0]) { in rndis_bulk_out()
339 rndis.in_pkt_len = parse_rndis_header(rx_buf, len); in rndis_bulk_out()
367 rx_buf + hdr_offset, len - hdr_offset)) { in rndis_bulk_out()
/subsys/net/lib/mqtt/
A Dmqtt_rx.c201 if ((buf->end + remaining > client->rx_buf + client->rx_buf_size) || in mqtt_read_message_chunk()
202 (buf->end + remaining < client->rx_buf)) { in mqtt_read_message_chunk()
318 buf->cur = client->rx_buf; in mqtt_read_and_parse_fixed_header()
334 buf.cur = client->rx_buf; in mqtt_handle_rx()
335 buf.end = client->rx_buf + client->internal.rx_buf_datalen; in mqtt_handle_rx()
/subsys/shell/backends/
A Dshell_websocket.c123 buf_left = sizeof(ws->rx_buf) - ws->rx_len; in ws_recv()
131 buf = ws->rx_buf + ws->rx_len; in ws_recv()
352 memcpy(data, ws->rx_buf, read_len); in sh_read()
357 memmove(ws->rx_buf, ws->rx_buf + read_len, ws->rx_len); in sh_read()
A Dshell_telnet.c279 buf_left = sizeof(sh_telnet->rx_buf) - sh_telnet->rx_len; in telnet_recv()
287 buf = sh_telnet->rx_buf + sh_telnet->rx_len; in telnet_recv()
760 memcpy(data, sh_telnet->rx_buf, read_len); in telnet_read()
765 memmove(sh_telnet->rx_buf, sh_telnet->rx_buf + read_len, in telnet_read()
A Dshell_uart.c61 uart_async_rx_on_buf_rel(&sh_uart->async_rx, evt->data.rx_buf.buf); in async_callback()
216 sh_uart->rx_buf); in irq_init()
284 sh_uart->rx_buf); in polling_init()
A Dshell_rpmsg.c69 k_msgq_init(&sh_rpmsg->rx_q, (char *)sh_rpmsg->rx_buf, sizeof(struct shell_rpmsg_rx), in init()
/subsys/mgmt/ec_host_cmd/backends/
A Dec_host_cmd_backend_shi_npcx.c130 volatile uint8_t *rx_buf; /* Entry pointer of receive buffer */ member
272 while (data->rx_buf == inst->IBUF + shi_npcx_read_buf_pointer(inst)) { in shi_npcx_read_inbuf_wait()
279 *data->rx_msg++ = *data->rx_buf++; in shi_npcx_read_inbuf_wait()
538 *data->rx_msg++ = *data->rx_buf++; in shi_npcx_read_half_inbuf()
666 data->rx_buf = inst->IBUF; in shi_npcx_handle_input_buf_full()
793 data->rx_buf = inst->IBUF; in shi_npcx_reset_prepare()
/subsys/usb/device/class/
A Dcdc_acm.c114 uint8_t rx_buf[CDC_ACM_BUFFER_SIZE]; /* Internal RX buffer */ member
312 wrote = ring_buf_put(dev_data->rx_ringbuf, dev_data->rx_buf, size); in cdc_acm_read_cb()
324 if (ring_buf_space_get(dev_data->rx_ringbuf) < sizeof(dev_data->rx_buf)) { in cdc_acm_read_cb()
331 usb_transfer(ep, dev_data->rx_buf, sizeof(dev_data->rx_buf), in cdc_acm_read_cb()
372 memset(&dev_data->rx_buf, 0, CDC_ACM_BUFFER_SIZE); in cdc_acm_reset_port()
/subsys/mgmt/ec_host_cmd/
A Dec_host_cmd_handler.c346 static void ec_host_cmd_log_request(const uint8_t *rx_buf) in ec_host_cmd_log_request() argument
350 (const struct ec_host_cmd_request_header *const)rx_buf; in ec_host_cmd_log_request()
362 const uint8_t *rx_data = rx_buf + RX_HEADER_SIZE; in ec_host_cmd_log_request()
/subsys/modem/backends/
A Dmodem_backend_uart_async.c95 if (evt->data.rx_buf.buf == backend->async.receive_bufs[0]) { in modem_backend_uart_async_event_handler()
102 if (evt->data.rx_buf.buf == backend->async.receive_bufs[1]) { in modem_backend_uart_async_event_handler()
A Dmodem_backend_uart_async_hwfc.c168 if (evt->data.rx_buf.buf) { in modem_backend_uart_async_hwfc_event_handler()
169 rx_buf_unref(&backend->async, evt->data.rx_buf.buf); in modem_backend_uart_async_hwfc_event_handler()
/subsys/rtio/
A Drtio_handlers.c45 valid_sqe &= K_SYSCALL_MEMORY(sqe->txrx.rx_buf, sqe->txrx.buf_len, true); in rtio_vrfy_sqe()
/subsys/bluetooth/mesh/
A Dpb_adv.c141 NET_BUF_SIMPLE_DEFINE_STATIC(rx_buf, RX_BUFFER_MAX);
143 static struct pb_adv link = { .rx = { .buf = &rx_buf } };
367 link.rx.buf = &rx_buf; in reset_adv_link()

Completed in 42 milliseconds

12