Home
last modified time | relevance | path

Searched refs:mpsc_buffer (Results 1 – 4 of 4) sorted by relevance

/Zephyr-4.2.1/subsys/shell/
Dshell_log_backend.c23 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()
214 struct mpsc_pbuf_buffer *mpsc_buffer = log_backend->mpsc_buffer; in process_msg_from_buffer() local
220 msg = (union log_msg_generic *)mpsc_pbuf_claim(mpsc_buffer); in process_msg_from_buffer()
227 mpsc_pbuf_free(mpsc_buffer, &msg->buf); in process_msg_from_buffer()
237 struct mpsc_pbuf_buffer *mpsc_buffer = log_backend->mpsc_buffer; in process() local
247 if (copy_to_pbuffer(mpsc_buffer, msg, log_backend->timeout)) { in process()
/Zephyr-4.2.1/tests/lib/mpsc_pbuf/src/
Dconcurrent.c18 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()
Dmain.c1044 struct mpsc_pbuf_buffer mpsc_buffer; member
1076 msg = mpsc_pbuf_claim(&test_hnd->mpsc_buffer); in t_data_consumer_entry()
1082 if (test_data && test_hnd->mpsc_buffer.wr_idx == 0) { in t_data_consumer_entry()
1089 mpsc_pbuf_free(&test_hnd->mpsc_buffer, msg); in t_data_consumer_entry()
1126 mpsc_pbuf_init(&test_hnd.mpsc_buffer, &cfg); in ZTEST()
1152 item = (struct test_msg_data *)mpsc_pbuf_alloc(&test_hnd.mpsc_buffer, in ZTEST()
1157 mpsc_pbuf_commit(&test_hnd.mpsc_buffer, &item->hdr); in ZTEST()
/Zephyr-4.2.1/include/zephyr/shell/
Dshell_log_backend.h42 struct mpsc_pbuf_buffer *mpsc_buffer; member
91 .mpsc_buffer = &_name##_mpsc_buffer, \