Lines Matching refs:pi

245     struct method_context *mthd_ctxt, const proto_info_t *pi) __NORETURN;
837 proto_info_t *pi; in poll_bound_fds() local
840 for (pi = uu_list_first(cfg->proto_list); pi != NULL; in poll_bound_fds()
841 pi = uu_list_next(cfg->proto_list, pi)) { in poll_bound_fds()
842 if (pi->listen_fd != -1) { /* fd bound */ in poll_bound_fds()
844 strcmp(pi->proto, proto_name) == 0) { in poll_bound_fds()
846 clear_pollfd(pi->listen_fd); in poll_bound_fds()
847 } else if (set_pollfd(pi->listen_fd, in poll_bound_fds()
884 proto_info_t *pi; in handle_bind_failure() local
892 for (pi = uu_list_first(cfg->proto_list); pi != NULL; in handle_bind_failure()
893 pi = uu_list_next(cfg->proto_list, pi)) { in handle_bind_failure()
894 if ((pi->listen_fd != -1) && in handle_bind_failure()
895 (find_pollfd(pi->listen_fd) != NULL)) in handle_bind_failure()
898 if (pi != NULL) { /* polling on > 0 fds */ in handle_bind_failure()
1036 proto_info_t *pi; in is_rpc_num_in_use() local
1045 for (pi = uu_list_first(cfg->proto_list); pi != NULL; in is_rpc_num_in_use()
1046 pi = uu_list_next(cfg->proto_list, pi)) { in is_rpc_num_in_use()
1048 if (pi->ri == NULL) in is_rpc_num_in_use()
1050 if (pi->ri->prognum != rpc_n) in is_rpc_num_in_use()
1052 if (!is_rpc_proto_conflict(pi->proto, proto)) in is_rpc_num_in_use()
1054 if ((lowver < pi->ri->lowver && in is_rpc_num_in_use()
1055 highver < pi->ri->lowver) || in is_rpc_num_in_use()
1056 (lowver > pi->ri->highver && in is_rpc_num_in_use()
1057 highver > pi->ri->highver)) in is_rpc_num_in_use()
1081 proto_info_t *pi; in create_bound_fds() local
1086 for (pi = uu_list_first(cfg->proto_list); pi != NULL; in create_bound_fds()
1087 pi = uu_list_next(cfg->proto_list, pi)) { in create_bound_fds()
1088 if (pi->listen_fd != -1) in create_bound_fds()
1091 pi->listen_fd = create_bound_endpoint(instance, in create_bound_fds()
1092 (tlx_info_t *)pi); in create_bound_fds()
1102 void *p = pi; in create_bound_fds()
1103 pi->listen_fd = create_bound_socket(instance, in create_bound_fds()
1106 if (pi->listen_fd == -1) { in create_bound_fds()
1111 if (pi->ri != NULL) { in create_bound_fds()
1118 if (is_rpc_num_in_use(pi->ri->prognum, pi->proto, in create_bound_fds()
1119 pi->ri->lowver, pi->ri->highver)) { in create_bound_fds()
1121 close_net_fd(instance, pi->listen_fd); in create_bound_fds()
1122 pi->listen_fd = -1; in create_bound_fds()
1126 unregister_rpc_service(instance->fmri, pi->ri); in create_bound_fds()
1127 if (register_rpc_service(instance->fmri, pi->ri) == in create_bound_fds()
1129 close_net_fd(instance, pi->listen_fd); in create_bound_fds()
1130 pi->listen_fd = -1; in create_bound_fds()
1192 proto_info_t *pi; in destroy_bound_fds() local
1194 for (pi = uu_list_first(cfg->proto_list); pi != NULL; in destroy_bound_fds()
1195 pi = uu_list_next(cfg->proto_list, pi)) { in destroy_bound_fds()
1196 if (pi->listen_fd != -1) { in destroy_bound_fds()
1197 if (pi->ri != NULL) in destroy_bound_fds()
1198 unregister_rpc_service(instance->fmri, pi->ri); in destroy_bound_fds()
1199 clear_pollfd(pi->listen_fd); in destroy_bound_fds()
1200 close_net_fd(instance, pi->listen_fd); in destroy_bound_fds()
1201 pi->listen_fd = -1; in destroy_bound_fds()
1220 expand_address(instance_t *inst, const proto_info_t *pi) in expand_address() argument
1232 const void *p = pi; in expand_address()
2189 proto_info_t *pi; in process_start_term() local
2205 for (pi = uu_list_first(cfg->proto_list); pi != NULL; in process_start_term()
2206 pi = uu_list_next(cfg->proto_list, pi)) { in process_start_term()
2211 if (pi->listen_fd != -1) { in process_start_term()
2214 strcmp(pi->proto, proto_name) == 0) in process_start_term()
2218 if (pi != NULL) { in process_start_term()
2694 struct method_context *mthd_ctxt, const proto_info_t *pi) in exec_method() argument
2733 args = expand_address(instance, pi); in exec_method()
3171 pending_connections(instance_t *instance, proto_info_t *pi) in pending_connections() argument
3174 tlx_info_t *tl = (tlx_info_t *)pi; in pending_connections()
3183 accept_connection(instance_t *instance, proto_info_t *pi) in accept_connection() argument
3189 tlx_info_t *tl = (tlx_info_t *)pi; in accept_connection()
3193 fd = tlx_accept(instance->fmri, (tlx_info_t *)pi, in accept_connection()
3200 fd = accept(pi->listen_fd, in accept_connection()
3219 process_nowait_request(instance_t *instance, proto_info_t *pi) in process_nowait_request() argument
3227 if ((instance->conn_fd = accept_connection(instance, pi)) == -1) { in process_nowait_request()
3297 ret = run_method(instance, IM_START, pi); in process_nowait_request()
3345 process_wait_request(instance_t *instance, const proto_info_t *pi) in process_wait_request() argument
3352 instance->conn_fd = pi->listen_fd; in process_wait_request()
3416 ret = run_method(instance, IM_START, pi); in process_wait_request()
3425 (void) poll_bound_fds(instance, B_FALSE, pi->proto); in process_wait_request()
3440 proto_info_t *pi; in process_network_events() local
3457 for (pi = uu_list_first(cfg->proto_list); pi != NULL; in process_network_events()
3458 pi = uu_list_next(cfg->proto_list, pi)) { in process_network_events()
3459 if (((pi->listen_fd != -1) && in process_network_events()
3460 isset_pollfd(pi->listen_fd)) || in process_network_events()
3461 pending_connections(instance, pi)) { in process_network_events()
3463 process_wait_request(instance, pi); in process_network_events()
3465 process_nowait_request(instance, pi); in process_network_events()