Home
last modified time | relevance | path

Searched refs:k_pipe (Results 1 – 25 of 34) sorted by relevance

12

/Zephyr-latest/kernel/
Dpipe.c17 static inline bool pipe_closed(struct k_pipe *pipe) in pipe_closed()
22 static inline bool pipe_resetting(struct k_pipe *pipe) in pipe_resetting()
27 static inline bool pipe_full(struct k_pipe *pipe) in pipe_full()
32 static inline bool pipe_empty(struct k_pipe *pipe) in pipe_empty()
37 static int wait_for(_wait_q_t *waitq, struct k_pipe *pipe, k_spinlock_key_t *key, in wait_for()
50 SYS_PORT_TRACING_OBJ_FUNC_BLOCKING(k_pipe, write, pipe, timeout); in wait_for()
52 SYS_PORT_TRACING_OBJ_FUNC_BLOCKING(k_pipe, read, pipe, timeout); in wait_for()
67 void z_impl_k_pipe_init(struct k_pipe *pipe, uint8_t *buffer, size_t buffer_size) in z_impl_k_pipe_init()
84 SYS_PORT_TRACING_OBJ_INIT(k_pipe, pipe, buffer, buffer_size); in z_impl_k_pipe_init()
93 static size_t copy_to_pending_readers(struct k_pipe *pipe, bool *need_resched, in copy_to_pending_readers()
[all …]
Dpipes.c30 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()
49 SYS_PORT_TRACING_OBJ_INIT(k_pipe, pipe, buffer, size); in z_impl_k_pipe_init()
63 int z_impl_k_pipe_alloc_init(struct k_pipe *pipe, size_t size) in z_impl_k_pipe_alloc_init()
68 SYS_PORT_TRACING_OBJ_FUNC_ENTER(k_pipe, alloc_init, pipe); in z_impl_k_pipe_alloc_init()
84 SYS_PORT_TRACING_OBJ_FUNC_EXIT(k_pipe, alloc_init, pipe, ret); in z_impl_k_pipe_alloc_init()
90 static inline void z_vrfy_k_pipe_init(struct k_pipe *pipe, unsigned char *buffer, size_t size) in z_vrfy_k_pipe_init()
99 static inline int z_vrfy_k_pipe_alloc_init(struct k_pipe *pipe, size_t size) in z_vrfy_k_pipe_alloc_init()
108 static inline bool handle_poll_events(struct k_pipe *pipe) in handle_poll_events()
118 void z_impl_k_pipe_flush(struct k_pipe *pipe) in z_impl_k_pipe_flush()
[all …]
/Zephyr-latest/tests/kernel/pipe/deprecated/pipe_api/src/
Dtest_pipe_fail.c15 struct k_pipe put_get_pipe;
17 static void put_fail(struct k_pipe *p) in put_fail()
55 struct k_pipe *p = k_object_alloc(K_OBJ_PIPE); in ZTEST_USER()
68 static void get_fail(struct k_pipe *p) in get_fail()
108 struct k_pipe *p = k_object_alloc(K_OBJ_PIPE); in ZTEST_USER()
128 struct k_pipe pipe; in ZTEST_USER()
166 struct k_pipe *p = k_object_alloc(K_OBJ_PIPE); in ZTEST_USER()
190 struct k_pipe *p = k_object_alloc(K_OBJ_PIPE); in ZTEST_USER()
234 struct k_pipe *p = k_object_alloc(K_OBJ_PIPE); in ZTEST_USER()
258 struct k_pipe *p = k_object_alloc(K_OBJ_PIPE); in ZTEST_USER()
Dtest_pipe_contexts.c26 struct k_pipe pipe, pipe1;
47 static void tpipe_put(struct k_pipe *ppipe, k_timeout_t timeout) in tpipe_put()
61 static void tpipe_get(struct k_pipe *ppipe, k_timeout_t timeout) in tpipe_get()
82 tpipe_get((struct k_pipe *)p1, K_FOREVER); in tThread_entry()
85 tpipe_put((struct k_pipe *)p1, K_NO_WAIT); in tThread_entry()
89 static void tpipe_thread_thread(struct k_pipe *ppipe) in tpipe_thread_thread()
107 static void tpipe_kthread_to_kthread(struct k_pipe *ppipe) in tpipe_kthread_to_kthread()
124 static void tpipe_put_no_wait(struct k_pipe *ppipe) in tpipe_put_no_wait()
138 static void tpipe_put_small_size(struct k_pipe *ppipe, k_timeout_t timeout) in tpipe_put_small_size()
151 static void tpipe_get_small_size(struct k_pipe *ppipe, k_timeout_t timeout) in tpipe_get_small_size()
[all …]
Dtest_pipe_avail.c16 static struct k_pipe pipe = {
21 static struct k_pipe bufferless;
23 static struct k_pipe bufferless1 = {
Dmain.c17 extern struct k_pipe pipe, kpipe, khalfpipe, put_get_pipe;
/Zephyr-latest/tests/benchmarks/app_kernel/src/
Dmaster.h53 extern struct k_pipe *test_pipes[];
102 extern struct k_pipe PIPE_NOBUFF;
103 extern struct k_pipe PIPE_SMALLBUFF;
104 extern struct k_pipe PIPE_BIGBUFF;
Dpipe_r.c15 int pipeget(struct k_pipe *pipe, enum pipe_options option,
82 int pipeget(struct k_pipe *pipe, enum pipe_options option, int size, int count, in pipeget()
Dpipe_b.c47 int pipeput(struct k_pipe *pipe, enum pipe_options
155 int pipeput(struct k_pipe *pipe, in pipeput()
Dmaster.c26 BENCH_DMEM struct k_pipe *test_pipes[] = {&PIPE_NOBUFF, &PIPE_SMALLBUFF, &PIPE_BIGBUFF};
/Zephyr-latest/tests/kernel/pipe/deprecated/pipe/src/
Dmain.c9 extern struct k_pipe test_pipe;
10 extern struct k_pipe small_pipe;
Dtest_pipe.c991 struct k_pipe pipe; in ZTEST()
1044 struct k_pipe *pipe = (struct k_pipe *)p1; in test_pipe_flush_helper()
/Zephyr-latest/subsys/tracing/
Dtracing_tracking.c34 struct k_pipe *_track_list_k_pipe;
104 void sys_track_k_pipe_init(struct k_pipe *pipe, void *buffer, size_t size) in sys_track_k_pipe_init()
109 SYS_PORT_TRACING_TYPE_MASK(k_pipe, in sys_track_k_pipe_init()
161 SYS_PORT_TRACING_TYPE_MASK(k_pipe, in sys_track_static_init()
162 SYS_TRACK_STATIC_INIT(k_pipe, NULL, 0)); in sys_track_static_init()
/Zephyr-latest/tests/kernel/pipe/pipe_api/src/
Dconcurrency.c19 static struct k_pipe pipe;
23 k_pipe_close((struct k_pipe *)arg1); in thread_close()
28 k_pipe_reset((struct k_pipe *)arg1); in thread_reset()
35 zassert_true(k_pipe_write((struct k_pipe *)arg1, garbage, sizeof(garbage), in thread_write()
43 zassert_true(k_pipe_read((struct k_pipe *)arg1, garbage, sizeof(garbage), in thread_read()
Dstress.c21 static struct k_pipe pipe;
Dbasic.c20 static struct k_pipe pipe;
/Zephyr-latest/subsys/tracing/test/
Dtracing_test.h642 void sys_trace_k_pipe_init(struct k_pipe *pipe, unsigned char *buffer, size_t size);
643 void sys_trace_k_pipe_reset_enter(struct k_pipe *pipe);
644 void sys_trace_k_pipe_reset_exit(struct k_pipe *pipe);
645 void sys_trace_k_pipe_close_enter(struct k_pipe *pipe);
646 void sys_trace_k_pipe_close_exit(struct k_pipe *pipe);
647 void sys_trace_k_pipe_write_enter(struct k_pipe *pipe, const void *data, size_t len,
649 void sys_trace_k_pipe_write_blocking(struct k_pipe *pipe, k_timeout_t timeout);
650 void sys_trace_k_pipe_write_exit(struct k_pipe *pipe, int ret);
651 void sys_trace_k_pipe_read_enter(struct k_pipe *pipe, const void *data, size_t len,
653 void sys_trace_k_pipe_read_blocking(struct k_pipe *pipe, k_timeout_t timeout);
[all …]
/Zephyr-latest/include/zephyr/
Dkernel.h77 struct k_pipe;
5005 __syscall void k_pipe_init(struct k_pipe *pipe, uint8_t *buffer, size_t buffer_size);
5009 struct k_pipe { struct
5026 SYS_PORT_TRACING_TRACKING_FIELD(k_pipe) argument
5074 STRUCT_SECTION_ITERABLE(k_pipe, name) = \
5089 __deprecated int k_pipe_cleanup(struct k_pipe *pipe);
5107 __deprecated __syscall int k_pipe_alloc_init(struct k_pipe *pipe, size_t size);
5128 __deprecated __syscall int k_pipe_put(struct k_pipe *pipe, const void *data,
5152 __deprecated __syscall int k_pipe_get(struct k_pipe *pipe, void *data,
5165 __deprecated __syscall size_t k_pipe_read_avail(struct k_pipe *pipe);
[all …]
/Zephyr-latest/include/zephyr/tracing/
Dtracking.h44 extern struct k_pipe *_track_list_k_pipe;
108 void sys_track_k_pipe_init(struct k_pipe *pipe, void *buffer, size_t size);
/Zephyr-latest/tests/kernel/obj_tracking/src/
Dmain.c39 struct k_pipe pipe; in ZTEST()
129 list = SYS_PORT_TRACK_NEXT((struct k_pipe *)list); in ZTEST()
/Zephyr-latest/tests/kernel/mutex/mutex_error_case/src/
Dtest_mutex_error.c18 static struct k_pipe pipe;
/Zephyr-latest/cmake/sca/eclair/ECL/
Dextra.ecl71 …_data|k_timer|k_mem_slab|k_mem_pool|k_heap|k_mutex|k_stack|k_msgq|k_mbox|k_pipe|k_sem|k_queue)_lis…
/Zephyr-latest/include/zephyr/linker/
Dcommon-ram.ld83 ITERABLE_SECTION_RAM_GC_ALLOWED(k_pipe, Z_LINK_ITERABLE_SUBALIGN)
/Zephyr-latest/doc/kernel/services/data_passing/
Dpipes.rst51 A pipe is defined using a variable of type :c:struct:`k_pipe` and a
60 struct k_pipe my_pipe;
/Zephyr-latest/tests/kernel/obj_core/obj_core/src/
Dmain.c30 static struct k_pipe pipe2;

12