| /Zephyr-latest/subsys/ipc/ipc_service/lib/ |
| D | pbuf.c | 19 static uint32_t idx_occupied(uint32_t len, uint32_t wr_idx, uint32_t rd_idx) in idx_occupied() argument
22 return (rd_idx > wr_idx) ? (len - (rd_idx - wr_idx)) : (wr_idx - rd_idx); in idx_occupied()
80 pb->data.wr_idx = 0; in pbuf_tx_init()
84 *(pb->cfg->wr_idx_loc) = pb->data.wr_idx; in pbuf_tx_init()
106 pb->data.wr_idx = 0; in pbuf_rx_init()
126 uint32_t wr_idx = pb->data.wr_idx; in pbuf_write() local
129 __ASSERT_NO_MSG(IS_PTR_ALIGNED_BYTES(wr_idx, _PBUF_IDX_SIZE)); in pbuf_write()
137 uint32_t free_space = blen - idx_occupied(blen, wr_idx, rd_idx) - _PBUF_IDX_SIZE; in pbuf_write()
150 *((uint32_t *)(&data_loc[wr_idx])) = 0; in pbuf_write()
151 sys_put_be16(len, &data_loc[wr_idx]); in pbuf_write()
[all …]
|
| /Zephyr-latest/lib/os/ |
| D | spsc_pbuf.c | 71 return &pb->ext.cache.wr_idx; in get_wr_idx_loc()
74 return &pb->ext.nocache.wr_idx; in get_wr_idx_loc()
155 uint32_t wr_idx = *wr_idx_loc; in spsc_pbuf_alloc() local
159 if (wr_idx >= rd_idx) { in spsc_pbuf_alloc()
160 int32_t remaining = pblen - wr_idx; in spsc_pbuf_alloc()
180 data_loc[wr_idx] = PADDING_MARK; in spsc_pbuf_alloc()
182 cache_wb(&data_loc[wr_idx], sizeof(uint8_t), flags); in spsc_pbuf_alloc()
184 wr_idx = 0; in spsc_pbuf_alloc()
185 *wr_idx_loc = wr_idx; in spsc_pbuf_alloc()
192 free_space = rd_idx - wr_idx - FREE_SPACE_DISTANCE; in spsc_pbuf_alloc()
[all …]
|
| D | mpsc_pbuf.c | 23 buffer->wr_idx, buffer->tmp_wr_idx, in mpsc_state_print()
88 if (buffer->flags & MPSC_PBUF_FULL || buffer->tmp_rd_idx > buffer->wr_idx) { in available()
93 *res = (buffer->wr_idx - buffer->tmp_rd_idx); in available()
172 buffer->wr_idx = idx_inc(buffer, buffer->wr_idx, wlen); in add_skip_item()
215 buffer->wr_idx = idx_inc(buffer, buffer->wr_idx, rd_wlen); in drop_item_locked()
284 buffer->wr_idx = idx_inc(buffer, in post_drop_action()
285 buffer->wr_idx, in post_drop_action()
316 buffer->wr_idx = idx_inc(buffer, buffer->wr_idx, 1); in mpsc_pbuf_put_word()
418 buffer->wr_idx = idx_inc(buffer, buffer->wr_idx, wlen); in mpsc_pbuf_commit()
456 buffer->wr_idx = idx_inc(buffer, buffer->wr_idx, l); in mpsc_pbuf_put_word_ext()
[all …]
|
| /Zephyr-latest/drivers/serial/ |
| D | uart_async_rx.c | 49 rx_buf->wr_idx += length; in uart_async_rx_on_rdy()
50 __ASSERT_NO_MSG(rx_buf->wr_idx <= rx_data->buf_len); in uart_async_rx_on_rdy()
57 buf->wr_idx = 0; in buf_reset()
95 if ((buf->completed == 1) && (rx_data->rd_idx == buf->wr_idx)) { in uart_async_rx_data_claim()
103 rem = buf->wr_idx - rx_data->rd_idx; in uart_async_rx_data_claim()
114 if ((buf->completed == 1) && (rx_data->rd_idx == buf->wr_idx)) { in uart_async_rx_data_consume()
120 __ASSERT_NO_MSG(rx_data->rd_idx <= buf->wr_idx); in uart_async_rx_data_consume()
|
| /Zephyr-latest/modules/hal_nordic/nrf_802154/serialization/platform/ |
| D | nrf_802154_spinel_backend_ipc.c | 112 static uint8_t wr_idx; variable
121 if (get_rb_idx_plus_1(wr_idx) == rd_idx) { in spinel_packet_from_thread_send()
128 struct ringbuffer *buf = &ring_buffer[wr_idx]; in spinel_packet_from_thread_send()
130 wr_idx = get_rb_idx_plus_1(wr_idx); in spinel_packet_from_thread_send()
|
| /Zephyr-latest/include/zephyr/sys/ |
| D | spsc_pbuf.h | 83 uint32_t wr_idx; /* Index of the first free byte in data[] */ member
89 uint32_t wr_idx; /* Index of the first free byte in data[] */ member
|
| D | mpsc_pbuf.h | 95 uint32_t wr_idx; member
|
| /Zephyr-latest/subsys/logging/frontends/ |
| D | log_frontend_stmesp_demux.c | 99 uint32_t *wr_idx = source_ids_data; in store_source_id() local
103 source_ids[*wr_idx].entry_id = entry_id; in store_source_id()
104 source_ids[*wr_idx].source_id = source_id; in store_source_id()
105 *wr_idx = *wr_idx + 1; in store_source_id()
106 if (*wr_idx == (demux.source_id_len)) { in store_source_id()
107 *wr_idx = 0; in store_source_id()
|
| /Zephyr-latest/doc/services/ipc/ipc_service/backends/ |
| D | ipc_service_icmsg.rst | 133 - Padding added to align ``wr_idx`` to the cache alignment.
134 * - ``wr_idx``
145 * The Indexes (``rd_idx`` and ``wr_idx``) are wrapped around when they reach the end of the ``data`…
146 * The FIFO is empty if ``rd_idx == wr_idx``.
185 #. Write the packet to ``data`` FIFO buffer starting at ``wr_idx``.
187 #. Write a new value of the ``wr_idx``.
195 #. Set the ``wr_idx`` and ``rd_idx`` to zero.
|
| /Zephyr-latest/include/zephyr/drivers/serial/ |
| D | uart_async_rx.h | 26 uint8_t wr_idx:7; member
|
| /Zephyr-latest/include/zephyr/ipc/ |
| D | pbuf.h | 73 volatile uint32_t wr_idx; /* Index of the first holding first member
|
| /Zephyr-latest/drivers/interrupt_controller/ |
| D | intc_gicv3_its.c | 300 uint64_t wr_idx, rd_idx, idx; in its_post_command() local
303 wr_idx = (data->cmd_write - data->cmd_base) * sizeof(*cmd); in its_post_command()
308 sys_write32(wr_idx, data->base + GITS_CWRITER); in its_post_command()
313 if (idx == wr_idx) { in its_post_command()
320 rd_idx, idx, wr_idx); in its_post_command()
|
| /Zephyr-latest/doc/services/logging/ |
| D | cs_stm.rst | 205 [00:00:00.163,319] <inf> app/spsc_pbuf: alloc 0x2f0df800 wr_idx:20
207 [00:00:00.189,090] <inf> app/spsc_pbuf: commit 0x2f0df800, len:20 wr_idx: 44
216 [00:00:05.077,068] <inf> rad/spsc_pbuf: alloc 0x2f0df000 wr_idx:44
218 [00:00:05.077,134] <inf> rad/spsc_pbuf: commit 0x2f0df000, len:20 wr_idx
|
| /Zephyr-latest/tests/subsys/ipc/pbuf/src/ |
| D | main.c | 30 printk("data.wr_idx: %u\n", pb->data.wr_idx); in print_pbuf_info()
|
