Lines Matching defs:pi

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