sd 631 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c int sd; sd 636 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c sd = socket(af_family, SOCK_STREAM, 0); sd 637 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(sd < 0) { sd 645 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_set_socket_options(sd); sd 661 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 673 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if (setsockopt (sd, IPPROTO_IPV6, IPV6_V6ONLY, sd 689 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if (setsockopt (sd, SOL_SOCKET, SO_REUSEADDR, (const char *)&flg, sizeof (flg)) < 0) { sd 693 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 716 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(bind(sd, (struct sockaddr*)&inaddr, addrlen) < 0) { sd 722 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 739 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 744 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(getsockname(sd, (struct sockaddr*)&inaddr, &addrlen) < 0) { sd 747 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 753 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_component.tcp_listen_sd = sd; sd 758 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_component.tcp6_listen_sd = sd; sd 763 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(listen(sd, SOMAXCONN) < 0) { sd 766 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 771 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 774 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 778 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(fcntl(sd, F_SETFL, flags) < 0) { sd 781 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 1006 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c int sd = accept(incoming_sd, (struct sockaddr*)&addr, &addrlen); sd 1007 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(sd < 0) { sd 1015 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_set_socket_options(sd); sd 1020 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c opal_event_set(opal_event_base, &event->event, sd, OPAL_EV_READ, mca_btl_tcp2_component_recv_handler, event); sd 1032 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c static void mca_btl_tcp2_component_recv_handler(int sd, short flags, void* user) sd 1044 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c retval = recv(sd, (char *)&guid, sizeof(guid), 0); sd 1046 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 1052 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 1057 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(fcntl(sd, F_SETFL, flags) < 0) { sd 1066 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 1071 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(getpeername(sd, (struct sockaddr*)&addr, &addr_len) != 0) { sd 1074 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 1079 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(mca_btl_tcp2_proc_accept(btl_proc, (struct sockaddr*)&addr, sd) == false) { sd 1080 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c CLOSE_THE_SOCKET(sd); sd 111 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static void mca_btl_tcp2_endpoint_recv_handler(int sd, short flags, void* user); sd 112 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static void mca_btl_tcp2_endpoint_send_handler(int sd, short flags, void* user); sd 361 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c struct sockaddr* addr, int sd) sd 381 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c btl_endpoint->endpoint_sd = sd; sd 414 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c int sd = btl_endpoint->endpoint_sd; sd 417 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if( sd < 0 ) return; sd 418 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c } while ( opal_atomic_cmpset( &(btl_endpoint->endpoint_sd), sd, -1 ) ); sd 420 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c CLOSE_THE_SOCKET(sd); sd 523 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c void mca_btl_tcp2_set_socket_options(int sd) sd 528 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if(setsockopt(sd, IPPROTO_TCP, TCP_NODELAY, (char *)&optval, sizeof(optval)) < 0) { sd 535 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c setsockopt(sd, SOL_SOCKET, SO_SNDBUF, (char *)&mca_btl_tcp2_component.tcp_sndbuf, sizeof(int)) < 0) { sd 542 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c setsockopt(sd, SOL_SOCKET, SO_RCVBUF, (char *)&mca_btl_tcp2_component.tcp_rcvbuf, sizeof(int)) < 0) { sd 685 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static void mca_btl_tcp2_endpoint_recv_handler(int sd, short flags, void* user) sd 692 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c if( sd != btl_endpoint->endpoint_sd ) sd 793 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.c static void mca_btl_tcp2_endpoint_send_handler(int sd, short flags, void* user) sd 77 contrib/build-mca-comps-outside-of-tree/btl_tcp2_endpoint.h void mca_btl_tcp2_set_socket_options(int sd); sd 101 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c bool mca_btl_tcp2_frag_send(mca_btl_tcp2_frag_t* frag, int sd) sd 108 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c cnt = writev(sd, frag->iov_ptr, frag->iov_cnt); sd 149 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c bool mca_btl_tcp2_frag_recv(mca_btl_tcp2_frag_t* frag, int sd) sd 196 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.c cnt = readv(sd, frag->iov_ptr, num_vecs); sd 160 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h bool mca_btl_tcp2_frag_send(mca_btl_tcp2_frag_t*, int sd); sd 161 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h bool mca_btl_tcp2_frag_recv(mca_btl_tcp2_frag_t*, int sd); sd 726 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c bool mca_btl_tcp2_proc_accept(mca_btl_tcp2_proc_t* btl_proc, struct sockaddr* addr, int sd) sd 758 contrib/build-mca-comps-outside-of-tree/btl_tcp2_proc.c if(mca_btl_tcp_endpoint_accept(btl_endpoint, addr, sd)) { sd 541 opal/mca/btl/tcp/btl_tcp.c int mca_btl_tcp_recv_blocking(int sd, void* data, size_t size) sd 546 opal/mca/btl/tcp/btl_tcp.c int retval = recv(sd, ((char *)ptr) + cnt, size - cnt, 0); sd 559 opal/mca/btl/tcp/btl_tcp.c BTL_ERROR(("recv(%d) failed: %s (%d)", sd, strerror(opal_socket_errno), opal_socket_errno)); sd 576 opal/mca/btl/tcp/btl_tcp.c int mca_btl_tcp_send_blocking(int sd, const void* data, size_t size) sd 581 opal/mca/btl/tcp/btl_tcp.c int retval = send(sd, ((const char *)ptr) + cnt, size - cnt, 0); sd 360 opal/mca/btl/tcp/btl_tcp.h int mca_btl_tcp_send_blocking(int sd, const void* data, size_t size); sd 371 opal/mca/btl/tcp/btl_tcp.h int mca_btl_tcp_recv_blocking(int sd, void* data, size_t size); sd 890 opal/mca/btl/tcp/btl_tcp_component.c int flags, sd, rc; sd 895 opal/mca/btl/tcp/btl_tcp_component.c sd = socket(af_family, SOCK_STREAM, 0); sd 896 opal/mca/btl/tcp/btl_tcp_component.c if(sd < 0) { sd 904 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_set_socket_options(sd); sd 919 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 937 opal/mca/btl/tcp/btl_tcp_component.c if (setsockopt (sd, IPPROTO_IPV6, IPV6_V6ONLY, sd 952 opal/mca/btl/tcp/btl_tcp_component.c if (setsockopt (sd, SOL_SOCKET, SO_REUSEADDR, (const char *)&flg, sizeof (flg)) < 0) { sd 956 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 985 opal/mca/btl/tcp/btl_tcp_component.c if(bind(sd, (struct sockaddr*)&inaddr, addrlen) < 0) { sd 991 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1012 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1017 opal/mca/btl/tcp/btl_tcp_component.c if(getsockname(sd, (struct sockaddr*)&inaddr, &addrlen) < 0) { sd 1020 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1027 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp6_listen_sd = sd; sd 1036 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_listen_sd = sd; sd 1044 opal/mca/btl/tcp/btl_tcp_component.c if(listen(sd, SOMAXCONN) < 0) { sd 1047 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1052 opal/mca/btl/tcp/btl_tcp_component.c if((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 1057 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1061 opal/mca/btl/tcp/btl_tcp_component.c if(fcntl(sd, F_SETFL, flags) < 0) { sd 1067 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1356 opal/mca/btl/tcp/btl_tcp_component.c int sd = accept(incoming_sd, (struct sockaddr*)&addr, &addrlen); sd 1357 opal/mca/btl/tcp/btl_tcp_component.c if(sd < 0) { sd 1370 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_set_socket_options(sd); sd 1375 opal/mca/btl/tcp/btl_tcp_component.c opal_event_set(mca_btl_tcp_event_base, &(event->event), sd, sd 1388 opal/mca/btl/tcp/btl_tcp_component.c static void mca_btl_tcp_component_recv_handler(int sd, short flags, void* user) sd 1408 opal/mca/btl/tcp/btl_tcp_component.c if (0 != getsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, (void*)&save, &rcvtimeo_save_len)) { sd 1422 opal/mca/btl/tcp/btl_tcp_component.c if (0 != setsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv))) { sd 1433 opal/mca/btl/tcp/btl_tcp_component.c retval = mca_btl_tcp_recv_blocking(sd, (void *)&hs_msg, sizeof(hs_msg)); sd 1445 opal/mca/btl/tcp/btl_tcp_component.c const char *peer = opal_fd_get_peer_name(sd); sd 1450 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1459 opal/mca/btl/tcp/btl_tcp_component.c const char *peer = opal_fd_get_peer_name(sd); sd 1468 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1474 opal/mca/btl/tcp/btl_tcp_component.c if (0 != setsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, &save, sizeof(save))) { sd 1487 opal/mca/btl/tcp/btl_tcp_component.c if((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 1492 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1495 opal/mca/btl/tcp/btl_tcp_component.c if(fcntl(sd, F_SETFL, flags) < 0) { sd 1501 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1512 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1517 opal/mca/btl/tcp/btl_tcp_component.c if(getpeername(sd, (struct sockaddr*)&addr, &addr_len) != 0) { sd 1525 opal/mca/btl/tcp/btl_tcp_component.c CLOSE_THE_SOCKET(sd); sd 1530 opal/mca/btl/tcp/btl_tcp_component.c (void)mca_btl_tcp_proc_accept(btl_proc, (struct sockaddr*)&addr, sd); sd 1532 opal/mca/btl/tcp/btl_tcp_component.c const char *str = opal_fd_get_peer_name(sd); sd 124 opal/mca/btl/tcp/btl_tcp_endpoint.c static void mca_btl_tcp_endpoint_recv_handler(int sd, short flags, void* user); sd 125 opal/mca/btl/tcp/btl_tcp_endpoint.c static void mca_btl_tcp_endpoint_send_handler(int sd, short flags, void* user); sd 497 opal/mca/btl/tcp/btl_tcp_endpoint.c struct sockaddr* addr, int sd) sd 502 opal/mca/btl/tcp/btl_tcp_endpoint.c btl_endpoint->endpoint_sd_next = sd; sd 639 opal/mca/btl/tcp/btl_tcp_endpoint.c void mca_btl_tcp_set_socket_options(int sd) sd 644 opal/mca/btl/tcp/btl_tcp_endpoint.c if(setsockopt(sd, IPPROTO_TCP, TCP_NODELAY, (char *)&optval, sizeof(optval)) < 0) { sd 651 opal/mca/btl/tcp/btl_tcp_endpoint.c setsockopt(sd, SOL_SOCKET, SO_SNDBUF, (char *)&mca_btl_tcp_component.tcp_sndbuf, sizeof(int)) < 0) { sd 658 opal/mca/btl/tcp/btl_tcp_endpoint.c setsockopt(sd, SOL_SOCKET, SO_RCVBUF, (char *)&mca_btl_tcp_component.tcp_rcvbuf, sizeof(int)) < 0) { sd 884 opal/mca/btl/tcp/btl_tcp_endpoint.c static void mca_btl_tcp_endpoint_recv_handler(int sd, short flags, void* user) sd 891 opal/mca/btl/tcp/btl_tcp_endpoint.c if( sd != btl_endpoint->endpoint_sd ) sd 929 opal/mca/btl/tcp/btl_tcp_endpoint.c CLOSE_THE_SOCKET(sd); sd 1022 opal/mca/btl/tcp/btl_tcp_endpoint.c static void mca_btl_tcp_endpoint_send_handler(int sd, short flags, void* user) sd 86 opal/mca/btl/tcp/btl_tcp_endpoint.h void mca_btl_tcp_set_socket_options(int sd); sd 113 opal/mca/btl/tcp/btl_tcp_frag.c bool mca_btl_tcp_frag_send(mca_btl_tcp_frag_t* frag, int sd) sd 120 opal/mca/btl/tcp/btl_tcp_frag.c cnt = writev(sd, frag->iov_ptr, frag->iov_cnt); sd 159 opal/mca/btl/tcp/btl_tcp_frag.c __FILE__, __LINE__, cnt, sd)); sd 166 opal/mca/btl/tcp/btl_tcp_frag.c bool mca_btl_tcp_frag_recv(mca_btl_tcp_frag_t* frag, int sd) sd 212 opal/mca/btl/tcp/btl_tcp_frag.c cnt = readv(sd, frag->iov_ptr, num_vecs); sd 128 opal/mca/btl/tcp/btl_tcp_frag.h bool mca_btl_tcp_frag_send(mca_btl_tcp_frag_t*, int sd); sd 129 opal/mca/btl/tcp/btl_tcp_frag.h bool mca_btl_tcp_frag_recv(mca_btl_tcp_frag_t*, int sd); sd 854 opal/mca/btl/tcp/btl_tcp_proc.c void mca_btl_tcp_proc_accept(mca_btl_tcp_proc_t* btl_proc, struct sockaddr* addr, int sd) sd 917 opal/mca/btl/tcp/btl_tcp_proc.c (void)mca_btl_tcp_endpoint_accept(btl_endpoint, addr, sd); sd 925 opal/mca/btl/tcp/btl_tcp_proc.c (void)mca_btl_tcp_endpoint_accept(match_btl_endpoint, addr, sd); sd 930 opal/mca/btl/tcp/btl_tcp_proc.c CLOSE_THE_SOCKET(sd); sd 74 opal/mca/if/posix_ipv4/if_posix.c int sd; sd 84 opal/mca/if/posix_ipv4/if_posix.c if ((sd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { sd 113 opal/mca/if/posix_ipv4/if_posix.c close(sd); sd 123 opal/mca/if/posix_ipv4/if_posix.c if (ioctl(sd, SIOCGIFCONF, &ifconf) < 0) { sd 132 opal/mca/if/posix_ipv4/if_posix.c close(sd); sd 154 opal/mca/if/posix_ipv4/if_posix.c close(sd); sd 191 opal/mca/if/posix_ipv4/if_posix.c if (ioctl(sd, SIOCGIFFLAGS, ifr) < 0) { sd 215 opal/mca/if/posix_ipv4/if_posix.c close(sd); sd 235 opal/mca/if/posix_ipv4/if_posix.c if (ioctl(sd, SIOCGIFINDEX, ifr) < 0) { sd 251 opal/mca/if/posix_ipv4/if_posix.c if (ioctl(sd, SIOCGIFADDR, ifr) < 0) { sd 264 opal/mca/if/posix_ipv4/if_posix.c if (ioctl(sd, SIOCGIFNETMASK, ifr) < 0) { sd 275 opal/mca/if/posix_ipv4/if_posix.c if (ioctl(sd, SIOCGIFHWADDR, ifr) < 0) { sd 284 opal/mca/if/posix_ipv4/if_posix.c if (ioctl(sd, SIOCGIFMTU, ifr) < 0) { sd 294 opal/mca/if/posix_ipv4/if_posix.c close(sd); sd 51 opal/mca/if/solaris_ipv6/if_solaris_ipv6.c int sd; sd 58 opal/mca/if/solaris_ipv6/if_solaris_ipv6.c sd = socket (AF_INET6, SOCK_DGRAM, 0); sd 59 opal/mca/if/solaris_ipv6/if_solaris_ipv6.c if (sd < 0) { sd 70 opal/mca/if/solaris_ipv6/if_solaris_ipv6.c error = ioctl (sd, SIOCGLIFNUM, &lifnum); sd 90 opal/mca/if/solaris_ipv6/if_solaris_ipv6.c error = ioctl (sd, SIOCGLIFCONF, &lifconf); sd 104 opal/mca/if/solaris_ipv6/if_solaris_ipv6.c error = ioctl (sd, SIOCGLIFINDEX, &lifquery); sd 113 opal/mca/if/solaris_ipv6/if_solaris_ipv6.c error = ioctl (sd, SIOCGLIFFLAGS, &lifquery); sd 688 opal/mca/pmix/cray/pmix_cray.c static void fencenb(int sd, short args, void *cbdata) sd 244 opal/mca/pmix/ext3x/ext3x.c static void process_event(int sd, short args, void *cbdata) sd 722 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void fin_timeout(int sd, short args, void *cbdata) sd 776 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if ( 0 <= pmix_client_globals.myserver->sd ) { sd 855 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (0 <= pmix_client_globals.myserver->sd) { sd 856 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c CLOSE_THE_SOCKET(pmix_client_globals.myserver->sd); sd 960 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void _putfn(int sd, short args, void *cbdata) sd 1065 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void _commitfn(int sd, short args, void *cbdata) sd 1228 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void _resolve_peers(int sd, short args, void *cbdata) sd 66 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c static void _getnbfn(int sd, short args, void *cbdata); sd 761 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c PMIX_EXPORT void pmix_attrs_query_support(int sd, short args, void *cbdata) sd 68 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.h PMIX_EXPORT void pmix_attrs_query_support(int sd, short args, void *cbdata); sd 126 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c static void _local_cbfunc(int sd, short args, void *cbdata) sd 807 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c static void _notify_client_event(int sd, short args, void *cbdata) sd 459 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c static void reg_event_hdlr(int sd, short args, void *cbdata) sd 905 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c static void dereg_event_hdlr(int sd, short args, void *cbdata) sd 181 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c p->sd = -1; sd 196 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c if (0 <= p->sd) { sd 197 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c CLOSE_THE_SOCKET(p->sd); sd 247 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h int sd; sd 383 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c pmix_pdata_t *pd, *sd; sd 616 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c sd = (pmix_pdata_t*)src->array; sd 618 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c PMIX_PDATA_XFER(&pd[n], &sd[n]); sd 348 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c pmix_pdata_t *pd, *sd; sd 665 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c sd = (pmix_pdata_t*)src->data.darray->array; sd 667 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c PMIX_PDATA_LOAD(&pd[n], &sd[n].proc, sd[n].key, &sd[n].value.data.flag, sd[n].value.type); sd 1037 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c pmix_pdata_t *pd, *sd; sd 1269 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c sd = (pmix_pdata_t*)src->array; sd 1271 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/v20/copy.c PMIX_PDATA_LOAD(&pd[n], &sd[n].proc, sd[n].key, &sd[n].value.data, sd[n].value.type); sd 104 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c int sd; sd 114 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c if ((sd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { sd 143 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c close(sd); sd 153 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c if (ioctl(sd, SIOCGIFCONF, &ifconf) < 0) { sd 162 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c close(sd); sd 184 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c close(sd); sd 221 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c if (ioctl(sd, SIOCGIFFLAGS, ifr) < 0) { sd 245 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c close(sd); sd 265 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c if (ioctl(sd, SIOCGIFINDEX, ifr) < 0) { sd 281 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c if (ioctl(sd, SIOCGIFADDR, ifr) < 0) { sd 294 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c if (ioctl(sd, SIOCGIFNETMASK, ifr) < 0) { sd 305 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c if (ioctl(sd, SIOCGIFHWADDR, ifr) < 0) { sd 314 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c if (ioctl(sd, SIOCGIFMTU, ifr) < 0) { sd 325 opal/mca/pmix/pmix4x/pmix/src/mca/pif/posix_ipv4/pif_posix.c close(sd); sd 100 opal/mca/pmix/pmix4x/pmix/src/mca/pif/solaris_ipv6/pif_solaris_ipv6.c int sd; sd 107 opal/mca/pmix/pmix4x/pmix/src/mca/pif/solaris_ipv6/pif_solaris_ipv6.c sd = socket (AF_INET6, SOCK_DGRAM, 0); sd 108 opal/mca/pmix/pmix4x/pmix/src/mca/pif/solaris_ipv6/pif_solaris_ipv6.c if (sd < 0) { sd 119 opal/mca/pmix/pmix4x/pmix/src/mca/pif/solaris_ipv6/pif_solaris_ipv6.c error = ioctl (sd, SIOCGLIFNUM, &lifnum); sd 139 opal/mca/pmix/pmix4x/pmix/src/mca/pif/solaris_ipv6/pif_solaris_ipv6.c error = ioctl (sd, SIOCGLIFCONF, &lifconf); sd 153 opal/mca/pmix/pmix4x/pmix/src/mca/pif/solaris_ipv6/pif_solaris_ipv6.c error = ioctl (sd, SIOCGLIFINDEX, &lifquery); sd 162 opal/mca/pmix/pmix4x/pmix/src/mca/pif/solaris_ipv6/pif_solaris_ipv6.c error = ioctl (sd, SIOCGLIFFLAGS, &lifquery); sd 179 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c "psec:native checking getsockopt on socket %d for peer credentials", pr->sd); sd 180 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c if (getsockopt(pr->sd, SOL_SOCKET, SO_PEERCRED, &ucred, &crlen) < 0) { sd 196 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c "psec:native checking getpeereid on socket %d for peer credentials", pr->sd); sd 197 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c if (0 != getpeereid(pr->sd, &euid, &egid)) { sd 77 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h typedef pmix_status_t (*pmix_psec_base_module_client_hndshk_fn_t)(int sd); sd 101 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h typedef pmix_status_t (*pmix_psec_base_module_server_hndshk_fn_t)(int sd); sd 135 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h #define PMIX_PSEC_CLIENT_HANDSHAKE(r, p, sd) \ sd 136 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = (p)->nptr->compat.psec->client_handshake(sd) sd 159 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h if (PMIX_SUCCESS != (_r = pmix_ptl_base_send_blocking((p)->sd, (char*)&(_r), sizeof(int)))) { \ sd 168 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h if (PMIX_SUCCESS != (_r = pmix_ptl_base_send_blocking((p)->sd, (char*)&(_r), sizeof(int)))) { \ sd 171 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h if (PMIX_SUCCESS != (_r = p->nptr->compat.psec->server_handshake((p)->sd))) { \ sd 156 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c static void file_sample(int sd, short args, void *cbdata); sd 158 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c static void add_tracker(int sd, short flags, void *cbdata) sd 234 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c static void del_tracker(int sd, short flags, void *cbdata) sd 282 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c static void file_sample(int sd, short args, void *cbdata) sd 151 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c static void add_tracker(int sd, short flags, void *cbdata) sd 228 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c static void del_tracker(int sd, short flags, void *cbdata) sd 325 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c static void add_beat(int sd, short args, void *cbdata) sd 106 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT void pmix_ptl_base_send(int sd, short args, void *cbdata); sd 107 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT void pmix_ptl_base_send_recv(int sd, short args, void *cbdata); sd 108 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT void pmix_ptl_base_send_handler(int sd, short flags, void *cbdata); sd 109 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT void pmix_ptl_base_recv_handler(int sd, short flags, void *cbdata); sd 111 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_set_nonblocking(int sd); sd 112 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_set_blocking(int sd); sd 113 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_send_blocking(int sd, char *ptr, size_t size); sd 114 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_recv_blocking(int sd, char *data, size_t size); sd 117 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT void pmix_ptl_base_connection_handler(int sd, short args, void *cbdata); sd 118 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_send_connect_ack(int sd); sd 119 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_recv_connect_ack(int sd); sd 45 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c pmix_status_t pmix_ptl_base_set_nonblocking(int sd) sd 49 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c if ((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 55 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c if(fcntl(sd, F_SETFL, flags) < 0) sd 63 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c pmix_status_t pmix_ptl_base_set_blocking(int sd) sd 67 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c if ((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 73 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c if(fcntl(sd, F_SETFL, flags) < 0) sd 85 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c pmix_status_t pmix_ptl_base_send_blocking(int sd, char *ptr, size_t size) sd 92 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c size, sd ); sd 94 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c retval = send(sd, (char*)ptr+cnt, size-cnt, 0); sd 107 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c sd, strerror(pmix_socket_errno), sd 117 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c "blocking send complete to socket %d", sd); sd 125 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c pmix_status_t pmix_ptl_base_recv_blocking(int sd, char *data, size_t size) sd 133 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c int retval = recv(sd, (char *)data+cnt, size-cnt, MSG_WAITALL); sd 187 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c int sd = -1; sd 196 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c sd = socket(addr->ss_family, SOCK_STREAM, 0); sd 197 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c if (sd < 0) { sd 204 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c "pmix_ptl_base_connect: attempting to connect to server on socket %d", sd); sd 206 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c if (connect(sd, (struct sockaddr*)addr, addrlen) < 0) { sd 211 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c CLOSE_THE_SOCKET(sd); sd 223 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c CLOSE_THE_SOCKET(sd); sd 229 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c CLOSE_THE_SOCKET(sd); sd 238 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c if (retries == PMIX_MAX_RETRIES || sd < 0){ sd 241 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c if (0 <= sd) { sd 242 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c CLOSE_THE_SOCKET(sd); sd 246 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_connect.c *fd = sd; sd 87 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c if (0 <= pmix_client_globals.myserver->sd) { sd 88 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c CLOSE_THE_SOCKET(pmix_client_globals.myserver->sd); sd 89 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c pmix_client_globals.myserver->sd = -1; sd 255 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->sd = accept(lt->socket, sd 258 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (pending_connection->sd < 0) { sd 284 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->sd, pmix_socket_errno); sd 87 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c CLOSE_THE_SOCKET(peer->sd); sd 257 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c static pmix_status_t send_msg(int sd, pmix_ptl_send_t *msg) sd 274 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rc = writev(sd, iov, iov_count); sd 300 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_socket_errno, sd); sd 330 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c static pmix_status_t read_bytes(int sd, char **buf, size_t *remain) sd 338 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rc = read(sd, ptr, *remain); sd 386 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c void pmix_ptl_base_send_handler(int sd, short flags, void *cbdata) sd 407 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (PMIX_SUCCESS == (rc = send_msg(peer->sd, msg))) { sd 464 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c void pmix_ptl_base_recv_handler(int sd, short flags, void *cbdata) sd 501 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c msg->sd = sd; sd 505 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c "ptl:base:recv:handler read hdr on socket %d", peer->sd); sd 508 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (PMIX_SUCCESS == (rc = read_bytes(peer->sd, &ptr, &nbytes))) { sd 571 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (PMIX_SUCCESS == (rc = read_bytes(peer->sd, &msg->rdptr, &msg->rdbytes))) { sd 577 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c peer->recv_msg->hdr.tag, peer->sd); sd 626 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c void pmix_ptl_base_send(int sd, short args, void *cbdata) sd 634 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL == queue->peer || queue->peer->sd < 0 || sd 692 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL == ms->peer || ms->peer->sd < 0 || sd 772 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (int)msg->hdr.nbytes, msg->hdr.tag, msg->sd); sd 126 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h typedef void (*pmix_ptl_pending_cbfunc_t)(int sd, short args, void *cbdata); sd 146 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h int sd; sd 199 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h int sd; sd 292 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h if (!(p)->send_ev_active && 0 <= (p)->sd) { \ sd 87 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t recv_connect_ack(int sd, uint8_t myflag); sd 88 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t send_connect_ack(int sd, uint8_t *myflag, pmix_info_t info[], size_t ninfo); sd 119 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t try_connect(char *uri, int *sd, pmix_info_t info[], size_t ninfo); sd 122 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c int *sd, char **nspace, sd 132 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c int sd, rc; sd 232 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS != (rc = try_connect(uri[1], &sd, info, ninfo))) { sd 464 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS != (rc = try_connect(suri, &sd, iptr, niptr))) { sd 481 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS == try_connect(suri, &sd, iptr, niptr)) { sd 511 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS == try_connect(suri, &sd, iptr, niptr)) { sd 541 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c filename, iptr, niptr, &sd, &nspace, &rank, &suri); sd 565 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c filename, iptr, niptr, &sd, &nspace, &rank, &suri); sd 590 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c filename, iptr, niptr, &sd, &nspace, &rank, &suri); sd 603 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c CLOSE_THE_SOCKET(sd); sd 609 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_client_globals.myserver->sd = sd; sd 643 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_ptl_base_set_nonblocking(sd); sd 648 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_client_globals.myserver->sd, sd 658 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_client_globals.myserver->sd, sd 723 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static void timeout(int sd, short args, void *cbdata) sd 845 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t try_connect(char *uri, int *sd, pmix_info_t iptr[], size_t niptr) sd 931 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_connect(&mca_ptl_tcp_component.connection, len, sd))) { sd 937 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS != (rc = send_connect_ack(*sd, &myflag, iptr, niptr))) { sd 939 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c CLOSE_THE_SOCKET(*sd); sd 944 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS != (rc = recv_connect_ack(*sd, myflag))) { sd 945 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c CLOSE_THE_SOCKET(*sd); sd 957 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t send_connect_ack(int sd, uint8_t *myflag, sd 1191 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS != pmix_ptl_base_send_blocking(sd, msg, sdsize)) { sd 1204 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t recv_connect_ack(int sd, uint8_t myflag) sd 1219 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (0 != getsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, (void*)&save, &sz)) { sd 1229 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (0 != setsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv))) { sd 1241 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c rc = pmix_ptl_base_recv_blocking(sd, (char*)&u32, sizeof(uint32_t)); sd 1245 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (0 != setsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, &save, sz)) { sd 1256 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c PMIX_PSEC_CLIENT_HANDSHAKE(rc, pmix_client_globals.myserver, sd); sd 1267 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c rc = pmix_ptl_base_recv_blocking(sd, (char*)&u32, sizeof(uint32_t)); sd 1280 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c rc = pmix_ptl_base_recv_blocking(sd, (char*)&nspace, PMIX_MAX_NSLEN+1); sd 1286 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c rc = pmix_ptl_base_recv_blocking(sd, (char*)&u32, sizeof(uint32_t)); sd 1301 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_ptl_base_recv_blocking(sd, (char*)nspace, PMIX_MAX_NSLEN+1); sd 1310 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_ptl_base_recv_blocking(sd, (char*)&u32, sizeof(uint32_t)); sd 1320 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_ptl_base_recv_blocking(sd, (char*)&reply, sizeof(pmix_status_t)); sd 1324 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c PMIX_PSEC_CLIENT_HANDSHAKE(reply, pmix_client_globals.myserver, sd); sd 1336 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (0 != setsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, &save, sz)) { sd 1346 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c int *sd, char **nspace, sd 1377 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c rc = df_search(newdir, prefix, info, ninfo, sd, nspace, rank, uri); sd 1397 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c if (PMIX_SUCCESS == try_connect(suri, sd, info, ninfo)) { sd 131 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c static void connection_handler(int sd, short args, void *cbdata); sd 954 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c static void connection_handler(int sd, short args, void *cbdata) sd 981 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->sd); sd 984 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_ptl_base_set_blocking(pnd->sd); sd 990 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, (char*)&hdr, sizeof(pmix_ptl_hdr_t)))) { sd 991 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1000 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1005 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1009 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, msg, hdr.nbytes))) { sd 1013 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pnd->sd); sd 1015 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1058 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1333 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1395 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1406 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1535 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1555 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->sd = pnd->sd; sd 1561 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1641 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { sd 1646 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1652 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { sd 1678 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_ptl_base_set_nonblocking(pnd->sd); sd 1681 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_event_assign(&peer->recv_event, pmix_globals.evbase, pnd->sd, sd 1685 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_event_assign(&peer->send_event, pmix_globals.evbase, pnd->sd, sd 1689 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->info->pname.nspace, peer->info->pname.rank, peer->sd); sd 1696 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(int)))) { sd 1698 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1705 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c static void process_cbfunc(int sd, short args, void *cbdata) sd 1723 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { sd 1725 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1743 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, cd->proc.nspace, PMIX_MAX_NSLEN+1))) { sd 1745 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1754 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { sd 1756 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1765 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, pmix_globals.myid.nspace, PMIX_MAX_NSLEN+1))) { sd 1767 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1776 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&u32, sizeof(uint32_t)))) { sd 1778 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1815 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->sd = pnd->sd; sd 1824 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1839 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1858 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1879 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(pnd->sd); sd 1884 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_ptl_base_set_nonblocking(pnd->sd); sd 1898 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_event_assign(&peer->recv_event, pmix_globals.evbase, peer->sd, sd 1902 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_event_assign(&peer->send_event, pmix_globals.evbase, peer->sd, sd 1906 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer->info->pname.nspace, peer->info->pname.rank, peer->sd); sd 83 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t recv_connect_ack(int sd); sd 84 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t send_connect_ack(int sd); sd 104 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c int sd; sd 179 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_connect(&mca_ptl_usock_component.connection, len, &sd))) { sd 183 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_client_globals.myserver->sd = sd; sd 186 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS != (rc = send_connect_ack(sd))) { sd 187 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c CLOSE_THE_SOCKET(sd); sd 192 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS != (rc = recv_connect_ack(sd))) { sd 193 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c CLOSE_THE_SOCKET(sd); sd 210 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_ptl_base_set_nonblocking(sd); sd 215 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_client_globals.myserver->sd, sd 226 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_client_globals.myserver->sd, sd 276 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t send_connect_ack(int sd) sd 373 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS != pmix_ptl_base_send_blocking(sd, msg, sdsize)) { sd 384 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t recv_connect_ack(int sd) sd 397 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (0 != getsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, (void*)&save, &sz)) { sd 407 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (0 != setsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv))) { sd 415 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c rc = pmix_ptl_base_recv_blocking(sd, (char*)&reply, sizeof(int)); sd 419 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (0 != setsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, &save, sz)) { sd 428 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c PMIX_PSEC_CLIENT_HANDSHAKE(rc, pmix_client_globals.myserver, sd); sd 440 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c rc = pmix_ptl_base_recv_blocking(sd, (char*)&pmix_globals.pindex, sizeof(int)); sd 446 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (0 != setsockopt(sd, SOL_SOCKET, SO_RCVTIMEO, &save, sz)) { sd 454 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t send_bytes(int sd, char **buf, size_t *remain) sd 460 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c rc = write(sd, ptr, *remain); sd 482 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_socket_errno, sd); sd 496 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t read_bytes(int sd, char **buf, size_t *remain) sd 504 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c rc = read(sd, ptr, *remain); sd 552 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c void pmix_usock_send_handler(int sd, short flags, void *cbdata) sd 581 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS == (rc = send_bytes(peer->sd, &msg->sdptr, &msg->sdbytes))) { sd 631 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS == (rc = send_bytes(peer->sd, &msg->sdptr, &msg->sdbytes))) { sd 649 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->sd); sd 689 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c void pmix_usock_recv_handler(int sd, short flags, void *cbdata) sd 722 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c msg->sd = sd; sd 726 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c "usock:recv:handler read hdr on socket %d", peer->sd); sd 727 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS == (rc = read_bytes(peer->sd, &msg->rdptr, &msg->rdbytes))) { sd 779 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (PMIX_SUCCESS == (rc = read_bytes(peer->sd, &msg->rdptr, &msg->rdbytes))) { sd 784 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c peer->recv_msg->hdr.tag, peer->sd); sd 841 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (ms->peer->sd < 0) { sd 898 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static void pmix_usock_send(int sd, short args, void *cbdata) sd 906 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (NULL == queue->peer || queue->peer->sd < 0 || sd 45 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.h void pmix_usock_send_handler(int sd, short args, void *cbdata); sd 47 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.h void pmix_usock_recv_handler(int sd, short args, void *cbdata); sd 106 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c static void connection_handler(int sd, short args, void *cbdata); sd 332 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pending_connection->sd = incoming_sd; sd 338 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c static void connection_handler(int sd, short args, void *cbdata) sd 362 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c "USOCK CONNECTION FROM PEER ON SOCKET %d", pnd->sd); sd 368 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_recv_blocking(pnd->sd, (char*)&hdr, sizeof(pmix_usock_hdr_t)))) { sd 369 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 378 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 383 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 387 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != pmix_ptl_base_recv_blocking(pnd->sd, msg, hdr.nbytes)) { sd 390 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c "unable to complete recv of connect-ack with client ON SOCKET %d", pnd->sd); sd 392 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 407 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 420 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 433 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 449 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 465 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 477 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 500 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 513 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 525 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 538 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 545 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c nspace, rank, version, pnd->sd); sd 603 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 620 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c psave->sd = pnd->sd; sd 627 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 704 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 710 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != (rc = pmix_ptl_base_send_blocking(pnd->sd, (char*)&psave->index, sizeof(int)))) { sd 716 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 735 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 740 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_event_assign(&psave->recv_event, pmix_globals.evbase, pnd->sd, sd 744 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_event_assign(&psave->send_event, pmix_globals.evbase, pnd->sd, sd 748 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c psave->info->pname.nspace, psave->info->pname.rank, psave->sd); sd 755 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (PMIX_SUCCESS != pmix_ptl_base_send_blocking(pnd->sd, (char*)&rc, sizeof(int))) { sd 758 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(pnd->sd); sd 529 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _register_nspace(int sd, short args, void *cbdata) sd 721 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _deregister_nspace(int sd, short args, void *cbdata) sd 792 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c void pmix_server_execute_collective(int sd, short args, void *cbdata) sd 946 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _register_client(int sd, short args, void *cbdata) sd 1104 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _deregister_client(int sd, short args, void *cbdata) sd 1166 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c CLOSE_THE_SOCKET(peer->sd); sd 1294 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _dmodex_req(int sd, short args, void *cbdata) sd 1459 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _store_internal(int sd, short args, void *cbdata) sd 1552 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _setup_app(int sd, short args, void *cbdata) sd 1644 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _setup_local_support(int sd, short args, void *cbdata) sd 1695 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _iofdeliver(int sd, short args, void *cbdata) sd 1926 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void clct(int sd, short args, void *cbdata) sd 2005 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void dlinv(int sd, short args, void *cbdata) sd 2093 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void connection_cleanup(int sd, short args, void *cbdata) sd 2148 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _spcb(int sd, short args, void *cbdata) sd 2280 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _mdxcbfunc(int sd, short argc, void *cbdata) sd 2498 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _cnct(int sd, short args, void *cbdata) sd 2677 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _discnct(int sd, short args, void *cbdata) sd 3163 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static void _iofreg(int sd, short args, void *cbdata) sd 3559 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c peer->info->pname.rank, peer->sd); sd 96 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c static void get_timeout(int sd, short args, void *cbdata); sd 1067 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c static void get_timeout(int sd, short args, void *cbdata) sd 504 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c static void fence_timeout(int sd, short args, void *cbdata) sd 1677 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c static void connect_timeout(int sd, short args, void *cbdata) sd 1839 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c static void _check_cached_events(int sd, short args, void *cbdata) sd 3667 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c static void grp_timeout(int sd, short args, void *cbdata) sd 3703 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c static void _grpcbfunc(int sd, short argc, void *cbdata) sd 353 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h void pmix_server_execute_collective(int sd, short args, void *cbdata); sd 1093 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static void fin_timeout(int sd, short args, void *cbdata) sd 42 opal/mca/pmix/pmix4x/pmix/src/util/getid.c pmix_status_t pmix_util_getid(int sd, uid_t *uid, gid_t *gid) sd 58 opal/mca/pmix/pmix4x/pmix/src/util/getid.c if (getsockopt(sd, SOL_SOCKET, SO_PEERCRED, &ucred, &crlen) < 0) { sd 75 opal/mca/pmix/pmix4x/pmix/src/util/getid.c if (0 != getpeereid(sd, uid, gid)) { sd 26 opal/mca/pmix/pmix4x/pmix/src/util/getid.h PMIX_EXPORT pmix_status_t pmix_util_getid(int sd, uid_t *uid, gid_t *gid); sd 48 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli_info[n].sd = -1; sd 61 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c void cli_connect(cli_info_t *cli, int sd, pmix_event_base_t * ebase, event_callback_fn callback) sd 70 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli->sd = sd; sd 71 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli->ev = pmix_event_new(ebase, sd, sd 74 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c pmix_ptl_base_set_nonblocking(sd); sd 98 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c if( 0 > cli->sd ){ sd 99 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c TEST_ERROR(("Bad sd = %d of rank = %d ", cli->sd, cli_rank(cli))); sd 102 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c TEST_VERBOSE(("close sd = %d for rank = %d", cli->sd, cli_rank(cli))); sd 103 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c close(cli->sd); sd 104 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c cli->sd = -1; sd 108 opal/mca/pmix/pmix4x/pmix/test/cli_stages.c TEST_ERROR(("Bad ev = NULL of rank = %d ", cli->sd, cli_rank(cli))); sd 44 opal/mca/pmix/pmix4x/pmix/test/cli_stages.h int sd; sd 58 opal/mca/pmix/pmix4x/pmix/test/cli_stages.h void cli_connect(cli_info_t *cli, int sd, struct event_base * ebase, event_callback_fn callback); sd 228 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void dlcbfunc(int sd, short flags, void *cbdata) sd 841 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void fencbfn(int sd, short args, void *cbdata) sd 922 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void lkcbfn(int sd, short args, void *cbdata) sd 1112 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void qfn(int sd, short args, void *cbdata) sd 1175 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static void foobar(int sd, short args, void *cbdata) sd 243 opal/mca/pmix/pmix4x/pmix4x.c static void process_event(int sd, short args, void *cbdata) sd 541 opal/mca/pmix/s1/pmix_s1.c static void fencenb(int sd, short args, void *cbdata) sd 560 opal/mca/pmix/s2/pmix_s2.c static void fencenb(int sd, short args, void *cbdata) sd 114 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c static void wakeup(int sd, short args, void *cbdata) sd 111 orte/mca/errmgr/default_orted/errmgr_default_orted.c static void wakeup(int sd, short args, void *cbdata) sd 912 orte/mca/odls/base/odls_base_default_fns.c void orte_odls_base_spawn_proc(int fd, short sd, void *cbdata) sd 1058 orte/mca/odls/base/odls_base_default_fns.c void orte_odls_base_default_launch_local(int fd, short sd, void *cbdata) sd 1535 orte/mca/odls/base/odls_base_default_fns.c void orte_odls_base_default_wait_local_proc(int fd, short sd, void *cbdata) sd 89 orte/mca/odls/base/odls_private.h ORTE_DECLSPEC void orte_odls_base_spawn_proc(int fd, short sd, void *cbdata); sd 133 orte/mca/odls/base/odls_private.h ORTE_DECLSPEC void orte_odls_base_default_launch_local(int fd, short sd, void *cbdata); sd 135 orte/mca/odls/base/odls_private.h ORTE_DECLSPEC void orte_odls_base_default_wait_local_proc(int fd, short sd, void *cbdata); sd 388 orte/mca/oob/base/oob_base_stubs.c void orte_oob_base_ft_event(int sd, short argc, void *cbdata) sd 91 orte/mca/oob/tcp/oob_tcp.c static void recv_handler(int sd, short flags, void* user); sd 250 orte/mca/oob/tcp/oob_tcp.c static void recv_handler(int sd, short flg, void *cbdata) sd 264 orte/mca/oob/tcp/oob_tcp.c if (ORTE_SUCCESS != mca_oob_tcp_peer_recv_connect_ack(NULL, sd, &hdr)) { sd 276 orte/mca/oob/tcp/oob_tcp.c if ((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 281 orte/mca/oob/tcp/oob_tcp.c if (fcntl(sd, F_SETFL, flags) < 0) { sd 287 orte/mca/oob/tcp/oob_tcp.c peer->sd = sd; sd 297 orte/mca/oob/tcp/oob_tcp.c CLOSE_THE_SOCKET(sd); sd 89 orte/mca/oob/tcp/oob_tcp.h ORTE_MODULE_DECLSPEC void mca_oob_tcp_queue_msg(int sd, short args, void *cbdata); sd 75 orte/mca/oob/tcp/oob_tcp_common.c static void set_keepalive(int sd) sd 83 orte/mca/oob/tcp/oob_tcp_common.c if (getsockopt(sd, SOL_SOCKET, SO_KEEPALIVE, &option, &optlen) < 0) { sd 90 orte/mca/oob/tcp/oob_tcp_common.c if (setsockopt(sd, SOL_SOCKET, SO_KEEPALIVE, &option, optlen) < 0) { sd 100 orte/mca/oob/tcp/oob_tcp_common.c if (setsockopt(sd, IPPROTO_TCP, TCP_KEEPALIVE, sd 112 orte/mca/oob/tcp/oob_tcp_common.c if (setsockopt(sd, IPPROTO_TCP, TCP_KEEPIDLE, sd 125 orte/mca/oob/tcp/oob_tcp_common.c if (setsockopt(sd, IPPROTO_TCP, TCP_KEEPINTVL, sd 138 orte/mca/oob/tcp/oob_tcp_common.c if (setsockopt(sd, IPPROTO_TCP, TCP_KEEPCNT, sd 151 orte/mca/oob/tcp/oob_tcp_common.c void orte_oob_tcp_set_socket_options(int sd) sd 156 orte/mca/oob/tcp/oob_tcp_common.c if (setsockopt(sd, IPPROTO_TCP, TCP_NODELAY, (char *)&optval, sizeof(optval)) < 0) { sd 167 orte/mca/oob/tcp/oob_tcp_common.c setsockopt(sd, SOL_SOCKET, SO_SNDBUF, (char *)&mca_oob_tcp_component.tcp_sndbuf, sizeof(int)) < 0) { sd 177 orte/mca/oob/tcp/oob_tcp_common.c setsockopt(sd, SOL_SOCKET, SO_RCVBUF, (char *)&mca_oob_tcp_component.tcp_rcvbuf, sizeof(int)) < 0) { sd 187 orte/mca/oob/tcp/oob_tcp_common.c set_keepalive(sd); sd 31 orte/mca/oob/tcp/oob_tcp_common.h ORTE_MODULE_DECLSPEC void orte_oob_tcp_set_socket_options(int sd); sd 1332 orte/mca/oob/tcp/oob_tcp_component.c peer->sd = -1; sd 1358 orte/mca/oob/tcp/oob_tcp_component.c if (0 <= peer->sd) { sd 1362 orte/mca/oob/tcp/oob_tcp_component.c peer->sd); sd 1363 orte/mca/oob/tcp/oob_tcp_component.c CLOSE_THE_SOCKET(peer->sd); sd 88 orte/mca/oob/tcp/oob_tcp_connection.c static int tcp_peer_send_connect_nack(int sd, orte_process_name_t name); sd 89 orte/mca/oob/tcp/oob_tcp_connection.c static int tcp_peer_send_blocking(int sd, void* data, size_t size); sd 90 orte/mca/oob/tcp/oob_tcp_connection.c static bool tcp_peer_recv_blocking(mca_oob_tcp_peer_t* peer, int sd, sd 98 orte/mca/oob/tcp/oob_tcp_connection.c if (peer->sd >= 0) { sd 106 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd = socket(family, SOCK_STREAM, 0); sd 107 orte/mca/oob/tcp/oob_tcp_connection.c if (peer->sd < 0) { sd 117 orte/mca/oob/tcp/oob_tcp_connection.c if (opal_fd_set_cloexec(peer->sd) != OPAL_SUCCESS) { sd 120 orte/mca/oob/tcp/oob_tcp_connection.c close(peer->sd); sd 121 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd = -1; sd 126 orte/mca/oob/tcp/oob_tcp_connection.c orte_oob_tcp_set_socket_options(peer->sd); sd 132 orte/mca/oob/tcp/oob_tcp_connection.c if (peer->sd >= 0) { sd 133 orte/mca/oob/tcp/oob_tcp_connection.c if((flags = fcntl(peer->sd, F_GETFL, 0)) < 0) { sd 141 orte/mca/oob/tcp/oob_tcp_connection.c if(fcntl(peer->sd, F_SETFL, flags) < 0) sd 183 orte/mca/oob/tcp/oob_tcp_connection.c ORTE_NAME_PRINT(&(peer->name)), peer->sd); sd 215 orte/mca/oob/tcp/oob_tcp_connection.c if (peer->sd >= 0) { sd 216 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(peer->sd); sd 217 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd = -1; sd 240 orte/mca/oob/tcp/oob_tcp_connection.c rc = connect(peer->sd, (struct sockaddr*) &addr->addr, addrlen); sd 295 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(peer->sd); sd 330 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(peer->sd); sd 376 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(peer->sd); sd 389 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(peer->sd); sd 440 orte/mca/oob/tcp/oob_tcp_connection.c if (ORTE_SUCCESS != tcp_peer_send_blocking(peer->sd, msg, sdsize)) { sd 455 orte/mca/oob/tcp/oob_tcp_connection.c static int tcp_peer_send_connect_nack(int sd, orte_process_name_t name) sd 493 orte/mca/oob/tcp/oob_tcp_connection.c if (ORTE_SUCCESS != tcp_peer_send_blocking(sd, msg, sdsize)) { sd 508 orte/mca/oob/tcp/oob_tcp_connection.c if (peer->sd >= 0) { sd 515 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd, sd 527 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd, sd 552 orte/mca/oob/tcp/oob_tcp_connection.c ORTE_NAME_PRINT(&peer->name), peer->sd); sd 555 orte/mca/oob/tcp/oob_tcp_connection.c if (getsockopt(peer->sd, SOL_SOCKET, SO_ERROR, (char *)&so_error, &so_length) < 0) { sd 625 orte/mca/oob/tcp/oob_tcp_connection.c static int tcp_peer_send_blocking(int sd, void* data, size_t size) sd 636 orte/mca/oob/tcp/oob_tcp_connection.c size, sd); sd 639 orte/mca/oob/tcp/oob_tcp_connection.c retval = send(sd, (char*)ptr+cnt, size-cnt, 0); sd 643 orte/mca/oob/tcp/oob_tcp_connection.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), sd, sd 655 orte/mca/oob/tcp/oob_tcp_connection.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), sd); sd 665 orte/mca/oob/tcp/oob_tcp_connection.c static bool retry(mca_oob_tcp_peer_t* peer, int sd, bool fatal) sd 683 orte/mca/oob/tcp/oob_tcp_connection.c if (0 <= peer->sd) { sd 684 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(peer->sd); sd 685 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd = -1; sd 707 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(peer->sd); sd 712 orte/mca/oob/tcp/oob_tcp_connection.c tcp_peer_send_connect_nack(sd, peer->name); sd 713 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(sd); sd 721 orte/mca/oob/tcp/oob_tcp_connection.c int sd, mca_oob_tcp_hdr_t *dhdr) sd 735 orte/mca/oob/tcp/oob_tcp_connection.c (NULL == pr) ? "UNKNOWN" : ORTE_NAME_PRINT(&pr->name), sd); sd 739 orte/mca/oob/tcp/oob_tcp_connection.c if (tcp_peer_recv_blocking(peer, sd, &hdr, sizeof(mca_oob_tcp_hdr_t))) { sd 748 orte/mca/oob/tcp/oob_tcp_connection.c ORTE_NAME_PRINT(&(peer->name)), sd); sd 758 orte/mca/oob/tcp/oob_tcp_connection.c (NULL == peer) ? "UNKNOWN" : ORTE_NAME_PRINT(&peer->name), sd); sd 780 orte/mca/oob/tcp/oob_tcp_connection.c tcp_peer_send_blocking(sd, &hdr, sizeof(mca_oob_tcp_hdr_t)); sd 781 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(sd); sd 792 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(sd); sd 811 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(sd); sd 840 orte/mca/oob/tcp/oob_tcp_connection.c if (!tcp_peer_recv_blocking(peer, sd, msg, hdr.nbytes)) { sd 845 orte/mca/oob/tcp/oob_tcp_connection.c ORTE_NAME_PRINT(&peer->name), peer->sd); sd 862 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(peer->sd); sd 863 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd = -1; sd 899 orte/mca/oob/tcp/oob_tcp_connection.c if (retry(peer, sd, false)) { sd 914 orte/mca/oob/tcp/oob_tcp_connection.c opal_fd_get_peer_name(peer->sd), sd 959 orte/mca/oob/tcp/oob_tcp_connection.c ORTE_NAME_PRINT(&(peer->name)), peer->sd); sd 996 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd, mca_oob_tcp_state_print(peer->state)); sd 999 orte/mca/oob/tcp/oob_tcp_connection.c close(peer->sd); sd 1000 orte/mca/oob/tcp/oob_tcp_connection.c peer->sd = -1; sd 1055 orte/mca/oob/tcp/oob_tcp_connection.c static bool tcp_peer_recv_blocking(mca_oob_tcp_peer_t* peer, int sd, sd 1067 orte/mca/oob/tcp/oob_tcp_connection.c int retval = recv(sd, (char *)ptr+cnt, size-cnt, 0); sd 1080 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(sd); sd 1092 orte/mca/oob/tcp/oob_tcp_connection.c CLOSE_THE_SOCKET(sd); sd 1153 orte/mca/oob/tcp/oob_tcp_connection.c if (getsockname(peer->sd, (struct sockaddr*)&inaddr, &addrlen) < 0) { sd 1160 orte/mca/oob/tcp/oob_tcp_connection.c if (getpeername(peer->sd, (struct sockaddr*)&inaddr, &addrlen) < 0) { sd 1168 orte/mca/oob/tcp/oob_tcp_connection.c if ((flags = fcntl(peer->sd, F_GETFL, 0)) < 0) { sd 1176 orte/mca/oob/tcp/oob_tcp_connection.c if(getsockopt(peer->sd, SOL_SOCKET, SO_SNDBUF, (char *)&sndbuf, &optlen) < 0) { sd 1186 orte/mca/oob/tcp/oob_tcp_connection.c if (getsockopt(peer->sd, SOL_SOCKET, SO_RCVBUF, (char *)&rcvbuf, &optlen) < 0) { sd 1196 orte/mca/oob/tcp/oob_tcp_connection.c if (getsockopt(peer->sd, IPPROTO_TCP, TCP_NODELAY, (char *)&nodelay, &optlen) < 0) { sd 1222 orte/mca/oob/tcp/oob_tcp_connection.c mca_oob_tcp_state_print(peer->state), peer->sd); sd 1259 orte/mca/oob/tcp/oob_tcp_connection.c mca_oob_tcp_state_print(peer->state), peer->sd); sd 99 orte/mca/oob/tcp/oob_tcp_connection.h int sd, mca_oob_tcp_hdr_t *dhdr); sd 85 orte/mca/oob/tcp/oob_tcp_listener.c static void connection_handler(int sd, short flags, void* cbdata); sd 86 orte/mca/oob/tcp/oob_tcp_listener.c static void connection_event_handler(int sd, short flags, void* cbdata); sd 161 orte/mca/oob/tcp/oob_tcp_listener.c listener->sd, sd 189 orte/mca/oob/tcp/oob_tcp_listener.c int sd = -1; sd 303 orte/mca/oob/tcp/oob_tcp_listener.c sd = socket(AF_INET, SOCK_STREAM, 0); sd 304 orte/mca/oob/tcp/oob_tcp_listener.c if (sd < 0) { sd 319 orte/mca/oob/tcp/oob_tcp_listener.c if (setsockopt (sd, SOL_SOCKET, SO_REUSEADDR, (const char *)&flags, sizeof(flags)) < 0) { sd 323 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 330 orte/mca/oob/tcp/oob_tcp_listener.c if (opal_fd_set_cloexec(sd) != OPAL_SUCCESS) { sd 334 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 339 orte/mca/oob/tcp/oob_tcp_listener.c if (bind(sd, (struct sockaddr*)&inaddr, addrlen) < 0) { sd 348 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 353 orte/mca/oob/tcp/oob_tcp_listener.c if (getsockname(sd, (struct sockaddr*)&inaddr, &addrlen) < 0) { sd 356 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 362 orte/mca/oob/tcp/oob_tcp_listener.c if (listen(sd, SOMAXCONN) < 0) { sd 365 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 371 orte/mca/oob/tcp/oob_tcp_listener.c if ((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 374 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 379 orte/mca/oob/tcp/oob_tcp_listener.c if (fcntl(sd, F_SETFL, flags) < 0) { sd 382 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 389 orte/mca/oob/tcp/oob_tcp_listener.c conn->sd = sd; sd 416 orte/mca/oob/tcp/oob_tcp_listener.c if (0 <= sd) { sd 417 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 442 orte/mca/oob/tcp/oob_tcp_listener.c int sd; sd 556 orte/mca/oob/tcp/oob_tcp_listener.c sd = socket(AF_INET6, SOCK_STREAM, 0); sd 557 orte/mca/oob/tcp/oob_tcp_listener.c if (sd < 0) { sd 566 orte/mca/oob/tcp/oob_tcp_listener.c if (opal_fd_set_cloexec(sd) != OPAL_SUCCESS) { sd 570 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 581 orte/mca/oob/tcp/oob_tcp_listener.c if (setsockopt (sd, SOL_SOCKET, SO_REUSEADDR, (const char *)&flags, sizeof(flags)) < 0) { sd 585 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 590 orte/mca/oob/tcp/oob_tcp_listener.c if (bind(sd, (struct sockaddr*)&inaddr, addrlen) < 0) { sd 599 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 604 orte/mca/oob/tcp/oob_tcp_listener.c if (getsockname(sd, (struct sockaddr*)&inaddr, &addrlen) < 0) { sd 607 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 612 orte/mca/oob/tcp/oob_tcp_listener.c if (listen(sd, SOMAXCONN) < 0) { sd 619 orte/mca/oob/tcp/oob_tcp_listener.c if ((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 625 orte/mca/oob/tcp/oob_tcp_listener.c if (fcntl(sd, F_SETFL, flags) < 0) { sd 634 orte/mca/oob/tcp/oob_tcp_listener.c conn->sd = sd; sd 654 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 675 orte/mca/oob/tcp/oob_tcp_listener.c int rc, max, accepted_connections, sd; sd 691 orte/mca/oob/tcp/oob_tcp_listener.c FD_SET(listener->sd, &readfds); sd 692 orte/mca/oob/tcp/oob_tcp_listener.c max = (listener->sd > max) ? listener->sd : max; sd 726 orte/mca/oob/tcp/oob_tcp_listener.c sd = listener->sd; sd 734 orte/mca/oob/tcp/oob_tcp_listener.c if (0 == FD_ISSET(sd, &readfds)) { sd 750 orte/mca/oob/tcp/oob_tcp_listener.c pending_connection->fd = accept(sd, sd 768 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(sd); sd 846 orte/mca/oob/tcp/oob_tcp_listener.c listener->sd, sd 860 orte/mca/oob/tcp/oob_tcp_listener.c static void connection_handler(int sd, short flags, void* cbdata) sd 890 orte/mca/oob/tcp/oob_tcp_listener.c int sd; sd 892 orte/mca/oob/tcp/oob_tcp_listener.c sd = accept(incoming_sd, (struct sockaddr*)&addr, &addrlen); sd 897 orte/mca/oob/tcp/oob_tcp_listener.c sd, opal_socket_errno, sd 900 orte/mca/oob/tcp/oob_tcp_listener.c if (sd < 0) { sd 941 orte/mca/oob/tcp/oob_tcp_listener.c mca_oob_tcp_module.accept_connection(sd, &addr); sd 949 orte/mca/oob/tcp/oob_tcp_listener.c event->sd = -1; sd 958 orte/mca/oob/tcp/oob_tcp_listener.c if (0 <= event->sd) { sd 959 orte/mca/oob/tcp/oob_tcp_listener.c CLOSE_THE_SOCKET(event->sd); sd 960 orte/mca/oob/tcp/oob_tcp_listener.c event->sd = -1; sd 45 orte/mca/oob/tcp/oob_tcp_listener.h int sd; sd 50 orte/mca/oob/tcp/oob_tcp_peer.h int sd; sd 83 orte/mca/oob/tcp/oob_tcp_sendrecv.c void mca_oob_tcp_queue_msg(int sd, short args, void *cbdata) sd 140 orte/mca/oob/tcp/oob_tcp_sendrecv.c rc = writev(peer->sd, iov, iov_count); sd 174 orte/mca/oob/tcp/oob_tcp_sendrecv.c opal_socket_errno, peer->sd); sd 201 orte/mca/oob/tcp/oob_tcp_sendrecv.c void mca_oob_tcp_send_handler(int sd, short flags, void *cbdata) sd 247 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)ntohl(msg->hdr.nbytes), peer->sd); sd 256 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)ntohl(msg->hdr.nbytes), peer->sd); sd 270 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)ntohl(msg->hdr.nbytes), peer->sd); sd 291 orte/mca/oob/tcp/oob_tcp_sendrecv.c (int)ntohl(msg->hdr.nbytes), peer->sd); sd 307 orte/mca/oob/tcp/oob_tcp_sendrecv.c ORTE_NAME_PRINT(&(peer->name)), peer->sd); sd 337 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer->state, peer->sd); sd 352 orte/mca/oob/tcp/oob_tcp_sendrecv.c rc = read(peer->sd, peer->recv_msg->rdptr, peer->recv_msg->rdbytes); sd 429 orte/mca/oob/tcp/oob_tcp_sendrecv.c void mca_oob_tcp_recv_handler(int sd, short flags, void *cbdata) sd 444 orte/mca/oob/tcp/oob_tcp_sendrecv.c if (ORTE_SUCCESS == (rc = mca_oob_tcp_peer_recv_connect_ack(peer, peer->sd, NULL))) { sd 522 orte/mca/plm/alps/plm_alps_module.c static void alps_wait_cb(int sd, short args, void *cbdata) { sd 262 orte/mca/plm/rsh/plm_rsh_module.c static void rsh_wait_daemon(int sd, short flags, void *cbdata) sd 536 orte/mca/plm/slurm/plm_slurm_module.c static void srun_wait_cb(int sd, short fd, void *cbdata){ sd 105 orte/mca/rmaps/base/base.h ORTE_DECLSPEC void orte_rmaps_base_map_job(int sd, short args, void *cbdata); sd 225 orte/mca/rml/base/base.h ORTE_DECLSPEC void orte_rml_base_post_recv(int sd, short args, void *cbdata); sd 58 orte/mca/rml/base/rml_base_msg_handlers.c void orte_rml_base_post_recv(int sd, short args, void *cbdata) sd 68 orte/mca/state/hnp/state_hnp.c static void hnp_notify(int sd, short args, void *cbdata); sd 338 orte/mca/state/hnp/state_hnp.c static void hnp_notify(int sd, short args, void *cbdata) sd 142 orte/orted/orted_submit.c static void orte_timeout_wakeup(int sd, short args, void *cbdata); sd 143 orte/orted/orted_submit.c static void orte_profile_wakeup(int sd, short args, void *cbdata); sd 3160 orte/orted/orted_submit.c static void stack_trace_timeout(int sd, short args, void *cbdata) sd 3168 orte/orted/orted_submit.c void orte_timeout_wakeup(int sd, short args, void *cbdata) sd 3274 orte/orted/orted_submit.c static void profile_timeout(int sd, short args, void *cbdata) sd 3341 orte/orted/orted_submit.c void orte_profile_wakeup(int sd, short args, void *cbdata) sd 403 orte/orted/pmix/pmix_server.c static void _mdxresp(int sd, short args, void *cbdata) sd 108 orte/orted/pmix/pmix_server_dyn.c static void spawn(int sd, short args, void *cbdata) sd 535 orte/orted/pmix/pmix_server_dyn.c static void _cnct(int sd, short args, void *cbdata); sd 694 orte/orted/pmix/pmix_server_dyn.c static void _cnct(int sd, short args, void *cbdata) sd 131 orte/orted/pmix/pmix_server_fence.c static void dmodex_req(int sd, short args, void *cbdata) sd 55 orte/orted/pmix/pmix_server_gen.c static void _client_conn(int sd, short args, void *cbdata) sd 106 orte/orted/pmix/pmix_server_gen.c static void _client_finalized(int sd, short args, void *cbdata) sd 166 orte/orted/pmix/pmix_server_gen.c static void _client_abort(int sd, short args, void *cbdata) sd 220 orte/orted/pmix/pmix_server_gen.c static void _register_events(int sd, short args, void *cbdata) sd 254 orte/orted/pmix/pmix_server_gen.c static void _deregister_events(int sd, short args, void *cbdata) sd 483 orte/orted/pmix/pmix_server_gen.c static void _query(int sd, short args, void *cbdata) sd 849 orte/orted/pmix/pmix_server_gen.c static void _toolconn(int sd, short args, void *cbdata) sd 1046 orte/orted/pmix/pmix_server_gen.c static void lgcbfn(int sd, short args, void *cbdata) sd 153 orte/orted/pmix/pmix_server_pub.c static void execute(int sd, short args, void *cbdata) sd 30 orte/test/system/event-threads.c static void send_handler(int sd, short flags, void *arg); sd 109 orte/test/system/event-threads.c static void stop_handler(int sd, short flags, void* cbdata) sd 142 orte/test/system/event-threads.c static void send_handler(int sd, short flags, void *arg) sd 35 orte/test/system/evthread-test.c static void send_handler(int sd, short flags, void *arg); sd 108 orte/test/system/evthread-test.c static void stop_handler(int sd, short flags, void* cbdata) sd 145 orte/test/system/evthread-test.c static void send_handler(int sd, short flags, void *arg) sd 94 orte/util/listener.c int sd = -1; sd 118 orte/util/listener.c sd = socket(PF_UNIX, SOCK_STREAM, 0); sd 119 orte/util/listener.c if (sd < 0) { sd 128 orte/util/listener.c if (opal_fd_set_cloexec(sd) != OPAL_SUCCESS) { sd 132 orte/util/listener.c CLOSE_THE_SOCKET(sd); sd 137 orte/util/listener.c if (bind(sd, (struct sockaddr*)address, addrlen) < 0) { sd 142 orte/util/listener.c CLOSE_THE_SOCKET(sd); sd 147 orte/util/listener.c if (listen(sd, SOMAXCONN) < 0) { sd 150 orte/util/listener.c CLOSE_THE_SOCKET(sd); sd 155 orte/util/listener.c if ((flags = fcntl(sd, F_GETFL, 0)) < 0) { sd 158 orte/util/listener.c CLOSE_THE_SOCKET(sd); sd 162 orte/util/listener.c if (fcntl(sd, F_SETFL, flags) < 0) { sd 165 orte/util/listener.c CLOSE_THE_SOCKET(sd); sd 171 orte/util/listener.c conn->sd = sd; sd 236 orte/util/listener.c int rc, max, accepted_connections, sd; sd 247 orte/util/listener.c FD_SET(listener->sd, &readfds); sd 248 orte/util/listener.c max = (listener->sd > max) ? listener->sd : max; sd 280 orte/util/listener.c sd = listener->sd; sd 288 orte/util/listener.c if (0 == FD_ISSET(sd, &readfds)) { sd 304 orte/util/listener.c pending_connection->fd = accept(sd, sd 320 orte/util/listener.c CLOSE_THE_SOCKET(sd); sd 335 orte/util/listener.c CLOSE_THE_SOCKET(sd); sd 364 orte/util/listener.c p->sd = -1; sd 370 orte/util/listener.c if (0 <= p->sd) { sd 371 orte/util/listener.c CLOSE_THE_SOCKET(p->sd); sd 39 orte/util/listener.h typedef void (*orte_listener_callback_fn_t)(int sd, short args, void *cbdata); sd 46 orte/util/listener.h int sd;