Lines Matching refs:pipe

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()
90 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
93 thread_reset, &pipe, NULL, NULL, K_PRIO_COOP(0), 0, K_MSEC(100)); in ZTEST()
95 zassert_true(k_pipe_read(&pipe, &res, sizeof(res), K_MSEC(1000)) == -ECANCELED, in ZTEST()
98 zassert_true((pipe.flags & PIPE_FLAG_RESET) == 0, in ZTEST()
100 zassert_true((pipe.flags & PIPE_FLAG_OPEN) != 0, in ZTEST()
110 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
111 zassert_true(sizeof(garbage) == k_pipe_write(&pipe, garbage, sizeof(garbage), K_MSEC(1000)), in ZTEST()
115 thread_reset, &pipe, NULL, NULL, K_PRIO_COOP(0), 0, K_MSEC(100)); in ZTEST()
117 zassert_true(k_pipe_write(&pipe, garbage, sizeof(garbage), K_MSEC(1000)) == -ECANCELED, in ZTEST()
120 zassert_true((pipe.flags & PIPE_FLAG_RESET) == 0, in ZTEST()
122 zassert_true((pipe.flags & PIPE_FLAG_OPEN) != 0, in ZTEST()
133 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
135 thread_read, &pipe, NULL, NULL, K_PRIO_COOP(0), 0, K_NO_WAIT); in ZTEST()
137 zassert_true(k_pipe_write(&pipe, garbage, write_size, K_NO_WAIT) == write_size, in ZTEST()
140 zassert_true(k_pipe_write(&pipe, garbage, write_size, K_NO_WAIT) == write_size, in ZTEST()
152 k_pipe_init(&pipe, buffer, sizeof(buffer)); in ZTEST()
154 zassert_true(k_pipe_write(&pipe, garbage, sizeof(garbage), K_NO_WAIT) == sizeof(garbage), in ZTEST()
157 thread_write, &pipe, NULL, NULL, K_PRIO_COOP(0), 0, K_NO_WAIT); in ZTEST()
159 zassert_true(k_pipe_read(&pipe, garbage, read_size, K_NO_WAIT) == read_size, in ZTEST()
162 zassert_true(k_pipe_read(&pipe, garbage, read_size, K_NO_WAIT) == read_size, in ZTEST()