Lines Matching refs:res
163 int res; in spair_delete() local
176 res = k_sem_take(&remote->sem, K_FOREVER); in spair_delete()
177 if (res == 0) { in spair_delete()
180 res = k_poll_signal_raise(&remote->readable, in spair_delete()
182 __ASSERT(res == 0, in spair_delete()
184 res); in spair_delete()
191 res = k_poll_signal_raise(&spair->writeable, SPAIR_SIG_CANCEL); in spair_delete()
192 __ASSERT(res == 0, "k_poll_signal_raise() failed: %d", res); in spair_delete()
221 int res; in spair_new() local
225 res = k_mem_slab_alloc(&spair_slab, (void **) &spair, K_NO_WAIT); in spair_new()
226 if (res != 0) { in spair_new()
258 res = k_poll_signal_raise(&spair->writeable, SPAIR_SIG_DATA); in spair_new()
259 __ASSERT(res == 0, "k_poll_signal_raise() failed: %d", res); in spair_new()
282 int res; in z_impl_zsock_socketpair() local
290 res = -1; in z_impl_zsock_socketpair()
296 res = -1; in z_impl_zsock_socketpair()
302 res = -1; in z_impl_zsock_socketpair()
309 res = -1; in z_impl_zsock_socketpair()
316 res = -1; in z_impl_zsock_socketpair()
341 return res; in z_impl_zsock_socketpair()
404 int res; in spair_write() local
416 res = -1; in spair_write()
420 res = k_sem_take(&spair->sem, K_NO_WAIT); in spair_write()
422 if (res < 0) { in spair_write()
425 res = -1; in spair_write()
429 res = k_sem_take(&spair->sem, K_FOREVER); in spair_write()
430 if (res < 0) { in spair_write()
431 errno = -res; in spair_write()
432 res = -1; in spair_write()
445 res = -1; in spair_write()
449 res = k_sem_take(&remote->sem, K_NO_WAIT); in spair_write()
450 if (res < 0) { in spair_write()
453 res = -1; in spair_write()
456 res = k_sem_take(&remote->sem, K_FOREVER); in spair_write()
457 if (res < 0) { in spair_write()
458 errno = -res; in spair_write()
459 res = -1; in spair_write()
471 res = -1; in spair_write()
480 res = -1; in spair_write()
497 res = k_poll(events, ARRAY_SIZE(events), K_FOREVER); in spair_write()
498 if (res < 0) { in spair_write()
499 errno = -res; in spair_write()
500 res = -1; in spair_write()
510 res = -1; in spair_write()
514 res = k_sem_take(&remote->sem, K_FOREVER); in spair_write()
515 if (res < 0) { in spair_write()
516 errno = -res; in spair_write()
517 res = -1; in spair_write()
536 res = -1; in spair_write()
558 res = k_poll_signal_raise(&remote->readable, SPAIR_SIG_DATA); in spair_write()
559 __ASSERT(res == 0, "k_poll_signal_raise() failed: %d", res); in spair_write()
561 res = bytes_written; in spair_write()
572 return res; in spair_write()
611 int res; in spair_read() local
622 res = -1; in spair_read()
626 res = k_sem_take(&spair->sem, K_NO_WAIT); in spair_read()
628 if (res < 0) { in spair_read()
631 res = -1; in spair_read()
635 res = k_sem_take(&spair->sem, K_FOREVER); in spair_read()
636 if (res < 0) { in spair_read()
637 errno = -res; in spair_read()
638 res = -1; in spair_read()
652 res = 0; in spair_read()
658 res = -1; in spair_read()
668 res = -1; in spair_read()
686 res = k_poll(events, ARRAY_SIZE(events), K_FOREVER); in spair_read()
687 __ASSERT(res == 0, "k_poll() failed: %d", res); in spair_read()
689 res = k_sem_take(&spair->sem, K_FOREVER); in spair_read()
690 __ASSERT(res == 0, "failed to take local sem: %d", res); in spair_read()
707 res = -1; in spair_read()
730 res = k_poll_signal_raise(&spair->writeable, SPAIR_SIG_DATA); in spair_read()
731 __ASSERT(res == 0, "k_poll_signal_raise() failed: %d", res); in spair_read()
734 res = bytes_read; in spair_read()
742 return res; in spair_read()
750 int res; in zsock_poll_prepare_ctx() local
759 res = -EALREADY; in zsock_poll_prepare_ctx()
764 res = -ENOMEM; in zsock_poll_prepare_ctx()
776 res = -EALREADY; in zsock_poll_prepare_ctx()
781 res = -ENOMEM; in zsock_poll_prepare_ctx()
791 res = k_sem_take(&remote->sem, K_FOREVER); in zsock_poll_prepare_ctx()
792 if (res < 0) { in zsock_poll_prepare_ctx()
808 res = 0; in zsock_poll_prepare_ctx()
816 return res; in zsock_poll_prepare_ctx()
823 int res; in zsock_poll_update_ctx() local
840 res = k_sem_take(&remote->sem, K_FOREVER); in zsock_poll_update_ctx()
841 if (res < 0) { in zsock_poll_update_ctx()
895 res = 0; in zsock_poll_update_ctx()
903 return res; in zsock_poll_update_ctx()
908 int res; in spair_ioctl() local
918 res = -1; in spair_ioctl()
926 res = k_sem_take(&spair->sem, K_FOREVER); in spair_ioctl()
927 __ASSERT(res == 0, "failed to take local sem: %d", res); in spair_ioctl()
937 res = flags; in spair_ioctl()
950 res = 0; in spair_ioctl()
956 res = 0; in spair_ioctl()
966 res = 0; in spair_ioctl()
975 res = zsock_poll_prepare_ctx(obj, pfd, pev, pev_end); in spair_ioctl()
983 res = zsock_poll_update_ctx(obj, pfd, pev); in spair_ioctl()
989 res = -1; in spair_ioctl()
999 return res; in spair_ioctl()
1060 int res; in spair_sendmsg() local
1069 res = -1; in spair_sendmsg()
1085 res = -1; in spair_sendmsg()
1090 res = 0; in spair_sendmsg()
1096 res = -1; in spair_sendmsg()
1101 res = spair_write(spair, msg->msg_iov[i].iov_base, in spair_sendmsg()
1103 if (res == -1) { in spair_sendmsg()
1108 res = len; in spair_sendmsg()
1111 return res; in spair_sendmsg()
1167 int res; in spair_close() local
1171 res = k_sem_take(&spair->sem, K_FOREVER); in spair_close()
1172 __ASSERT(res == 0, "failed to take local sem: %d", res); in spair_close()