| /dports/math/vowpal_wabbit/vowpal_wabbit-7.10/vowpalwabbit/ |
| H A D | allreduce.h | 63 …_t left_read_pos, size_t right_read_pos, size_t& parent_sent_pos, socket_t parent_sock, size_t n) { in pass_up() argument
68 int write_size = send(parent_sock, buffer+parent_sent_pos, (int)my_bufsize, 0); in pass_up()
78 …T&, const T&)>void reduce(char* buffer, const size_t n, const socket_t parent_sock, const socket_t… in reduce() argument
104 if(parent_sock != -1) in reduce()
105 pass_up<T>(buffer, child_read_pos[0], child_read_pos[1], parent_sent_pos, parent_sock, n); in reduce()
148 if(parent_sock == -1 && child_read_pos[0] == n && child_read_pos[1] == n) in reduce()
155 void broadcast(char* buffer, const size_t n, const socket_t parent_sock, const socket_t * child_soc…
|
| H A D | allreduce.cc | 261 void broadcast(char* buffer, const size_t n, const socket_t parent_sock, const socket_t * child_soc… in broadcast() argument
268 if(parent_sock == -1) { in broadcast()
279 if (parent_sock != -1) { in broadcast()
286 int read_size = recv(parent_sock, buffer + parent_read_pos, (int)count, 0); in broadcast()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/src/profiling/memory/ |
| H A D | client_api_android.cc | 129 perfetto::base::UnixSocketRaw parent_sock; in CreateClientAndPrivateDaemon() local
131 std::tie(parent_sock, child_sock) = perfetto::base::UnixSocketRaw::CreatePair( in CreateClientAndPrivateDaemon()
134 if (!parent_sock || !child_sock) { in CreateClientAndPrivateDaemon()
183 if (!parent_sock.SetTxTimeout(perfetto::profiling::kClientSockTimeoutMs)) { in CreateClientAndPrivateDaemon()
188 if (!parent_sock.SetRxTimeout(perfetto::profiling::kClientSockTimeoutMs)) { in CreateClientAndPrivateDaemon()
205 return perfetto::profiling::Client::CreateAndHandshake(std::move(parent_sock), in CreateClientAndPrivateDaemon()
|
| /dports/sysutils/py-mitogen/mitogen-0.2.9/ansible_mitogen/ |
| H A D | process.py | 426 parent_sock = None
465 self.parent_sock, self.child_sock = socket.socketpair()
466 mitogen.core.set_cloexec(self.parent_sock.fileno())
529 self.parent_sock.shutdown(socket.SHUT_WR)
535 mitogen.core.io_op(self.parent_sock.recv, 1)
536 self.parent_sock.close()
636 mitogen.core.io_op(self.model.parent_sock.recv, 1)
646 self.model.parent_sock.close()
647 self.model.parent_sock = None
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/src/profiling/memory/ |
| H A D | malloc_hooks.cc | 248 perfetto::base::UnixSocketRaw parent_sock; in CreateClientAndPrivateDaemon() local
250 std::tie(parent_sock, child_sock) = perfetto::base::UnixSocketRaw::CreatePair( in CreateClientAndPrivateDaemon()
253 if (!parent_sock || !child_sock) { in CreateClientAndPrivateDaemon()
302 if (!parent_sock.SetTxTimeout(perfetto::profiling::kClientSockTimeoutMs)) { in CreateClientAndPrivateDaemon()
307 if (!parent_sock.SetRxTimeout(perfetto::profiling::kClientSockTimeoutMs)) { in CreateClientAndPrivateDaemon()
321 return perfetto::profiling::Client::CreateAndHandshake(std::move(parent_sock), in CreateClientAndPrivateDaemon()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/nfc/ |
| H A D | llcp_sock.c | 532 struct nfc_llcp_sock *llcp_sock, *parent_sock; in llcp_accept_poll() local
535 parent_sock = nfc_llcp_sock(parent); in llcp_accept_poll()
537 list_for_each_entry(llcp_sock, &parent_sock->accept_queue, in llcp_accept_poll()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/nfc/ |
| H A D | llcp_sock.c | 532 struct nfc_llcp_sock *llcp_sock, *parent_sock; in llcp_accept_poll() local
535 parent_sock = nfc_llcp_sock(parent); in llcp_accept_poll()
537 list_for_each_entry(llcp_sock, &parent_sock->accept_queue, in llcp_accept_poll()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/nfc/ |
| H A D | llcp_sock.c | 532 struct nfc_llcp_sock *llcp_sock, *parent_sock; in llcp_accept_poll() local
535 parent_sock = nfc_llcp_sock(parent); in llcp_accept_poll()
537 list_for_each_entry(llcp_sock, &parent_sock->accept_queue, in llcp_accept_poll()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/mptcp/ |
| H A D | protocol.c | 3021 struct socket *parent_sock; in mptcp_finish_join() local
3060 parent_sock = READ_ONCE(parent->sk_socket); in mptcp_finish_join()
3061 if (parent_sock && !ssk->sk_socket) in mptcp_finish_join()
3062 mptcp_sock_graft(ssk, parent_sock); in mptcp_finish_join()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/mptcp/ |
| H A D | protocol.c | 3021 struct socket *parent_sock; in mptcp_finish_join() local
3060 parent_sock = READ_ONCE(parent->sk_socket); in mptcp_finish_join()
3061 if (parent_sock && !ssk->sk_socket) in mptcp_finish_join()
3062 mptcp_sock_graft(ssk, parent_sock); in mptcp_finish_join()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/mptcp/ |
| H A D | protocol.c | 3021 struct socket *parent_sock; in mptcp_finish_join() local
3060 parent_sock = READ_ONCE(parent->sk_socket); in mptcp_finish_join()
3061 if (parent_sock && !ssk->sk_socket) in mptcp_finish_join()
3062 mptcp_sock_graft(ssk, parent_sock); in mptcp_finish_join()
|
| /dports/mail/postfix-postfwd/postfwd-2.03/sbin/ |
| H A D | postfwd | 3257 my($parent) = $self->{server}->{parent_sock};
|
| H A D | postfwd1 | 3257 my($parent) = $self->{server}->{parent_sock};
|
| H A D | postfwd2 | 3257 my($parent) = $self->{server}->{parent_sock};
|
| H A D | postfwd3 | 3257 my($parent) = $self->{server}->{parent_sock};
|