Lines Matching refs:pi

243     struct method_context *mthd_ctxt, const proto_info_t *pi) __NORETURN;
835 proto_info_t *pi;
838 for (pi = uu_list_first(cfg->proto_list); pi != NULL;
839 pi = uu_list_next(cfg->proto_list, pi)) {
840 if (pi->listen_fd != -1) { /* fd bound */
842 strcmp(pi->proto, proto_name) == 0) {
844 clear_pollfd(pi->listen_fd);
845 } else if (set_pollfd(pi->listen_fd,
882 proto_info_t *pi;
890 for (pi = uu_list_first(cfg->proto_list); pi != NULL;
891 pi = uu_list_next(cfg->proto_list, pi)) {
892 if ((pi->listen_fd != -1) &&
893 (find_pollfd(pi->listen_fd) != NULL))
896 if (pi != NULL) { /* polling on > 0 fds */
1034 proto_info_t *pi;
1043 for (pi = uu_list_first(cfg->proto_list); pi != NULL;
1044 pi = uu_list_next(cfg->proto_list, pi)) {
1046 if (pi->ri == NULL)
1048 if (pi->ri->prognum != rpc_n)
1050 if (!is_rpc_proto_conflict(pi->proto, proto))
1052 if ((lowver < pi->ri->lowver &&
1053 highver < pi->ri->lowver) ||
1054 (lowver > pi->ri->highver &&
1055 highver > pi->ri->highver))
1079 proto_info_t *pi;
1084 for (pi = uu_list_first(cfg->proto_list); pi != NULL;
1085 pi = uu_list_next(cfg->proto_list, pi)) {
1086 if (pi->listen_fd != -1)
1089 pi->listen_fd = create_bound_endpoint(instance,
1090 (tlx_info_t *)pi);
1093 * We cast pi to a void so we can then go on to cast
1100 void *p = pi;
1101 pi->listen_fd = create_bound_socket(instance,
1104 if (pi->listen_fd == -1) {
1109 if (pi->ri != NULL) {
1116 if (is_rpc_num_in_use(pi->ri->prognum, pi->proto,
1117 pi->ri->lowver, pi->ri->highver)) {
1119 close_net_fd(instance, pi->listen_fd);
1120 pi->listen_fd = -1;
1124 unregister_rpc_service(instance->fmri, pi->ri);
1125 if (register_rpc_service(instance->fmri, pi->ri) ==
1127 close_net_fd(instance, pi->listen_fd);
1128 pi->listen_fd = -1;
1190 proto_info_t *pi;
1192 for (pi = uu_list_first(cfg->proto_list); pi != NULL;
1193 pi = uu_list_next(cfg->proto_list, pi)) {
1194 if (pi->listen_fd != -1) {
1195 if (pi->ri != NULL)
1196 unregister_rpc_service(instance->fmri, pi->ri);
1197 clear_pollfd(pi->listen_fd);
1198 close_net_fd(instance, pi->listen_fd);
1199 pi->listen_fd = -1;
1218 expand_address(instance_t *inst, const proto_info_t *pi)
1224 * We cast pi to a void so we can then go on to cast it to a
1230 const void *p = pi;
2187 proto_info_t *pi;
2203 for (pi = uu_list_first(cfg->proto_list); pi != NULL;
2204 pi = uu_list_next(cfg->proto_list, pi)) {
2209 if (pi->listen_fd != -1) {
2212 strcmp(pi->proto, proto_name) == 0)
2216 if (pi != NULL) {
2692 struct method_context *mthd_ctxt, const proto_info_t *pi)
2724 args = expand_address(instance, pi);
3162 pending_connections(instance_t *instance, proto_info_t *pi)
3165 tlx_info_t *tl = (tlx_info_t *)pi;
3174 accept_connection(instance_t *instance, proto_info_t *pi)
3180 tlx_info_t *tl = (tlx_info_t *)pi;
3184 fd = tlx_accept(instance->fmri, (tlx_info_t *)pi,
3191 fd = accept(pi->listen_fd,
3210 process_nowait_request(instance_t *instance, proto_info_t *pi)
3218 if ((instance->conn_fd = accept_connection(instance, pi)) == -1) {
3288 ret = run_method(instance, IM_START, pi);
3336 process_wait_request(instance_t *instance, const proto_info_t *pi)
3343 instance->conn_fd = pi->listen_fd;
3407 ret = run_method(instance, IM_START, pi);
3416 (void) poll_bound_fds(instance, B_FALSE, pi->proto);
3431 proto_info_t *pi;
3448 for (pi = uu_list_first(cfg->proto_list); pi != NULL;
3449 pi = uu_list_next(cfg->proto_list, pi)) {
3450 if (((pi->listen_fd != -1) &&
3451 isset_pollfd(pi->listen_fd)) ||
3452 pending_connections(instance, pi)) {
3454 process_wait_request(instance, pi);
3456 process_nowait_request(instance, pi);