17     MPP_RET ret = MPP_OK;  in task_input()  local
24         ret = mpp_port_poll(port, MPP_POLL_BLOCK);  in task_input()
25         mpp_assert(ret >= 0);  in task_input()
27         ret = mpp_port_dequeue(port, &task);  in task_input()
28         mpp_assert(!ret);  in task_input()
31         ret = mpp_port_enqueue(port, task);  in task_input()
32         mpp_assert(!ret);  in task_input()
45     MPP_RET ret = MPP_OK;  in task_output()  local
52         ret = mpp_port_poll(port, MPP_POLL_BLOCK);  in task_output()
53         mpp_assert(ret >= 0);  in task_output()
55         ret = mpp_port_dequeue(port, &task);  in task_output()
56         mpp_assert(!ret);  in task_output()
59         ret = mpp_port_enqueue(port, task);  in task_output()
60         mpp_assert(!ret);  in task_output()
73     MPP_RET ret = MPP_OK;  in task_in_and_out()  local
78         ret = mpp_port_poll(port_input, MPP_POLL_BLOCK);  in task_in_and_out()
79         mpp_assert(ret >= 0);  in task_in_and_out()
81         ret = mpp_port_dequeue(port_input, &task);  in task_in_and_out()
82         mpp_assert(!ret);  in task_in_and_out()
85         ret = mpp_port_enqueue(port_input, task);  in task_in_and_out()
86         mpp_assert(!ret);  in task_in_and_out()
89         ret = mpp_port_poll(port_output, MPP_POLL_BLOCK);  in task_in_and_out()
90         mpp_assert(ret >= 0);  in task_in_and_out()
92         ret = mpp_port_dequeue(port_output, &task);  in task_in_and_out()
93         mpp_assert(!ret);  in task_in_and_out()
96         ret = mpp_port_enqueue(port_output, task);  in task_in_and_out()
97         mpp_assert(!ret);  in task_in_and_out()
108     MPP_RET ret = MPP_OK;  in task_worker()  local
113         ret = mpp_port_poll(port_src, MPP_POLL_BLOCK);  in task_worker()
114         mpp_assert(ret >= 0);  in task_worker()
116         ret = mpp_port_dequeue(port_src, &task);  in task_worker()
117         mpp_assert(!ret);  in task_worker()
120         ret = mpp_port_enqueue(port_src, task);  in task_worker()
121         mpp_assert(!ret);  in task_worker()
123         ret = mpp_port_poll(port_dst, MPP_POLL_BLOCK);  in task_worker()
124         mpp_assert(ret >= 0);  in task_worker()
126         ret = mpp_port_dequeue(port_dst, &task);  in task_worker()
127         mpp_assert(!ret);  in task_worker()
130         ret = mpp_port_enqueue(port_dst, task);  in task_worker()
131         mpp_assert(!ret);  in task_worker()
142     MPP_RET ret = MPP_OK;  in serial_task()  local
149         ret = mpp_port_poll(port_ii, MPP_POLL_BLOCK);  in serial_task()
150         mpp_assert(ret >= 0);  in serial_task()
152         ret = mpp_port_dequeue(port_ii, &task);  in serial_task()
153         mpp_assert(!ret);  in serial_task()
156         ret = mpp_port_enqueue(port_ii, task);  in serial_task()
157         mpp_assert(!ret);  in serial_task()
160         ret = mpp_port_poll(port_io, MPP_POLL_BLOCK);  in serial_task()
161         mpp_assert(ret >= 0);  in serial_task()
163         ret = mpp_port_dequeue(port_io, &task);  in serial_task()
164         mpp_assert(!ret);  in serial_task()
167         ret = mpp_port_enqueue(port_io, task);  in serial_task()
168         mpp_assert(!ret);  in serial_task()
171         ret = mpp_port_poll(port_oi, MPP_POLL_BLOCK);  in serial_task()
172         mpp_assert(ret >= 0);  in serial_task()
174         ret = mpp_port_dequeue(port_oi, &task);  in serial_task()
175         mpp_assert(!ret);  in serial_task()
178         ret = mpp_port_enqueue(port_oi, task);  in serial_task()
179         mpp_assert(!ret);  in serial_task()
182         ret = mpp_port_poll(port_oo, MPP_POLL_BLOCK);  in serial_task()
183         mpp_assert(ret >= 0);  in serial_task()
185         ret = mpp_port_dequeue(port_oo, &task);  in serial_task()
186         mpp_assert(!ret);  in serial_task()
189         ret = mpp_port_enqueue(port_oo, task);  in serial_task()
190         mpp_assert(!ret);  in serial_task()