Home
last modified time | relevance | path

Searched refs:rx_len (Results 1 – 25 of 71) sorted by relevance

123

/Zephyr-latest/tests/drivers/ethernet/eth_ivshmem_queue/src/
Dmain.c21 static size_t rx_len; variable
53 rx_len = 0; in test_setup()
77 zassert_ok(eth_ivshmem_queue_rx(&q2, &rx_message, &rx_len)); in ZTEST()
78 zassert_equal(rx_len, sizeof(x)); in ZTEST()
96 zassert_ok(eth_ivshmem_queue_rx(&q2, &rx_message, &rx_len)); in ZTEST()
97 zassert_equal(rx_len, sizeof(q1_tx_data)); in ZTEST()
102 zassert_ok(eth_ivshmem_queue_rx(&q1, &rx_message, &rx_len)); in ZTEST()
103 zassert_equal(rx_len, sizeof(q2_tx_data)); in ZTEST()
111 zassert_equal(eth_ivshmem_queue_rx(&q1, &rx_message, &rx_len), -EWOULDBLOCK); in ZTEST()
141 zassert_ok(eth_ivshmem_queue_rx(&q2, &rx_message, &rx_len)); in ZTEST()
[all …]
/Zephyr-latest/drivers/spi/
Dspi_rtio.c140 uint32_t rx = 0, rx_len = 0; in spi_rtio_copy() local
155 rx_len = rx_bufs->buffers[rx].len; in spi_rtio_copy()
158 rx_len = tx_bufs->buffers[tx].len; in spi_rtio_copy()
162 while ((tx < tx_count || rx < rx_count) && (tx_len > 0 || rx_len > 0)) { in spi_rtio_copy()
174 if (tx_len == rx_len) { in spi_rtio_copy()
177 rx_buf, rx_len, NULL); in spi_rtio_copy()
183 tx_buf, rx_buf, rx_len, NULL); in spi_rtio_copy()
189 rx_len = rx_bufs->buffers[rx].len; in spi_rtio_copy()
192 rx_len = 0; in spi_rtio_copy()
204 (uint32_t)rx_len, in spi_rtio_copy()
[all …]
Dspi_context.h51 size_t rx_len; member
157 uint32_t rx_len = spi_context_total_rx_len(ctx); in spi_context_wait_for_completion() local
160 timeout_ms = MAX(tx_len, rx_len) * 8 * 1000 / in spi_context_wait_for_completion()
308 &ctx->rx_len, dfs); in spi_context_buffers_setup()
321 (void *)ctx->rx_buf, ctx->rx_len); in spi_context_buffers_setup()
382 if (!ctx->rx_len) { in spi_context_update_rx()
386 if (len > ctx->rx_len) { in spi_context_update_rx()
391 ctx->rx_len -= len; in spi_context_update_rx()
392 if (!ctx->rx_len) { in spi_context_update_rx()
399 &ctx->rx_len, dfs); in spi_context_update_rx()
[all …]
Dspi_sedi.c147 if ((ctx->tx_len == 0) && (ctx->rx_len == 0)) { in transceive()
162 transfer_bytes = ctx->rx_len; in transceive()
164 } else if (ctx->rx_len == 0) { in transceive()
170 } else if (ctx->tx_len == ctx->rx_len) { in transceive()
175 } else if (ctx->tx_len > ctx->rx_len) { in transceive()
182 transfer_bytes = ctx->rx_len; in transceive()
279 if ((ctx->rx_len == 0) && in spi_sedi_callback()
292 spi_context_update_rx(ctx, 1, ctx->rx_len); in spi_sedi_callback()
293 if (ctx->rx_len != 0) { in spi_sedi_callback()
295 ctx->rx_len); in spi_sedi_callback()
Dspi_mcux_dspi.c96 if ((ctx->tx_len == 0) && (ctx->rx_len == 0)) { in spi_mcux_transfer_next_packet()
122 if (ctx->rx_len != 0) { in spi_mcux_transfer_next_packet()
160 transfer.dataSize = ctx->rx_len; in spi_mcux_transfer_next_packet()
161 } else if (ctx->rx_len == 0) { in spi_mcux_transfer_next_packet()
166 } else if (ctx->tx_len == ctx->rx_len) { in spi_mcux_transfer_next_packet()
171 } else if (ctx->tx_len > ctx->rx_len) { in spi_mcux_transfer_next_packet()
178 transfer.dataSize = ctx->rx_len; in spi_mcux_transfer_next_packet()
399 if (data->ctx.rx_len == 0) { in update_rx_dma()
420 if (data->ctx.rx_len == 1) { in update_rx_dma()
502 LOG_DBG("ctx.rx_len is %d", data->ctx.rx_len); in dma_callback()
[all …]
Dspi_rv32m1_lpspi.c56 if ((ctx->tx_len == 0) && (ctx->rx_len == 0)) { in spi_mcux_transfer_next_packet()
70 transfer.dataSize = ctx->rx_len; in spi_mcux_transfer_next_packet()
71 } else if (ctx->rx_len == 0) { in spi_mcux_transfer_next_packet()
76 } else if (ctx->tx_len == ctx->rx_len) { in spi_mcux_transfer_next_packet()
81 } else if (ctx->tx_len > ctx->rx_len) { in spi_mcux_transfer_next_packet()
88 transfer.dataSize = ctx->rx_len; in spi_mcux_transfer_next_packet()
Dspi_psoc6.c59 LOG_DBG("TX L: %d, RX L: %d", ctx->tx_len, ctx->rx_len); in spi_psoc6_transfer_next_packet()
61 if ((ctx->tx_len == 0U) && (ctx->rx_len == 0U)) { in spi_psoc6_transfer_next_packet()
74 xfer->dataSize = ctx->rx_len; in spi_psoc6_transfer_next_packet()
75 } else if (ctx->rx_len == 0U) { in spi_psoc6_transfer_next_packet()
80 } else if (ctx->tx_len == ctx->rx_len) { in spi_psoc6_transfer_next_packet()
85 } else if (ctx->tx_len > ctx->rx_len) { in spi_psoc6_transfer_next_packet()
92 xfer->dataSize = ctx->rx_len; in spi_psoc6_transfer_next_packet()
Dspi_smartbond.c91 size_t rx_len; member
423 if (ctx->rx_len || ctx->tx_len) { in spi_smartbond_transfer_mode_get()
483 if (ctx->rx_len && !ctx->rx_buf) { in spi_smartbond_write()
495 while (data->rx_len) { in spi_smartbond_transfer()
510 data->rx_len--; in spi_smartbond_transfer()
579 data->rx_len = spi_context_max_continuous_chunk(ctx); in spi_smartbond_isr_trigger()
580 data->tx_len = data->rx_len; in spi_smartbond_isr_trigger()
645 if (!data->rx_len && !data->tx_len) { in spi_smartbond_isr()
656 data->rx_len = spi_context_max_continuous_chunk(ctx); in spi_smartbond_isr()
657 data->tx_len = data->rx_len; in spi_smartbond_isr()
[all …]
Dspi_dw.c123 if ((int)(spi->ctx.rx_len - spi->fifo_diff) <= 0) { in push_data()
175 if (!spi->ctx.rx_len && spi->ctx.tx_len < info->fifo_depth) { in pull_data()
177 } else if (read_rxftlr(dev) >= spi->ctx.rx_len) { in pull_data()
178 write_rxftlr(dev, spi->ctx.rx_len - 1); in pull_data()
413 if (spi->ctx.rx_len && in transceive()
414 spi->ctx.rx_len < dw_spi_rxftlr_dflt) { in transceive()
415 reg_data = spi->ctx.rx_len - 1; in transceive()
418 if (spi->ctx.rx_len && spi->ctx.rx_len < info->fifo_depth) { in transceive()
419 reg_data = spi->ctx.rx_len - 1; in transceive()
Dspi_mcux_flexcomm.c86 if ((ctx->tx_len == 0) && (ctx->rx_len == 0)) { in spi_mcux_transfer_next_packet()
98 transfer.dataSize = ctx->rx_len; in spi_mcux_transfer_next_packet()
99 } else if (ctx->rx_len == 0) { in spi_mcux_transfer_next_packet()
104 } else if (ctx->tx_len == ctx->rx_len) { in spi_mcux_transfer_next_packet()
109 } else if (ctx->tx_len > ctx->rx_len) { in spi_mcux_transfer_next_packet()
116 transfer.dataSize = ctx->rx_len; in spi_mcux_transfer_next_packet()
628 while (data->ctx.rx_len > 0 || data->ctx.tx_len > 0) { in transceive_dma()
636 if (data->ctx.rx_len == 0) { in transceive_dma()
640 dma_len = data->ctx.rx_len; in transceive_dma()
642 } else if (data->ctx.tx_len == data->ctx.rx_len) { in transceive_dma()
[all …]
Dspi_it8xxx2.c267 data->cmdq_data.data_length_lb = BYTE_0(ctx->rx_len); in spi_it8xxx2_rx()
268 data->cmdq_data.data_length_hb = BYTE_1(ctx->rx_len); in spi_it8xxx2_rx()
271 data->receive_len = ctx->rx_len; in spi_it8xxx2_rx()
288 spi_context_update_rx(ctx, 1, ctx->rx_len); in spi_it8xxx2_tx_rx()
291 data->cmdq_data.data_length_lb = BYTE_0(ctx->rx_len); in spi_it8xxx2_tx_rx()
292 data->cmdq_data.data_length_hb = BYTE_1(ctx->rx_len); in spi_it8xxx2_tx_rx()
296 data->receive_len = ctx->rx_len; in spi_it8xxx2_tx_rx()
311 spi_context_update_rx(ctx, 1, ctx->rx_len); in spi_it8xxx2_tx_rx()
/Zephyr-latest/subsys/shell/backends/
Dshell_websocket.c121 buf_left = sizeof(ws->rx_buf) - ws->rx_len; in ws_recv()
129 buf = ws->rx_buf + ws->rx_len; in ws_recv()
147 ws->rx_len += len; in ws_recv()
345 if (ws->rx_len == 0) { in sh_read()
350 read_len = ws->rx_len; in sh_read()
358 ws->rx_len -= read_len; in sh_read()
359 if (ws->rx_len > 0) { in sh_read()
360 memmove(ws->rx_buf, ws->rx_buf + read_len, ws->rx_len); in sh_read()
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()
371 sh_telnet->rx_len += len; in telnet_recv()
433 sh_telnet->rx_len = 0; in telnet_accept()
750 if (sh_telnet->rx_len == 0) { in telnet_read()
755 read_len = sh_telnet->rx_len; in telnet_read()
763 sh_telnet->rx_len -= read_len; in telnet_read()
764 if (sh_telnet->rx_len > 0) { in telnet_read()
766 sh_telnet->rx_len); in telnet_read()
/Zephyr-latest/drivers/w1/
Dw1_ds2485.c29 uint8_t *rx_buf, uint8_t rx_len) in ds2485_w1_script_cmd() argument
45 .len = rx_len, in ds2485_w1_script_cmd()
66 if ((rx_bytes[0] != (rx_len + 2)) || (rx_bytes[2] != w1_cmd)) { in ds2485_w1_script_cmd()
Dw1_ds2477_85_common.c226 int ds2477_85_read_block(const struct device *dev, uint8_t *buffer, size_t rx_len) in ds2477_85_read_block() argument
230 int w1_timing = cfg->mode_timing[data->master_reg.od_active].t_slot * 8 * rx_len; in ds2477_85_read_block()
231 uint8_t buf[3] = {CMD_RD_BLOCK, CMD_RD_BLOCK_LEN, rx_len}; in ds2477_85_read_block()
234 {.buf = buffer, .len = rx_len, .flags = (I2C_MSG_READ | I2C_MSG_STOP)} in ds2477_85_read_block()
238 __ASSERT_NO_MSG(rx_len <= MAX_BLOCK_LEN); in ds2477_85_read_block()
240 if (rx_len == 0) { in ds2477_85_read_block()
250 k_usleep(cfg->t_op_us + (cfg->t_seq_us * rx_len) + w1_timing); in ds2477_85_read_block()
/Zephyr-latest/drivers/ieee802154/
Dieee802154_uart_pipe.c119 if (!upipe->rx_len) { in upipe_rx()
124 upipe->rx_len = *buf; in upipe_rx()
130 if (upipe->rx_len == upipe->rx_off) { in upipe_rx()
131 pkt = net_pkt_rx_alloc_with_buffer(upipe->iface, upipe->rx_len, in upipe_rx()
138 if (net_pkt_write(pkt, upipe->rx_buf, upipe->rx_len)) { in upipe_rx()
155 LOG_DBG("Caught a packet (%u)", upipe->rx_len); in upipe_rx()
166 upipe->rx_len = 0U; in upipe_rx()
Dieee802154_uart_pipe.h21 uint8_t rx_len; member
Dieee802154_kw41z.c713 uint32_t rx_len; in kw41z_isr() local
754 rx_len = (irqsts & ZLL_IRQSTS_RX_FRAME_LENGTH_MASK) in kw41z_isr()
760 if (rx_len > IEEE802154_ACK_LENGTH) { in kw41z_isr()
763 seq_state, rx_len); in kw41z_isr()
775 rx_len = rx_len * 2U + 12 + 22 + 2; in kw41z_isr()
776 kw41z_tmr3_set_timeout(rx_len); in kw41z_isr()
831 rx_len = (ZLL->IRQSTS & in kw41z_isr()
836 if (rx_len != 0U) { in kw41z_isr()
838 rx_len); in kw41z_isr()
/Zephyr-latest/drivers/mipi_dsi/
Dmipi_dsi.c18 .rx_len = len, in mipi_dsi_generic_read()
78 .rx_len = len in mipi_dsi_dcs_read()
/Zephyr-latest/drivers/i2c/
Di2c_max32_rtio.c129 req->rx_len = buf_len; in max32_msg_start()
137 req->rx_len = 0; in max32_msg_start()
147 Wrap_MXC_I2C_SetRxCount(i2c, req->rx_len); in max32_msg_start()
209 } else if (readb < req->rx_len) { in i2c_max32_isr_controller()
239 readb += MXC_I2C_ReadRXFIFO(i2c, &req->rx_buf[readb], req->rx_len - readb); in i2c_max32_isr_controller()
240 if (readb == req->rx_len) { in i2c_max32_isr_controller()
256 Wrap_MXC_I2C_SetRxCount(i2c, req->rx_len - readb); in i2c_max32_isr_controller()
Di2c_max32.c236 Wrap_MXC_I2C_SetRxCount(i2c, req->rx_len); in i2c_max32_transfer_sync()
237 while (req->rx_len > readb) { in i2c_max32_transfer_sync()
240 readb += MXC_I2C_ReadRXFIFO(i2c, &req->rx_buf[readb], req->rx_len - readb); in i2c_max32_transfer_sync()
249 if ((int_fl0 & ADI_MAX32_I2C_INT_FL0_DONE) && (req->rx_len > readb) && in i2c_max32_transfer_sync()
251 Wrap_MXC_I2C_SetRxCount(i2c, req->rx_len - readb); in i2c_max32_transfer_sync()
270 if (req->rx_len) { in i2c_max32_transfer_sync()
455 req->rx_len = msgs[i].len; in i2c_max32_transfer()
463 req->rx_len = 0; in i2c_max32_transfer()
484 Wrap_MXC_I2C_SetRxCount(i2c, req->rx_len); in i2c_max32_transfer()
546 req->rx_len = msgs[i].len; in i2c_max32_transfer()
[all …]
Di2c_sc18im704.h80 uint8_t *rx_data, uint8_t rx_len);
/Zephyr-latest/drivers/serial/
Duart_sam0.c83 size_t rx_len; member
234 if (dev_data->rx_len == 0U) { in uart_sam0_dma_rx_done()
239 uart_sam0_notify_rx_processed(dev_data, dev_data->rx_len); in uart_sam0_dma_rx_done()
255 dev_data->rx_len = 0U; in uart_sam0_dma_rx_done()
270 dev_data->rx_len = dev_data->rx_next_len; in uart_sam0_dma_rx_done()
277 (uint32_t)dev_data->rx_buf, dev_data->rx_len); in uart_sam0_dma_rx_done()
314 if (dev_data->rx_len == 0U) { in uart_sam0_rx_timeout()
333 uint8_t *rx_dma_start = dev_data->rx_buf + dev_data->rx_len - in uart_sam0_rx_timeout()
344 dev_data->rx_len - rx_processed); in uart_sam0_rx_timeout()
750 if (dev_data->rx_len && regs->INTFLAG.bit.RXC && in uart_sam0_isr()
[all …]
/Zephyr-latest/drivers/bluetooth/hci/
Dapollox_blue.h29 typedef int (*bt_spi_transceive_fun)(void *tx, uint32_t tx_len, void *rx, uint32_t rx_len);
/Zephyr-latest/include/zephyr/shell/
Dshell_telnet.h49 size_t rx_len; member

123