Lines Matching full:remote
36 * endpoint) are said to be 'remote'.
43 * - write operations may block if the remote @a recv_q is full
47 int remote; /**< the remote endpoint file descriptor */ member
77 const struct spair *remote = z_get_fd_obj(spair->remote, in sock_is_connected() local
80 if (remote == NULL) { in sock_is_connected()
102 struct spair *const remote = z_get_fd_obj(spair->remote, in spair_write_avail() local
105 if (remote == NULL) { in spair_write_avail()
109 return k_pipe_write_avail(&remote->recv_q); in spair_write_avail()
147 * T1 waits on A's write signal. T2 triggers the remote
153 * If the remote endpoint is already closed, the former operation does not
154 * take place. Otherwise, the @ref spair.remote of the local endpoint is
164 struct spair *remote = NULL; in spair_delete() local
171 if (spair->remote != -1) { in spair_delete()
172 remote = z_get_fd_obj(spair->remote, in spair_delete()
175 if (remote != NULL) { in spair_delete()
176 res = k_sem_take(&remote->sem, K_FOREVER); in spair_delete()
179 remote->remote = -1; in spair_delete()
180 res = k_poll_signal_raise(&remote->readable, in spair_delete()
189 spair->remote = -1; in spair_delete()
194 if (remote != NULL && have_remote_sem) { in spair_delete()
195 k_sem_give(&remote->sem); in spair_delete()
213 * @ref spair.remote field initially.
215 * If both allocations are successful, then swap the @ref spair.remote
249 spair->remote = -1; in spair_new()
261 spair->remote = z_reserve_fd(); in spair_new()
262 if (spair->remote == -1) { in spair_new()
267 z_finalize_fd(spair->remote, spair, in spair_new()
320 swap32(&obj[0]->remote, &obj[1]->remote); in z_impl_zsock_socketpair()
323 sv[i] = obj[i]->remote; in z_impl_zsock_socketpair()
375 * set and there is insufficient space in the @em remote @ref spair.pipe.
378 * one of two possible results is received on the @em remote
381 * 1) @ref SPAIR_SIG_DATA - data has been read from the @em remote
384 * 2) @ref SPAIR_SIG_CANCEL - the @em remote socketpair endpoint was closed
406 struct spair *remote = NULL; in spair_write() local
434 remote = z_get_fd_obj(spair->remote, in spair_write()
437 if (remote == NULL) { in spair_write()
443 res = k_sem_take(&remote->sem, K_NO_WAIT); in spair_write()
450 res = k_sem_take(&remote->sem, K_FOREVER); in spair_write()
485 &remote->writeable), in spair_write()
488 k_sem_give(&remote->sem); in spair_write()
498 remote = z_get_fd_obj(spair->remote, in spair_write()
502 if (remote == NULL) { in spair_write()
508 res = k_sem_take(&remote->sem, K_FOREVER); in spair_write()
517 k_poll_signal_check(&remote->writeable, &signaled, in spair_write()
547 res = k_pipe_put(&remote->recv_q, (void *)buffer, count, in spair_write()
552 k_poll_signal_reset(&remote->writeable); in spair_write()
555 res = k_poll_signal_raise(&remote->readable, SPAIR_SIG_DATA); in spair_write()
562 if (remote != NULL && have_remote_sem) { in spair_write()
563 k_sem_give(&remote->sem); in spair_write()
752 struct spair *remote = NULL; in zsock_poll_prepare_ctx() local
785 remote = z_get_fd_obj(spair->remote, in zsock_poll_prepare_ctx()
789 __ASSERT(remote != NULL, "remote is NULL"); in zsock_poll_prepare_ctx()
791 res = k_sem_take(&remote->sem, K_FOREVER); in zsock_poll_prepare_ctx()
798 /* Wait until the recv queue on the remote end is no longer full */ in zsock_poll_prepare_ctx()
799 (*pev)->obj = &remote->writeable; in zsock_poll_prepare_ctx()
812 if (remote != NULL && have_remote_sem) { in zsock_poll_prepare_ctx()
813 k_sem_give(&remote->sem); in zsock_poll_prepare_ctx()
826 struct spair *remote = NULL; in zsock_poll_update_ctx() local
835 remote = z_get_fd_obj(spair->remote, in zsock_poll_update_ctx()
838 __ASSERT(remote != NULL, "remote is NULL"); in zsock_poll_update_ctx()
840 res = k_sem_take(&remote->sem, K_FOREVER); in zsock_poll_update_ctx()
855 k_poll_signal_check(&remote->writeable, &signaled, &result); in zsock_poll_update_ctx()
899 if (remote != NULL && have_remote_sem) { in zsock_poll_update_ctx()
900 k_sem_give(&remote->sem); in zsock_poll_update_ctx()
923 * function call requires the remote sem, it must acquire and free the in spair_ioctl()
924 * remote sem. in spair_ioctl()
1172 /* disconnect the remote endpoint */ in spair_close()