Searched refs:mpsc_buffer (Results 1 – 3 of 3) sorted by relevance
| /Zephyr-latest/subsys/shell/ |
| D | shell_log_backend.c | 23 mpsc_pbuf_init(backend->mpsc_buffer, backend->mpsc_buffer_config); in fifo_reset()
126 static bool copy_to_pbuffer(struct mpsc_pbuf_buffer *mpsc_buffer, in copy_to_pbuffer() argument
133 dst = mpsc_pbuf_alloc(mpsc_buffer, wlen, K_MSEC(timeout)); in copy_to_pbuffer()
153 mpsc_pbuf_commit(mpsc_buffer, dst); in copy_to_pbuffer()
208 struct mpsc_pbuf_buffer *mpsc_buffer = log_backend->mpsc_buffer; in process_msg_from_buffer() local
214 msg = (union log_msg_generic *)mpsc_pbuf_claim(mpsc_buffer); in process_msg_from_buffer()
221 mpsc_pbuf_free(mpsc_buffer, &msg->buf); in process_msg_from_buffer()
231 struct mpsc_pbuf_buffer *mpsc_buffer = log_backend->mpsc_buffer; in process() local
242 if (copy_to_pbuffer(mpsc_buffer, msg, log_backend->timeout)) { in process()
|
| /Zephyr-latest/tests/lib/mpsc_pbuf/src/ |
| D | concurrent.c | 18 static struct mpsc_pbuf_buffer mpsc_buffer; variable
251 memset(&mpsc_buffer, 0, sizeof(mpsc_buffer)); in stress_test()
252 mpsc_pbuf_init(&mpsc_buffer, &config); in stress_test()
259 ZTRESS_THREAD(h1, &mpsc_buffer, 0, 0, t), in stress_test()
260 ZTRESS_THREAD(h2, &mpsc_buffer, 0, preempt_max, t), in stress_test()
261 ZTRESS_THREAD(h3, &mpsc_buffer, 0, preempt_max, t)); in stress_test()
265 ZTRESS_THREAD(h1, &mpsc_buffer, 0, 0, t), in stress_test()
266 ZTRESS_THREAD(h2, &mpsc_buffer, 0, preempt_max, t), in stress_test()
267 ZTRESS_THREAD(h3, &mpsc_buffer, 0, preempt_max, t), in stress_test()
268 ZTRESS_THREAD(h4, &mpsc_buffer, 0, preempt_max, t) in stress_test()
|
| /Zephyr-latest/include/zephyr/shell/ |
| D | shell_log_backend.h | 42 struct mpsc_pbuf_buffer *mpsc_buffer; member
91 .mpsc_buffer = &_name##_mpsc_buffer, \
|
