| /Zephyr-latest/drivers/bluetooth/hci/ |
| D | hci_da1469x.c | 62 } rx = { variable
63 .fifo = Z_FIFO_INITIALIZER(rx.fifo),
69 if (cmac_mbox_read(&rx.type, 1) != 1) { in h4_get_type()
71 rx.type = BT_HCI_H4_NONE; in h4_get_type()
75 switch (rx.type) { in h4_get_type()
77 rx.remaining = sizeof(rx.evt); in h4_get_type()
78 rx.hdr_len = rx.remaining; in h4_get_type()
81 rx.remaining = sizeof(rx.acl); in h4_get_type()
82 rx.hdr_len = rx.remaining; in h4_get_type()
86 rx.remaining = sizeof(rx.iso); in h4_get_type()
[all …]
|
| D | h4.c | 55 } rx; member
79 if (uart_fifo_read(cfg->uart, &h4->rx.type, 1) != 1) { in h4_get_type()
81 h4->rx.type = BT_HCI_H4_NONE; in h4_get_type()
85 switch (h4->rx.type) { in h4_get_type()
87 h4->rx.remaining = sizeof(h4->rx.evt); in h4_get_type()
88 h4->rx.hdr_len = h4->rx.remaining; in h4_get_type()
91 h4->rx.remaining = sizeof(h4->rx.acl); in h4_get_type()
92 h4->rx.hdr_len = h4->rx.remaining; in h4_get_type()
96 h4->rx.remaining = sizeof(h4->rx.iso); in h4_get_type()
97 h4->rx.hdr_len = h4->rx.remaining; in h4_get_type()
[all …]
|
| /Zephyr-latest/subsys/bluetooth/mesh/ |
| D | transport.c | 717 static void seg_rx_assemble(struct seg_rx *rx, struct net_buf_simple *buf, in seg_rx_assemble() argument
724 for (i = 0; i <= rx->seg_n; i++) { in seg_rx_assemble()
725 net_buf_simple_add_mem(buf, rx->seg[i], in seg_rx_assemble()
726 MIN(seg_len(rx->ctl), in seg_rx_assemble()
727 rx->len - (i * seg_len(rx->ctl)))); in seg_rx_assemble()
731 if (!rx->ctl) { in seg_rx_assemble()
743 static int sdu_try_decrypt(struct bt_mesh_net_rx *rx, const struct bt_mesh_key *key, in sdu_try_decrypt() argument
756 if (BT_MESH_ADDR_IS_VIRTUAL(rx->ctx.recv_dst)) { in sdu_try_decrypt()
757 ctx->crypto.ad = bt_mesh_va_uuid_get(rx->ctx.recv_dst, ctx->crypto.ad, in sdu_try_decrypt()
770 if (!err && BT_MESH_ADDR_IS_VIRTUAL(rx->ctx.recv_dst)) { in sdu_try_decrypt()
[all …]
|
| D | pb_adv.c | 43 #define XACT_SEG_DATA(_seg) (&link.rx.buf->data[XACT_SEG_OFFSET(_seg)])
44 #define XACT_SEG_RECV(_seg) (link.rx.seg &= ~(1 << (_seg)))
90 } rx; member
143 static struct pb_adv link = { .rx = { .buf = &rx_buf } };
146 static void link_open(struct prov_rx *rx, struct net_buf_simple *buf);
147 static void link_ack(struct prov_rx *rx, struct net_buf_simple *buf);
148 static void link_close(struct prov_rx *rx, struct net_buf_simple *buf);
351 link.rx.id = XACT_ID_NVAL; in reset_adv_link()
362 link.rx.id = XACT_ID_MAX; in reset_adv_link()
367 link.rx.buf = &rx_buf; in reset_adv_link()
[all …]
|
| D | sar_cfg.c | 30 const struct bt_mesh_sar_rx *rx) in bt_mesh_sar_rx_encode() argument
32 net_buf_simple_add_u8(buf, (rx->seg_thresh & 0x1f) | in bt_mesh_sar_rx_encode()
33 (rx->ack_delay_inc << 5)); in bt_mesh_sar_rx_encode()
34 net_buf_simple_add_u8(buf, (rx->discard_timeout & 0xf) | in bt_mesh_sar_rx_encode()
35 ((rx->rx_seg_int_step & 0xf) << 4)); in bt_mesh_sar_rx_encode()
36 net_buf_simple_add_u8(buf, (rx->ack_retrans_count & 0x3)); in bt_mesh_sar_rx_encode()
58 struct bt_mesh_sar_rx *rx) in bt_mesh_sar_rx_decode() argument
63 rx->seg_thresh = (val & 0x1f); in bt_mesh_sar_rx_decode()
64 rx->ack_delay_inc = (val >> 5); in bt_mesh_sar_rx_decode()
66 rx->discard_timeout = (val & 0xf); in bt_mesh_sar_rx_decode()
[all …]
|
| D | net.c | 62 struct bt_mesh_net_rx *rx; member
169 static void msg_cache_add(struct bt_mesh_net_rx *rx) in msg_cache_add() argument
172 msg_cache[msg_cache_next].src = rx->ctx.addr; in msg_cache_add()
173 msg_cache[msg_cache_next].seq = rx->seq; in msg_cache_add()
404 struct bt_mesh_net_rx rx = { in bt_mesh_net_local() local
426 LOG_DBG("src: 0x%04x dst: 0x%04x seq 0x%06x sub %p", rx.ctx.addr, rx.ctx.addr, in bt_mesh_net_local()
427 rx.seq, buf->sub); in bt_mesh_net_local()
430 (void)bt_mesh_trans_recv(&sbuf, &rx); in bt_mesh_net_local()
622 static bool net_decrypt(struct bt_mesh_net_rx *rx, struct net_buf_simple *in, in net_decrypt() argument
626 bool proxy = (rx->net_if == BT_MESH_NET_IF_PROXY_CFG); in net_decrypt()
[all …]
|
| D | friend.h | 21 void bt_mesh_friend_enqueue_rx(struct bt_mesh_net_rx *rx,
37 int bt_mesh_friend_poll(struct bt_mesh_net_rx *rx, struct net_buf_simple *buf);
38 int bt_mesh_friend_req(struct bt_mesh_net_rx *rx, struct net_buf_simple *buf);
39 int bt_mesh_friend_clear(struct bt_mesh_net_rx *rx, struct net_buf_simple *buf);
40 int bt_mesh_friend_clear_cfm(struct bt_mesh_net_rx *rx,
42 int bt_mesh_friend_sub_add(struct bt_mesh_net_rx *rx,
44 int bt_mesh_friend_sub_rem(struct bt_mesh_net_rx *rx,
|
| D | lpn.h | 7 int bt_mesh_lpn_friend_update(struct bt_mesh_net_rx *rx,
9 int bt_mesh_lpn_friend_offer(struct bt_mesh_net_rx *rx,
11 int bt_mesh_lpn_friend_clear_cfm(struct bt_mesh_net_rx *rx,
13 int bt_mesh_lpn_friend_sub_cfm(struct bt_mesh_net_rx *rx,
45 void bt_mesh_lpn_msg_received(struct bt_mesh_net_rx *rx);
|
| /Zephyr-latest/subsys/bluetooth/controller/ll_sw/nordic/lll/ |
| D | lll_peripheral_iso.c | 221 phy = cis_lll->rx.phy; in prepare_cb()
238 payload_cnt = cis_lll->rx.payload_count + in prepare_cb()
239 cis_lll->rx.bn_curr - 1U; in prepare_cb()
241 cis_lll->rx.ccm.counter = payload_cnt; in prepare_cb()
247 (cis_lll->rx.max_pdu + PDU_MIC_SIZE), in prepare_cb()
249 radio_pkt_rx_set(radio_ccm_iso_rx_pkt_set(&cis_lll->rx.ccm, phy, in prepare_cb()
261 cis_lll->rx.max_pdu, pkt_flags); in prepare_cb()
270 radio_switch_complete_and_tx(cis_lll->rx.phy, 0U, cis_lll->tx.phy, in prepare_cb()
305 hcto += radio_rx_ready_delay_get(cis_lll->rx.phy, PHY_FLAGS_S8); in prepare_cb()
306 hcto += addr_us_get(cis_lll->rx.phy); in prepare_cb()
[all …]
|
| D | lll_prof.c | 26 static int send(struct node_rx_pdu *rx);
164 struct node_rx_pdu *rx; in lll_prof_send() local
167 rx = ull_pdu_rx_alloc_peek(3); in lll_prof_send()
168 if (rx) { in lll_prof_send()
175 struct node_rx_pdu *rx; in lll_prof_reserve() local
177 rx = ull_pdu_rx_alloc_peek(3); in lll_prof_reserve()
178 if (!rx) { in lll_prof_reserve()
184 return rx; in lll_prof_reserve()
187 void lll_prof_reserve_send(struct node_rx_pdu *rx) in lll_prof_reserve_send() argument
189 if (rx) { in lll_prof_reserve_send()
[all …]
|
| D | lll_central_iso.c | 204 pdu_tx->cie = (cis_lll->rx.bn_curr > cis_lll->rx.bn); in prepare_cb()
248 (cis_lll->rx.bn_curr > cis_lll->rx.bn); in prepare_cb()
303 radio_switch_complete_and_rx(cis_lll->rx.phy); in prepare_cb()
463 radio_phy_set(cis_lll->rx.phy, PHY_FLAGS_S8); in isr_tx()
473 payload_count = cis_lll->rx.payload_count + in isr_tx()
474 cis_lll->rx.bn_curr - 1U; in isr_tx()
476 cis_lll->rx.ccm.counter = payload_count; in isr_tx()
479 cis_lll->rx.phy, in isr_tx()
482 (cis_lll->rx.max_pdu + PDU_MIC_SIZE), in isr_tx()
484 radio_pkt_rx_set(radio_ccm_iso_rx_pkt_set(&cis_lll->rx.ccm, in isr_tx()
[all …]
|
| /Zephyr-latest/tests/bluetooth/controller/mock_ctrl/src/ |
| D | ull.c | 125 struct node_rx_hdr *rx; in ll_rx_mem_release() local
127 rx = *node_rx; in ll_rx_mem_release()
128 while (rx) { in ll_rx_mem_release()
131 rx_free = rx; in ll_rx_mem_release()
132 rx = rx->next; in ll_rx_mem_release()
151 *node_rx = rx; in ll_rx_mem_release()
181 void ll_rx_put(memq_link_t *link, void *rx) in ll_rx_put() argument
183 if (((struct node_rx_hdr *)rx)->type != NODE_RX_TYPE_RELEASE) { in ll_rx_put()
185 sys_slist_append(&ut_rx_q, (sys_snode_t *)rx); in ll_rx_put()
193 void ll_rx_put_sched(memq_link_t *link, void *rx) in ll_rx_put_sched() argument
[all …]
|
| /Zephyr-latest/drivers/sensor/meas/ms5607/ |
| D | ms5607_spi.c | 64 uint8_t rx[3]; in ms5607_spi_read_prom() member
65 } rx; in ms5607_spi_read_prom() local
69 .buf = &rx, in ms5607_spi_read_prom()
88 *val = sys_be16_to_cpu(rx.prom_value); in ms5607_spi_read_prom()
113 uint8_t rx[4]; in ms5607_spi_read_adc() member
114 } rx; in ms5607_spi_read_adc() local
117 .buf = &rx, in ms5607_spi_read_adc()
136 rx.rx[0] = 0; in ms5607_spi_read_adc()
137 *val = sys_be32_to_cpu(rx.adc_value); in ms5607_spi_read_adc()
|
| /Zephyr-latest/subsys/shell/backends/ |
| D | shell_rpmsg.c | 19 struct shell_rpmsg_rx rx; in rpmsg_shell_cb() local
25 rx.data = data; in rpmsg_shell_cb()
26 rx.len = len; in rpmsg_shell_cb()
27 if (k_msgq_put(&sh_rpmsg->rx_q, &rx, K_NO_WAIT) != 0) { in rpmsg_shell_cb()
135 struct shell_rpmsg_rx *rx = &sh_rpmsg->rx_cur; in read() local
144 if (rx->data == NULL) { in read()
145 int ret = k_msgq_get(&sh_rpmsg->rx_q, rx, K_NO_WAIT); in read()
148 rx->data = NULL; in read()
152 __ASSERT_NO_MSG(rx->len > 0); in read()
156 __ASSERT_NO_MSG(rx->len > sh_rpmsg->rx_consumed); in read()
[all …]
|
| /Zephyr-latest/subsys/bluetooth/controller/ll_sw/openisa/lll/ |
| D | lll_prof.c | 115 struct node_rx_pdu *rx; in lll_prof_send() local
118 rx = ull_pdu_rx_alloc_peek(3); in lll_prof_send()
119 if (rx) { in lll_prof_send()
125 rx->hdr.type = NODE_RX_TYPE_PROFILE; in lll_prof_send()
126 rx->hdr.handle = 0xFFFF; in lll_prof_send()
128 pdu = (void *)rx->pdu; in lll_prof_send()
137 ull_rx_put_sched(rx->hdr.link, rx); in lll_prof_send()
|
| /Zephyr-latest/drivers/ethernet/ |
| D | eth_ivshmem_queue.c | 48 q->rx.shmem = (void *)rx_shmem; in eth_ivshmem_queue_init()
52 vring_init(&q->rx.vring, vring_desc_len, q->rx.shmem, ETH_IVSHMEM_VRING_ALIGNMENT); in eth_ivshmem_queue_init()
60 q->tx.vring.used = q->rx.vring.used; in eth_ivshmem_queue_init()
61 q->rx.vring.used = tmp_used; in eth_ivshmem_queue_init()
79 q->rx.avail_idx = 0; in eth_ivshmem_queue_reset()
80 q->rx.used_idx = 0; in eth_ivshmem_queue_reset()
169 struct vring_desc *desc = &q->rx.vring.desc[avail_desc_idx]; in eth_ivshmem_queue_rx()
182 *data = (uint8_t *)q->rx.shmem + q->vring_header_size + offset; in eth_ivshmem_queue_rx()
197 uint16_t used_idx = q->rx.used_idx % q->desc_max_len; in eth_ivshmem_queue_rx_complete()
199 q->rx.used_idx++; in eth_ivshmem_queue_rx_complete()
[all …]
|
| /Zephyr-latest/samples/subsys/ipc/ipc_service/multi_endpoint/remote/boards/ |
| D | nrf5340dk_nrf5340_cpunet_icbmsg.overlay | 38 rx-region = <&sram_ipc0_rx>;
40 rx-blocks = <16>;
42 mbox-names = "rx", "tx";
49 rx-region = <&sram_ipc1_rx>;
51 rx-blocks = <32>;
53 mbox-names = "rx", "tx";
|
| /Zephyr-latest/subsys/bluetooth/controller/ll_sw/ |
| D | ull_scan_aux.c | 140 static void rx_release_put(struct node_rx_pdu *rx) in rx_release_put() argument
142 rx->hdr.type = NODE_RX_TYPE_RELEASE; in rx_release_put()
144 ll_rx_put(rx->hdr.link, rx); in rx_release_put()
169 void ull_scan_aux_setup(memq_link_t *link, struct node_rx_pdu *rx) in ull_scan_aux_setup() argument
206 ftr = &rx->rx_ftr; in ull_scan_aux_setup()
208 switch (rx->hdr.type) { in ull_scan_aux_setup()
331 rx->hdr.type = NODE_RX_TYPE_EXT_1M_REPORT; in ull_scan_aux_setup()
334 rx->hdr.type = NODE_RX_TYPE_EXT_2M_REPORT; in ull_scan_aux_setup()
338 rx->hdr.type = NODE_RX_TYPE_EXT_CODED_REPORT; in ull_scan_aux_setup()
355 rx->hdr.type = NODE_RX_TYPE_SYNC_REPORT; in ull_scan_aux_setup()
[all …]
|
| D | ull.c | 562 static void rx_release_replenish(struct node_rx_hdr *rx);
961 struct node_rx_pdu *rx; in ll_rx_get() local
978 link = memq_peek(memq_ll_rx.head, memq_ll_rx.tail, (void **)&rx); in ll_rx_get()
981 cmplt = tx_cmplt_get(handle, &mfifo_fifo_tx_ack.f, rx->hdr.ack_last); in ll_rx_get()
1002 } else if (rx->hdr.type == NODE_RX_TYPE_RELEASE) { in ll_rx_get()
1004 rx_release_replenish((struct node_rx_hdr *)rx); in ll_rx_get()
1012 } else if (rx->hdr.type == NODE_RX_TYPE_IQ_SAMPLE_REPORT_LLL_RELEASE) { in ll_rx_get()
1018 ull_df_iq_report_mem_release(rx); in ll_rx_get()
1025 } else if (rx->hdr.type == NODE_RX_TYPE_SYNC_CHM_COMPLETE) { in ll_rx_get()
1031 ull_adv_sync_chm_complete(rx); in ll_rx_get()
[all …]
|
| /Zephyr-latest/tests/subsys/mgmt/ec_host_cmd/uart/src/ |
| D | main.c | 109 evt.data.rx.len = CMD_HEADER_SIZE + sizeof(struct hello_cmd_data); in test_hello()
110 evt.data.rx.offset = 0; in test_hello()
111 evt.data.rx.buf = data->rx_buf; in test_hello()
150 evt.data.rx.len = CMD_HEADER_SIZE + 1; in ZTEST()
151 evt.data.rx.offset = 1; in ZTEST()
152 evt.data.rx.buf = data->rx_buf; in ZTEST()
189 evt.data.rx.len = CMD_HEADER_SIZE; in ZTEST()
190 evt.data.rx.offset = 0; in ZTEST()
191 evt.data.rx.buf = data->rx_buf; in ZTEST()
214 evt.data.rx.len = data->rx_buf_size + 1; in ZTEST()
[all …]
|
| /Zephyr-latest/drivers/serial/ |
| D | uart_max32.c | 73 struct max32_uart_async_rx rx; member
326 k_work_init_delayable(&data->async.rx.timeout_work, uart_max32_async_rx_timeout); in uart_max32_init()
327 data->async.rx.len = 0; in uart_max32_init()
328 data->async.rx.offset = 0; in uart_max32_init()
483 if (data->async.rx.timeout != SYS_FOREVER_US && data->async.rx.timeout != 0 && in uart_max32_isr()
485 k_work_reschedule(&data->async.rx.timeout_work, K_USEC(data->async.rx.timeout)); in uart_max32_isr()
733 k_work_cancel_delayable(&data->async.rx.timeout_work); in api_rx_disable()
751 .data.rx_buf.buf = data->async.rx.buf, in api_rx_disable()
760 data->async.rx.buf = NULL; in api_rx_disable()
761 data->async.rx.len = 0; in api_rx_disable()
[all …]
|
| D | uart_async_to_irq.c | 81 uint8_t *buf = uart_async_rx_buf_req(&data->rx.async_rx); in try_rx_enable()
82 size_t len = uart_async_rx_get_buf_len(&data->rx.async_rx); in try_rx_enable()
95 struct uart_async_rx *async_rx = &data->rx.async_rx; in on_rx_buf_req()
106 atomic_inc(&data->rx.pending_buf_req); in on_rx_buf_req()
115 if (data->rx.async_rx.pending_bytes == 0) { in on_rx_dis()
116 uart_async_rx_reset(&data->rx.async_rx); in on_rx_dis()
121 data->rx.pending_buf_req = 0; in on_rx_dis()
129 k_sem_give(&data->rx.sem); in on_rx_dis()
146 uart_async_rx_on_rdy(&data->rx.async_rx, evt->data.rx.buf, evt->data.rx.len); in uart_async_to_irq_callback()
153 uart_async_rx_on_buf_rel(&data->rx.async_rx, evt->data.rx_buf.buf); in uart_async_to_irq_callback()
[all …]
|
| /Zephyr-latest/samples/subsys/ipc/ipc_service/multi_endpoint/boards/ |
| D | nrf5340dk_nrf5340_cpuapp_icbmsg.overlay | 38 rx-region = <&sram_ipc0_rx>;
40 rx-blocks = <24>;
42 mbox-names = "tx", "rx";
54 rx-region = <&sram_ipc1_rx>;
56 rx-blocks = <48>;
58 mbox-names = "tx", "rx";
|
| /Zephyr-latest/drivers/spi/ |
| D | spi_rtio.c | 94 rx_bufs[i].buf = sqe->rx.buf; in spi_rtio_iodev_default_submit_sync()
95 rx_bufs[i].len = sqe->rx.buf_len; in spi_rtio_iodev_default_submit_sync()
97 tx_bufs[i].len = sqe->rx.buf_len; in spi_rtio_iodev_default_submit_sync()
177 uint32_t rx = 0, rx_len = 0; in spi_rtio_copy() local
187 tx_len = rx_bufs->buffers[rx].len; in spi_rtio_copy()
190 if (rx < rx_count) { in spi_rtio_copy()
191 rx_buf = rx_bufs->buffers[rx].buf; in spi_rtio_copy()
192 rx_len = rx_bufs->buffers[rx].len; in spi_rtio_copy()
199 while ((tx < tx_count || rx < rx_count) && (tx_len > 0 || rx_len > 0)) { in spi_rtio_copy()
223 rx++; in spi_rtio_copy()
[all …]
|
| /Zephyr-latest/subsys/net/lib/shell/ |
| D | mem.c | 102 struct k_mem_slab *rx, *tx; in cmd_net_mem() local
105 net_pkt_get_info(&rx, &tx, &rx_data, &tx_data); in cmd_net_mem()
119 PR("%p\t%d\t%u\t%u\tRX\n", rx, rx->info.num_blocks, in cmd_net_mem()
120 k_mem_slab_num_free_get(rx), rx->info.max_used); in cmd_net_mem()
126 rx, rx->info.num_blocks, k_mem_slab_num_free_get(rx)); in cmd_net_mem()
139 PR("%p\t%d\tRX\n", rx, rx->info.num_blocks); in cmd_net_mem()
|
