/dports/net/mpich2/mpich2-1.5/src/mpid/common/sock/poll/ |
H A D | sock_set.i | 27 if (sock_set == NULL) in MPIDU_Sock_create_set() 39 sock_set->pollfds = NULL; in MPIDU_Sock_create_set() 51 sock_set->intr_fds[0] = -1; in MPIDU_Sock_create_set() 52 sock_set->intr_fds[1] = -1; in MPIDU_Sock_create_set() 53 sock_set->intr_sock = NULL; in MPIDU_Sock_create_set() 123 sock_set->intr_sock = sock; in MPIDU_Sock_create_set() 140 *sock_setp = sock_set; in MPIDU_Sock_create_set() 148 if (sock_set != NULL) in MPIDU_Sock_create_set() 166 MPIU_Free(sock_set); in MPIDU_Sock_create_set() 232 sock_set->id = ~0; in MPIDU_Sock_destroy_set() [all …]
|
H A D | socki_util.i | 401 sock_set->pollfds[elem].events = sock_set->pollinfos[elem].pollfd_events; in MPIDI_Sock_update_sock_set() 403 sock_set->pollfds[elem].fd = sock_set->pollinfos[elem].fd; in MPIDI_Sock_update_sock_set() 410 if (sock_set->pollfds_active == sock_set->pollfds) { in MPIDI_Sock_update_sock_set() 423 if (sock_set->pollfds_active != sock_set->pollfds) { in MPIDI_Sock_update_sock_set() 653 if (sock_set->pollfds_active != sock_set->pollfds) in MPIDU_Socki_sock_alloc() 681 pollinfos[elem].sock_set = sock_set; in MPIDU_Socki_sock_alloc() 698 MPIU_Assert(sock_set->pollinfos[avail_elem].sock_set == sock_set); in MPIDU_Socki_sock_alloc() 716 sock->sock_set = sock_set; in MPIDU_Socki_sock_alloc() 771 struct MPIDU_Sock_set * sock_set = sock->sock_set; in MPIDU_Socki_sock_free() local 794 if (sock_set->starting_elem >= sock_set->poll_array_elems) in MPIDU_Socki_sock_free() [all …]
|
H A D | sock_wait.i | 72 pollinfo = &sock_set->pollinfos[elem]; in MPIDU_Sock_wait() 110 n_fds = poll(sock_set->pollfds, sock_set->poll_array_elems, in MPIDU_Sock_wait() 124 n_fds = poll(sock_set->pollfds, sock_set->poll_array_elems, in MPIDU_Sock_wait() 137 n_fds = poll(sock_set->pollfds, sock_set->poll_array_elems, 0); in MPIDU_Sock_wait() 154 sock_set->pollfds_active = sock_set->pollfds; in MPIDU_Sock_wait() 180 if (sock_set->pollfds_updated) { in MPIDU_Sock_wait() 185 sock_set->pollfds_active = NULL; in MPIDU_Sock_wait() 186 sock_set->wakeup_posted = FALSE; in MPIDU_Sock_wait() 227 elem = sock_set->starting_elem; in MPIDU_Sock_wait() 228 n_elems = sock_set->poll_array_elems; in MPIDU_Sock_wait() [all …]
|
H A D | sock_immed.i | 22 struct MPIDU_Sock_set * sock_set, void * user_ptr, in MPIDU_Sock_accept() argument 41 MPIDU_SOCKI_VALIDATE_SOCK_SET(sock_set, mpi_errno, fn_exit); in MPIDU_Sock_accept() 52 pollinfo->sock_set->id, pollinfo->sock_id); in MPIDU_Sock_accept() 62 pollinfo->sock_set->id, pollinfo->sock_id, pollinfo->state); in MPIDU_Sock_accept() 106 pollinfo->sock_set->id, pollinfo->sock_id, in MPIDU_Sock_accept() 219 mpi_errno = MPIDU_Socki_sock_alloc(sock_set, &sock); in MPIDU_Sock_accept() 316 pollinfo->sock_set->id, pollinfo->sock_id); in MPIDU_Sock_read() 429 pollinfo->sock_set->id, pollinfo->sock_id); in MPIDU_Sock_readv() 665 int MPIDU_Sock_wakeup(struct MPIDU_Sock_set * sock_set) in MPIDU_Sock_wakeup() argument 685 pollinfo = MPIDU_Socki_sock_get_pollinfo(sock_set->intr_sock); in MPIDU_Sock_wakeup() [all …]
|
H A D | sock_post.i | 32 int MPIDU_Sock_post_connect_ifaddr( struct MPIDU_Sock_set * sock_set, in MPIDU_Sock_post_connect_ifaddr() argument 98 mpi_errno = MPIDU_Socki_sock_alloc(sock_set, &sock); in MPIDU_Sock_post_connect_ifaddr() 167 pollinfo->sock_set->id, pollinfo->sock_id, ""), mpi_errno, fn_fail); in MPIDU_Sock_post_connect_ifaddr() 238 mpi_errno = MPIDU_Sock_post_connect_ifaddr( sock_set, user_ptr, in MPIDU_Sock_post_connect() 253 int MPIDU_Sock_listen(struct MPIDU_Sock_set * sock_set, void * user_ptr, in MPIDU_Sock_listen() argument 412 mpi_errno = MPIDU_Socki_sock_alloc(sock_set, &sock); in MPIDU_Sock_listen() 481 pollinfo->sock_set->id, pollinfo->sock_id, minlen, maxlen); in MPIDU_Sock_post_read() 530 pollinfo->sock_set->id, pollinfo->sock_id, iov_n); in MPIDU_Sock_post_readv() 580 pollinfo->sock_set->id, pollinfo->sock_id, minlen, maxlen); in MPIDU_Sock_post_write() 629 pollinfo->sock_set->id, pollinfo->sock_id, iov_n); in MPIDU_Sock_post_writev() [all …]
|
H A D | sock_misc.i | 101 int MPIDU_Sock_native_to_sock(struct MPIDU_Sock_set * sock_set, MPIDU_SOCK_NATIVE_FD fd, void *user… in MPIDU_Sock_native_to_sock() argument 117 mpi_errno = MPIDU_Socki_sock_alloc(sock_set, &sock); in MPIDU_Sock_native_to_sock() 192 sock->sock_set != MPIDU_SOCK_INVALID_SET) in MPIDU_Sock_set_user_ptr() 227 if (sock->sock_set != MPIDU_SOCK_INVALID_SET) in MPIDU_Sock_get_sock_id() 249 int MPIDU_Sock_get_sock_set_id(struct MPIDU_Sock_set * sock_set) in MPIDU_Sock_get_sock_set_id() argument 256 if (sock_set != MPIDU_SOCK_INVALID_SET) in MPIDU_Sock_get_sock_set_id() 258 id = sock_set->id; in MPIDU_Sock_get_sock_set_id()
|
H A D | sock.c | 94 struct MPIDU_Sock_set * sock_set; member 192 struct MPIDU_Sock_set * sock_set; member
|
H A D | .state-cache | 6 <file name="sock_set.i" info="1194043819"/> 54 <fileinfo name="sock_set.i">
|
/dports/net/mpich2/mpich2-1.5/src/pm/smpd/sock/poll/ |
H A D | smpd_sock_set.i | 26 if (sock_set == NULL) in SMPDU_Sock_create_set() 35 sock_set->poll_array_sz = 0; in SMPDU_Sock_create_set() 37 sock_set->starting_elem = 0; in SMPDU_Sock_create_set() 38 sock_set->pollfds = NULL; in SMPDU_Sock_create_set() 39 sock_set->pollinfos = NULL; in SMPDU_Sock_create_set() 46 *sock_setp = sock_set; in SMPDU_Sock_create_set() 54 if (sock_set != NULL) in SMPDU_Sock_create_set() 56 MPIU_Free(sock_set); in SMPDU_Sock_create_set() 105 sock_set->id = ~0; in SMPDU_Sock_destroy_set() 109 sock_set->pollfds = NULL; in SMPDU_Sock_destroy_set() [all …]
|
H A D | smpd_socki_util.i | 444 memcpy(pollfds, sock_set->pollfds, sock_set->poll_array_sz * sizeof(struct pollfd)); in SMPDU_Socki_sock_alloc() 445 MPIU_Free(sock_set->pollfds); in SMPDU_Socki_sock_alloc() 454 sock_set->pollfds = pollfds; in SMPDU_Socki_sock_alloc() 469 pollinfos[elem].sock_set = sock_set; in SMPDU_Socki_sock_alloc() 481 MPIU_Assert(sock_set->pollinfos[avail_elem].sock_set == sock_set); in SMPDU_Socki_sock_alloc() 492 sock_set->pollinfos[avail_elem].sock_id = (sock_set->id << 24) | avail_elem; in SMPDU_Socki_sock_alloc() 494 sock->sock_set = sock_set; in SMPDU_Socki_sock_alloc() 538 struct SMPDU_Sock_set * sock_set = sock->sock_set; in SMPDU_Socki_sock_free() local 550 if (sock_set->starting_elem >= sock_set->poll_array_elems) in SMPDU_Socki_sock_free() 572 sock->sock_set = NULL; in SMPDU_Socki_sock_free() [all …]
|
H A D | smpd_sock_misc.i | 93 int SMPDU_Sock_native_to_sock(struct SMPDU_Sock_set * sock_set, SMPDU_SOCK_NATIVE_FD fd, void *user… in SMPDU_Sock_native_to_sock() argument 108 result = SMPDU_Socki_sock_alloc(sock_set, &sock); in SMPDU_Sock_native_to_sock() 182 sock->sock_set != SMPDU_SOCK_INVALID_SET) in SMPDU_Sock_set_user_ptr() 217 if (sock->sock_set != SMPDU_SOCK_INVALID_SET) in SMPDU_Sock_get_sock_id() 239 int SMPDU_Sock_get_sock_set_id(struct SMPDU_Sock_set * sock_set) in SMPDU_Sock_get_sock_set_id() argument 245 if (sock_set != SMPDU_SOCK_INVALID_SET) in SMPDU_Sock_get_sock_set_id() 247 id = sock_set->id; in SMPDU_Sock_get_sock_set_id()
|
H A D | smpd_sock_wait.i | 54 result = SMPDU_Socki_event_dequeue(sock_set, &elem, eventp); in SMPDU_Sock_wait() 64 pollinfo = &sock_set->pollinfos[elem]; in SMPDU_Sock_wait() 101 n_fds = poll(sock_set->pollfds, sock_set->poll_array_elems, in SMPDU_Sock_wait() 135 elem = sock_set->starting_elem; in SMPDU_Sock_wait() 136 n_elems = sock_set->poll_array_elems; in SMPDU_Sock_wait() 145 struct pollfd * const pollfd = &sock_set->pollfds[elem]; in SMPDU_Sock_wait() 146 struct pollinfo * const pollinfo = &sock_set->pollinfos[elem]; in SMPDU_Sock_wait() 155 elem = (elem + 1 < sock_set->poll_array_elems) ? elem + 1 : 0; in SMPDU_Sock_wait() 162 sock_set->starting_elem = (elem + 1 < sock_set->poll_array_elems) ? elem + 1 : 0; in SMPDU_Sock_wait() 280 elem = (elem + 1 < sock_set->poll_array_elems) ? elem + 1 : 0; in SMPDU_Sock_wait() [all …]
|
H A D | smpd_sock_post.i | 32 int SMPDU_Sock_post_connect_ifaddr( struct SMPDU_Sock_set * sock_set, in SMPDU_Sock_post_connect_ifaddr() argument 95 result = SMPDU_Socki_sock_alloc(sock_set, &sock); in SMPDU_Sock_post_connect_ifaddr() 199 int SMPDU_Sock_post_connect(struct SMPDU_Sock_set * sock_set, void * user_ptr, in SMPDU_Sock_post_connect() argument 230 result = SMPDU_Sock_post_connect_ifaddr( sock_set, user_ptr, in SMPDU_Sock_post_connect() 245 int SMPDU_Sock_listen(struct SMPDU_Sock_set * sock_set, void * user_ptr, in SMPDU_Sock_listen() argument 405 result = SMPDU_Socki_sock_alloc(sock_set, &sock); in SMPDU_Sock_listen() 472 pollinfo->sock_set->id, pollinfo->sock_id, minlen, maxlen); in SMPDU_Sock_post_read() 520 pollinfo->sock_set->id, pollinfo->sock_id, iov_n); in SMPDU_Sock_post_readv() 569 pollinfo->sock_set->id, pollinfo->sock_id, minlen, maxlen); in SMPDU_Sock_post_write() 617 pollinfo->sock_set->id, pollinfo->sock_id, iov_n); in SMPDU_Sock_post_writev() [all …]
|
H A D | smpd_sock_immed.i | 22 struct SMPDU_Sock_set * sock_set, void * user_ptr, in SMPDU_Sock_accept() argument 40 SMPDU_SOCKI_VALIDATE_SOCK_SET(sock_set, result, fn_exit); in SMPDU_Sock_accept() 67 …cket state, sock_set->id = %d, sock_id = %d, state = %d\n", pollinfo->sock_set->id, pollinfo->so… in SMPDU_Sock_accept() 195 result = SMPDU_Socki_sock_alloc(sock_set, &sock); in SMPDU_Sock_accept() 643 int SMPDU_Sock_wakeup(struct SMPDU_Sock_set * sock_set) in SMPDU_Sock_wakeup() argument 650 SMPDU_SOCKI_VALIDATE_SOCK_SET(sock_set, result, fn_exit); in SMPDU_Sock_wakeup()
|
H A D | smpd_util_sock.c | 95 struct SMPDU_Sock_set * sock_set; member 172 struct SMPDU_Sock_set * sock_set; member
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/sock/src/ |
H A D | sock.c | 584 sock_set->pollfds[elem].fd = sock_set->pollinfos[elem].fd; in MPIDI_Sock_update_sock_set() 590 if (sock_set->pollfds_active == sock_set->pollfds) { in MPIDI_Sock_update_sock_set() 602 if (sock_set->pollfds_active != sock_set->pollfds) { in MPIDI_Sock_update_sock_set() 828 if (sock_set->pollfds_active != sock_set->pollfds) { in MPIDI_CH3I_Socki_sock_alloc() 854 pollinfos[elem].sock_set = sock_set; in MPIDI_CH3I_Socki_sock_alloc() 871 MPIR_Assert(sock_set->pollinfos[avail_elem].sock_set == sock_set); in MPIDI_CH3I_Socki_sock_alloc() 889 sock->sock_set = sock_set; in MPIDI_CH3I_Socki_sock_alloc() 929 struct MPIDI_CH3I_Sock_set *sock_set = sock->sock_set; in MPIDI_CH3I_Socki_sock_free() local 951 if (sock_set->starting_elem >= sock_set->poll_array_elems) { in MPIDI_CH3I_Socki_sock_free() 991 struct MPIDI_CH3I_Sock_set *sock_set = pollinfo->sock_set; in MPIDI_CH3I_Socki_event_enqueue() local [all …]
|
/dports/games/warmux/warmux-11.04/tools/servers/index_server/ |
H A D | server.cpp | 56 FD_ZERO(&sock_set); in Server() 57 FD_SET(fd, &sock_set); in Server() 72 return sock_set; in GetSockSet() 89 FD_SET(client_fd, &sock_set); in NewConnection() 102 FD_CLR(client_fd, &sock_set); in CloseConnection()
|
/dports/www/dillo2/dillo-3.0.5/dpid/ |
H A D | dpid.c | 612 FD_ZERO(&sock_set); in init_ids_srs_socket() 619 FD_SET(srs_fd, &sock_set); in init_ids_srs_socket() 639 FD_SET(s_fd, &sock_set); in init_dpi_socket() 691 FD_SET(dpi_attr_list[i].sock_fd, &sock_set); in handle_sigchld() 784 FD_CLR(dpi_attr_list[i].sock_fd, &sock_set); in ignore_dpi_sockets() 804 FD_ZERO(&sock_set); in register_all_cmd() 805 FD_SET(srs_fd, &sock_set); in register_all_cmd()
|
/dports/chinese/FreeWnn-server/FreeWnn-1.1.1-a021/Xwnmo/xwnmo/ |
H A D | do_socket.c | 117 #define sock_set(array,pos) (array[pos/BINTSIZE] |= (1<<(pos%BINTSIZE))) macro 315 sock_set (all_socks, so); in init_net_un() 373 sock_set (all_socks, so); in init_net_in() 412 sock_set (all_socks, fd); 610 sock_set (all_socks, cur_sock); 640 sock_set (all_socks, cur_sock);
|
H A D | do_xjpdrct.c | 88 #define sock_set(array,pos) (array[pos/BINTSIZE] |= (1<<(pos%BINTSIZE))) macro 145 sock_set (all_socks, so); in xjp_init_net_un() 208 sock_set (all_socks, so); in xjp_init_net_in() 403 sock_set (all_socks, cur_sock); 430 sock_set (all_socks, cur_sock);
|
/dports/chinese/FreeWnn-lib/FreeWnn-1.1.1-a021/Xwnmo/xwnmo/ |
H A D | do_socket.c | 117 #define sock_set(array,pos) (array[pos/BINTSIZE] |= (1<<(pos%BINTSIZE))) macro 315 sock_set (all_socks, so); in init_net_un() 373 sock_set (all_socks, so); in init_net_in() 412 sock_set (all_socks, fd); 610 sock_set (all_socks, cur_sock); 640 sock_set (all_socks, cur_sock);
|
/dports/japanese/FreeWnn-server/FreeWnn-1.1.1-a021/Xwnmo/xwnmo/ |
H A D | do_socket.c | 117 #define sock_set(array,pos) (array[pos/BINTSIZE] |= (1<<(pos%BINTSIZE))) macro 315 sock_set (all_socks, so); in init_net_un() 373 sock_set (all_socks, so); in init_net_in() 412 sock_set (all_socks, fd); 610 sock_set (all_socks, cur_sock); 640 sock_set (all_socks, cur_sock);
|
/dports/japanese/FreeWnn-lib/FreeWnn-1.1.1-a021/Xwnmo/xwnmo/ |
H A D | do_socket.c | 117 #define sock_set(array,pos) (array[pos/BINTSIZE] |= (1<<(pos%BINTSIZE))) macro 315 sock_set (all_socks, so); in init_net_un() 373 sock_set (all_socks, so); in init_net_in() 412 sock_set (all_socks, fd); 610 sock_set (all_socks, cur_sock); 640 sock_set (all_socks, cur_sock);
|
/dports/korean/FreeWnn-lib/FreeWnn-1.1.1-a021/Xwnmo/xwnmo/ |
H A D | do_socket.c | 117 #define sock_set(array,pos) (array[pos/BINTSIZE] |= (1<<(pos%BINTSIZE))) macro 315 sock_set (all_socks, so); in init_net_un() 373 sock_set (all_socks, so); in init_net_in() 412 sock_set (all_socks, fd); 610 sock_set (all_socks, cur_sock); 640 sock_set (all_socks, cur_sock);
|
/dports/korean/FreeWnn-server/FreeWnn-1.1.1-a021/Xwnmo/xwnmo/ |
H A D | do_socket.c | 117 #define sock_set(array,pos) (array[pos/BINTSIZE] |= (1<<(pos%BINTSIZE))) macro 315 sock_set (all_socks, so); in init_net_un() 373 sock_set (all_socks, so); in init_net_in() 412 sock_set (all_socks, fd); 610 sock_set (all_socks, cur_sock); 640 sock_set (all_socks, cur_sock);
|