| /Zephyr-latest/subsys/modem/ |
| D | modem_pipe.c | 14 static void pipe_set_callback(struct modem_pipe *pipe, in pipe_set_callback() argument
18 K_SPINLOCK(&pipe->spinlock) { in pipe_set_callback()
19 pipe->callback = callback; in pipe_set_callback()
20 pipe->user_data = user_data; in pipe_set_callback()
24 static void pipe_call_callback(struct modem_pipe *pipe, enum modem_pipe_event event) in pipe_call_callback() argument
26 K_SPINLOCK(&pipe->spinlock) { in pipe_call_callback()
27 if (pipe->callback != NULL) { in pipe_call_callback()
28 pipe->callback(pipe, event, pipe->user_data); in pipe_call_callback()
33 static uint32_t pipe_test_events(struct modem_pipe *pipe, uint32_t events) in pipe_test_events() argument
35 return k_event_test(&pipe->event, events); in pipe_test_events()
[all …]
|
| D | modem_pipelink.c | 41 return link->pipe; in modem_pipelink_get_pipe()
52 void modem_pipelink_init(struct modem_pipelink *link, struct modem_pipe *pipe) in modem_pipelink_init() argument
54 link->pipe = pipe; in modem_pipelink_init()
|
| D | modem_ubx.c | 117 if (ubx->pipe == NULL) { in modem_ubx_run_script_helper()
179 static void modem_ubx_pipe_callback(struct modem_pipe *pipe, enum modem_pipe_event event, in modem_ubx_pipe_callback() argument
195 ret = modem_pipe_transmit(ubx->pipe, (const uint8_t *) ubx->script->request, tx_frame_len); in modem_ubx_send_handler()
267 ret = modem_pipe_receive(ubx->pipe, ubx->receive_buf, ubx->receive_buf_size); in modem_ubx_process_handler()
284 int modem_ubx_attach(struct modem_ubx *ubx, struct modem_pipe *pipe) in modem_ubx_attach() argument
290 ubx->pipe = pipe; in modem_ubx_attach()
291 modem_pipe_attach(ubx->pipe, modem_ubx_pipe_callback, ubx); in modem_ubx_attach()
305 modem_pipe_release(ubx->pipe); in modem_ubx_release()
312 ubx->pipe = NULL; in modem_ubx_release()
332 ubx->pipe = NULL; in modem_ubx_init()
|
| /Zephyr-latest/kernel/ |
| D | pipe.c | 17 static inline bool pipe_closed(struct k_pipe *pipe) in pipe_closed() argument
19 return (pipe->flags & PIPE_FLAG_OPEN) == 0; in pipe_closed()
22 static inline bool pipe_resetting(struct k_pipe *pipe) in pipe_resetting() argument
24 return (pipe->flags & PIPE_FLAG_RESET) != 0; in pipe_resetting()
27 static inline bool pipe_full(struct k_pipe *pipe) in pipe_full() argument
29 return ring_buf_space_get(&pipe->buf) == 0; in pipe_full()
32 static inline bool pipe_empty(struct k_pipe *pipe) in pipe_empty() argument
34 return ring_buf_is_empty(&pipe->buf); in pipe_empty()
37 static int wait_for(_wait_q_t *waitq, struct k_pipe *pipe, k_spinlock_key_t *key, in wait_for() argument
47 pipe->waiting++; in wait_for()
[all …]
|
| D | pipes.c | 30 static int pipe_get_internal(k_spinlock_key_t key, struct k_pipe *pipe,
39 void z_impl_k_pipe_init(struct k_pipe *pipe, unsigned char *buffer, size_t size) in z_impl_k_pipe_init() argument
41 pipe->buffer = buffer; in z_impl_k_pipe_init()
42 pipe->size = size; in z_impl_k_pipe_init()
43 pipe->bytes_used = 0U; in z_impl_k_pipe_init()
44 pipe->read_index = 0U; in z_impl_k_pipe_init()
45 pipe->write_index = 0U; in z_impl_k_pipe_init()
46 pipe->lock = (struct k_spinlock){}; in z_impl_k_pipe_init()
47 z_waitq_init(&pipe->wait_q.writers); in z_impl_k_pipe_init()
48 z_waitq_init(&pipe->wait_q.readers); in z_impl_k_pipe_init()
[all …]
|
| /Zephyr-latest/tests/kernel/pipe/pipe_api/src/ |
| D | basic.c | 20 static struct k_pipe pipe; variable
26 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
27 zassert_true(pipe.flags == PIPE_FLAG_OPEN, "Unexpected pipe flags"); in ZTEST()
36 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
37 zassert_true(k_pipe_write(&pipe, &data, 1, K_NO_WAIT) == 1, in ZTEST()
39 zassert_true(k_pipe_read(&pipe, &read_data, 1, K_NO_WAIT) == 1, in ZTEST()
50 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
51 zassert_true(k_pipe_write(&pipe, &data, 1, K_NO_WAIT) == 1, "Failed to write to pipe"); in ZTEST()
52 zassert_true(k_pipe_write(&pipe, &data, 1, K_NO_WAIT) == 1, "Failed to write to pipe"); in ZTEST()
53 zassert_true(k_pipe_read(&pipe, &read_data, 1, K_NO_WAIT) == 1, "Failed to read from pipe"); in ZTEST()
[all …]
|
| D | concurrency.c | 19 static struct k_pipe pipe; variable
53 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
55 thread_close, &pipe, NULL, NULL, K_PRIO_COOP(0), 0, K_MSEC(100)); in ZTEST()
57 zassert_true(k_pipe_read(&pipe, &res, sizeof(res), K_MSEC(1000)) == -EPIPE, in ZTEST()
60 zassert_true((pipe.flags & PIPE_FLAG_OPEN) == 0, in ZTEST()
70 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
71 zassert_true(sizeof(garbage) == k_pipe_write(&pipe, garbage, sizeof(garbage), K_MSEC(1000)), in ZTEST()
75 thread_close, &pipe, NULL, NULL, K_PRIO_COOP(0), 0, K_MSEC(100)); in ZTEST()
77 zassert_true(k_pipe_write(&pipe, garbage, sizeof(garbage), K_MSEC(1000)) == -EPIPE, in ZTEST()
80 zassert_true((pipe.flags & PIPE_FLAG_OPEN) == 0, in ZTEST()
[all …]
|
| D | stress.c | 21 static struct k_pipe pipe; variable
32 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
36 rc = k_pipe_write(&pipe, &buf[sent], len - sent, K_FOREVER); in ZTEST()
53 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
58 rc = k_pipe_write(&pipe, &buf[sent], len - sent, K_FOREVER); in ZTEST()
64 rc = k_pipe_read(&pipe, &buf[read], len - read, K_FOREVER); in ZTEST()
|
| /Zephyr-latest/tests/kernel/pipe/deprecated/pipe_api/src/ |
| D | test_pipe_avail.c | 16 static struct k_pipe pipe = { variable
88 pipe.read_index = 0; in ZTEST()
89 pipe.write_index = 3; in ZTEST()
92 r_avail = k_pipe_read_avail(&pipe); in ZTEST()
95 w_avail = k_pipe_write_avail(&pipe); in ZTEST()
127 pipe.read_index = 3; in ZTEST()
128 pipe.write_index = 0; in ZTEST()
131 r_avail = k_pipe_read_avail(&pipe); in ZTEST()
134 w_avail = k_pipe_write_avail(&pipe); in ZTEST()
170 pipe.read_index = 4; in ZTEST()
[all …]
|
| D | main.c | 17 extern struct k_pipe pipe, kpipe, khalfpipe, put_get_pipe;
25 k_thread_access_grant(k_current_get(), &pipe, in pipe_api_setup()
|
| /Zephyr-latest/include/zephyr/modem/ |
| D | pipe.h | 42 typedef void (*modem_pipe_api_callback)(struct modem_pipe *pipe, enum modem_pipe_event event,
80 void modem_pipe_init(struct modem_pipe *pipe, void *data, const struct modem_pipe_api *api);
99 int modem_pipe_open(struct modem_pipe *pipe, k_timeout_t timeout);
112 int modem_pipe_open_async(struct modem_pipe *pipe);
124 void modem_pipe_attach(struct modem_pipe *pipe, modem_pipe_api_callback callback, void *user_data);
139 int modem_pipe_transmit(struct modem_pipe *pipe, const uint8_t *buf, size_t size);
154 int modem_pipe_receive(struct modem_pipe *pipe, uint8_t *buf, size_t size);
161 void modem_pipe_release(struct modem_pipe *pipe);
176 int modem_pipe_close(struct modem_pipe *pipe, k_timeout_t timeout);
189 int modem_pipe_close_async(struct modem_pipe *pipe);
[all …]
|
| /Zephyr-latest/tests/benchmarks/app_kernel/src/ |
| D | pipe_r.c | 15 int pipeget(struct k_pipe *pipe, enum pipe_options option,
32 int pipe; in piperecvtask() local
39 for (pipe = 0; pipe < 3; pipe++) { in piperecvtask()
41 pipeget(test_pipes[pipe], _ALL_N, getsize, in piperecvtask()
55 for (pipe = 0; pipe < 3; pipe++) { in piperecvtask()
57 pipeget(test_pipes[pipe], _1_TO_N, in piperecvtask()
82 int pipeget(struct k_pipe *pipe, enum pipe_options option, int size, int count, in pipeget() argument
99 sizexferd = k_pipe_read(pipe, data_recv, size2xfer, K_FOREVER); in pipeget()
|
| D | pipe_b.c | 47 int pipeput(struct k_pipe *pipe, enum pipe_options
63 int pipe; in pipe_test() local
93 for (pipe = 0; pipe < 3; pipe++) { in pipe_test()
95 pipeput(test_pipes[pipe], _ALL_N, putsize, putcount, in pipe_test()
96 &puttime[pipe]); in pipe_test()
128 for (pipe = 0; pipe < 3; pipe++) { in pipe_test()
129 pipeput(test_pipes[pipe], _1_TO_N, putsize, in pipe_test()
130 putcount, &puttime[pipe]); in pipe_test()
155 int pipeput(struct k_pipe *pipe, in pipeput() argument
175 sizexferd = k_pipe_write(pipe, data_bench, size2xfer, K_FOREVER); in pipeput()
|
| /Zephyr-latest/tests/ztest/fail/src/ |
| D | main.cpp | 20 auto pipe = popen(FAIL_TARGET_BINARY, "r"); in ZTEST() local
22 zassert_not_null(pipe, "Failed to execute '" FAIL_TARGET_BINARY "'"); in ZTEST()
25 while (!feof(pipe)) { in ZTEST()
26 if (fgets(buffer, ARRAY_SIZE(buffer), pipe) != nullptr) { in ZTEST()
51 auto rc = WEXITSTATUS(pclose(pipe)); in ZTEST()
|
| /Zephyr-latest/scripts/pylib/twister/twisterlib/ |
| D | jobserver.py | 82 self._internal_pipe = os.pipe()
140 pipe = [int(x) for x in match.groups()]
142 pipe = None
149 if pipe:
150 rc = fcntl.fcntl(pipe[0], fcntl.F_GETFL)
156 pipe = None
157 if pipe:
158 rc = fcntl.fcntl(pipe[1], fcntl.F_GETFL)
164 pipe = None
165 if pipe:
[all …]
|
| /Zephyr-latest/doc/kernel/services/data_passing/ |
| D | pipes.rst | 6 A :dfn:`pipe` is a kernel object that allows a thread to send a byte stream
17 Any number of pipes can be defined, limited only by available RAM. Each pipe
20 A pipe has the following key property:
22 * A **size** that indicates the capacity of the pipe's ring buffer. Note that a
23 size of zero defines a pipe with no ring buffer.
25 A pipe must be initialized before it can be used. When initialized, the pipe
28 Threads interact with the pipe as follows:
31 a pipe by a thread. Accepted data is either copied directly to the waiting
32 reader(s) or to the pipe's ring buffer. If the ring buffer is full or simply
37 pipe by a thread. Accepted data is either copied from the pipe's ring buffer
[all …]
|
| /Zephyr-latest/subsys/tracing/test/ |
| D | tracing_test.h | 345 #define sys_port_trace_k_pipe_init(pipe, buffer, size) sys_trace_k_pipe_init(pipe, buffer, size) argument
346 #define sys_port_trace_k_pipe_reset_enter(pipe) sys_trace_k_pipe_reset_enter(pipe) argument
347 #define sys_port_trace_k_pipe_reset_exit(pipe) sys_trace_k_pipe_reset_exit(pipe) argument
348 #define sys_port_trace_k_pipe_close_enter(pipe) sys_trace_k_pipe_close_enter(pipe) argument
349 #define sys_port_trace_k_pipe_close_exit(pipe) sys_trace_k_pipe_close_exit(pipe) argument
350 #define sys_port_trace_k_pipe_write_enter(pipe, data, len, timeout) \ argument
351 sys_trace_k_pipe_write_enter(pipe, data, len, timeout)
352 #define sys_port_trace_k_pipe_write_blocking(pipe, timeout) \ argument
353 sys_trace_k_pipe_write_blocking(pipe, timeout)
354 #define sys_port_trace_k_pipe_write_exit(pipe, ret) \ argument
[all …]
|
| /Zephyr-latest/tests/subsys/modem/backends/uart/src/ |
| D | main.c | 33 static struct modem_pipe *pipe; variable
47 static void modem_pipe_callback_handler(struct modem_pipe *pipe, enum modem_pipe_event event, in modem_pipe_callback_handler() argument
122 ret = modem_pipe_transmit(pipe, reserved, transmit_size); in transmit_prng()
137 ret = modem_pipe_receive(pipe, receive_buffer, sizeof(receive_buffer)); in receive_prng()
165 pipe = modem_backend_uart_init(&uart_backend, &config); in test_modem_backend_uart_setup()
166 modem_pipe_attach(pipe, modem_pipe_callback_handler, NULL); in test_modem_backend_uart_setup()
175 __ASSERT_NO_MSG(modem_pipe_open(pipe, K_SECONDS(10)) == 0); in test_modem_backend_uart_before()
180 __ASSERT_NO_MSG(modem_pipe_close(pipe, K_SECONDS(10)) == 0); in test_modem_backend_uart_after()
|
| /Zephyr-latest/subsys/modem/backends/ |
| D | modem_backend_uart.c | 19 modem_pipe_notify_receive_ready(&backend->pipe); in modem_backend_uart_receive_ready_handler()
27 modem_pipe_notify_transmit_idle(&backend->pipe); in modem_backend_uart_transmit_idle_handler()
49 return &backend->pipe; in modem_backend_uart_init()
56 return &backend->pipe; in modem_backend_uart_init()
|
| D | modem_backend_tty.c | 45 modem_pipe_notify_receive_ready(&backend->pipe); in modem_backend_tty_routine()
69 modem_pipe_notify_opened(&backend->pipe); in modem_backend_tty_open()
79 modem_pipe_notify_transmit_idle(&backend->pipe); in modem_backend_tty_transmit()
102 modem_pipe_notify_closed(&backend->pipe); in modem_backend_tty_close()
125 modem_pipe_init(&backend->pipe, backend, &modem_backend_tty_api); in modem_backend_tty_init()
126 return &backend->pipe; in modem_backend_tty_init()
|
| /Zephyr-latest/include/zephyr/tracing/ |
| D | tracing.h | 1564 #define sys_port_trace_k_pipe_init(pipe, buffer, size) argument
1570 #define sys_port_trace_k_pipe_reset_enter(pipe) argument
1576 #define sys_port_trace_k_pipe_reset_exit(pipe) argument
1582 #define sys_port_trace_k_pipe_close_enter(pipe) argument
1588 #define sys_port_trace_k_pipe_close_exit(pipe) argument
1597 #define sys_port_trace_k_pipe_write_enter(pipe, data, len, timeout) argument
1604 #define sys_port_trace_k_pipe_write_blocking(pipe, timeout) argument
1611 #define sys_port_trace_k_pipe_write_exit(pipe, ret) argument
1620 #define sys_port_trace_k_pipe_read_enter(pipe, data, len, timeout) argument
1627 #define sys_port_trace_k_pipe_read_blocking(pipe, timeout) argument
[all …]
|
| /Zephyr-latest/tests/subsys/modem/mock/ |
| D | modem_backend_mock.c | 15 modem_pipe_notify_opened(&mock->pipe); in modem_backend_mock_open()
79 modem_pipe_notify_closed(&mock->pipe); in modem_backend_mock_close()
95 modem_pipe_notify_receive_ready(&mock->pipe); in modem_backend_mock_receive_ready_handler()
103 modem_pipe_notify_transmit_idle(&mock->pipe); in modem_backend_mock_transmit_idle_handler()
116 modem_pipe_init(&mock->pipe, mock, &modem_backend_mock_api); in modem_backend_mock_init()
117 return &mock->pipe; in modem_backend_mock_init()
122 return &mock->pipe; in modem_backend_mock_get_pipe()
|
| /Zephyr-latest/tests/subsys/modem/modem_pipe/src/ |
| D | main.c | 27 struct modem_pipe pipe; member
52 modem_pipe_notify_opened(&backend->pipe); in modem_backend_fake_opened_handler()
62 modem_pipe_notify_opened(&backend->pipe); in modem_backend_fake_open()
76 modem_pipe_notify_transmit_idle(&backend->pipe); in modem_backend_fake_transmit_idle_handler()
88 modem_pipe_notify_transmit_idle(&backend->pipe); in modem_backend_fake_transmit()
112 modem_pipe_notify_closed(&backend->pipe); in modem_backend_fake_closed_handler()
122 modem_pipe_notify_closed(&backend->pipe); in modem_backend_fake_close()
146 modem_pipe_init(&backend->pipe, backend, &modem_backend_fake_api); in modem_backend_fake_init()
147 return &backend->pipe; in modem_backend_fake_init()
180 static void modem_pipe_fake_handler(struct modem_pipe *pipe, enum modem_pipe_event event, in modem_pipe_fake_handler() argument
[all …]
|
| /Zephyr-latest/subsys/tracing/user/ |
| D | tracing_user.h | 326 #define sys_port_trace_k_pipe_init(pipe, buffer, size) argument
327 #define sys_port_trace_k_pipe_reset_enter(pipe) argument
328 #define sys_port_trace_k_pipe_reset_exit(pipe) argument
329 #define sys_port_trace_k_pipe_close_enter(pipe) argument
330 #define sys_port_trace_k_pipe_close_exit(pipe) argument
331 #define sys_port_trace_k_pipe_write_enter(pipe, data, len, timeout) argument
332 #define sys_port_trace_k_pipe_write_blocking(pipe, timeout) argument
333 #define sys_port_trace_k_pipe_write_exit(pipe, ret) argument
334 #define sys_port_trace_k_pipe_read_enter(pipe, data, len, timeout) argument
335 #define sys_port_trace_k_pipe_read_blocking(pipe, timeout) argument
[all …]
|
| /Zephyr-latest/tests/kernel/pipe/deprecated/pipe/src/ |
| D | test_pipe.c | 728 ZTEST_USER(pipe, test_pipe_on_single_elements) in ZTEST_USER() argument
754 ZTEST_USER(pipe, test_pipe_on_multiple_elements) in ZTEST_USER() argument
772 ZTEST_USER(pipe, test_pipe_forever_wait) in ZTEST_USER() argument
823 ZTEST_USER(pipe, test_pipe_timeout) in ZTEST_USER() argument
841 ZTEST_USER(pipe, test_pipe_get_on_empty_pipe) in ZTEST_USER() argument
854 ZTEST_USER(pipe, test_pipe_forever_timeout) in ZTEST_USER() argument
873 ZTEST_USER(pipe, test_pipe_get_timeout) in ZTEST_USER() argument
885 ZTEST_USER(pipe, test_pipe_get_invalid_size) in ZTEST_USER() argument
904 ZTEST_USER(pipe, test_pipe_get_min_xfer) in ZTEST_USER() argument
927 ZTEST_USER(pipe, test_pipe_put_min_xfer) in ZTEST_USER() argument
[all …]
|
