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 = zvfs_get_fd_obj(spair->remote, in sock_is_connected() local
80 if (remote == NULL) { in sock_is_connected()
102 struct spair *const remote = zvfs_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 = zvfs_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 = zvfs_reserve_fd(); in spair_new()
262 if (spair->remote == -1) { in spair_new()
267 zvfs_finalize_typed_fd(spair->remote, spair, in spair_new()
322 swap32(&obj[0]->remote, &obj[1]->remote); in z_impl_zsock_socketpair()
325 sv[i] = obj[i]->remote; in z_impl_zsock_socketpair()
381 * set and there is insufficient space in the @em remote @ref spair.pipe.
384 * one of two possible results is received on the @em remote
387 * 1) @ref SPAIR_SIG_DATA - data has been read from the @em remote
390 * 2) @ref SPAIR_SIG_CANCEL - the @em remote socketpair endpoint was closed
412 struct spair *remote = NULL; in spair_write() local
440 remote = zvfs_get_fd_obj(spair->remote, in spair_write()
443 if (remote == NULL) { in spair_write()
449 res = k_sem_take(&remote->sem, K_NO_WAIT); in spair_write()
456 res = k_sem_take(&remote->sem, K_FOREVER); in spair_write()
491 &remote->writeable), in spair_write()
494 k_sem_give(&remote->sem); in spair_write()
504 remote = zvfs_get_fd_obj(spair->remote, in spair_write()
508 if (remote == NULL) { in spair_write()
514 res = k_sem_take(&remote->sem, K_FOREVER); in spair_write()
523 k_poll_signal_check(&remote->writeable, &signaled, in spair_write()
553 res = k_pipe_put(&remote->recv_q, (void *)buffer, count, in spair_write()
558 k_poll_signal_reset(&remote->writeable); in spair_write()
561 res = k_poll_signal_raise(&remote->readable, SPAIR_SIG_DATA); in spair_write()
568 if (remote != NULL && have_remote_sem) { in spair_write()
569 k_sem_give(&remote->sem); in spair_write()
758 struct spair *remote = NULL; in zsock_poll_prepare_ctx() local
791 remote = zvfs_get_fd_obj(spair->remote, in zsock_poll_prepare_ctx()
795 __ASSERT(remote != NULL, "remote is NULL"); in zsock_poll_prepare_ctx()
797 res = k_sem_take(&remote->sem, K_FOREVER); in zsock_poll_prepare_ctx()
804 /* Wait until the recv queue on the remote end is no longer full */ in zsock_poll_prepare_ctx()
805 (*pev)->obj = &remote->writeable; in zsock_poll_prepare_ctx()
818 if (remote != NULL && have_remote_sem) { in zsock_poll_prepare_ctx()
819 k_sem_give(&remote->sem); in zsock_poll_prepare_ctx()
832 struct spair *remote = NULL; in zsock_poll_update_ctx() local
841 remote = zvfs_get_fd_obj(spair->remote, in zsock_poll_update_ctx()
844 __ASSERT(remote != NULL, "remote is NULL"); in zsock_poll_update_ctx()
846 res = k_sem_take(&remote->sem, K_FOREVER); in zsock_poll_update_ctx()
861 k_poll_signal_check(&remote->writeable, &signaled, &result); in zsock_poll_update_ctx()
905 if (remote != NULL && have_remote_sem) { in zsock_poll_update_ctx()
906 k_sem_give(&remote->sem); in zsock_poll_update_ctx()
929 * function call requires the remote sem, it must acquire and free the in spair_ioctl()
930 * remote sem. in spair_ioctl()
1178 /* disconnect the remote endpoint */ in spair_close()