Home
last modified time | relevance | path

Searched refs:sock_set (Results 1 – 25 of 71) sorted by relevance

123

/dports/net/mpich2/mpich2-1.5/src/mpid/common/sock/poll/
H A Dsock_set.i27 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 Dsocki_util.i401 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 Dsock_wait.i72 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 Dsock_immed.i22 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 Dsock_post.i32 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 Dsock_misc.i101 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 Dsock.c94 struct MPIDU_Sock_set * sock_set; member
192 struct MPIDU_Sock_set * sock_set; member
H A D.state-cache6 <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 Dsmpd_sock_set.i26 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 Dsmpd_socki_util.i444 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 Dsmpd_sock_misc.i93 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 Dsmpd_sock_wait.i54 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 Dsmpd_sock_post.i32 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 Dsmpd_sock_immed.i22 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 Dsmpd_util_sock.c95 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 Dsock.c584 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 Dserver.cpp56 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 Ddpid.c612 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 Ddo_socket.c117 #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 Ddo_xjpdrct.c88 #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 Ddo_socket.c117 #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 Ddo_socket.c117 #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 Ddo_socket.c117 #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 Ddo_socket.c117 #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 Ddo_socket.c117 #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);

123