58 ctfs_endpoint_open(ctfs_endpoint_t *endpt, ct_equeue_t *q, int flag)  in ctfs_endpoint_open()  argument
63 	mutex_enter(&endpt->ctfs_endpt_lock);  in ctfs_endpoint_open()
64 	if ((endpt->ctfs_endpt_flags & CTFS_ENDPT_SETUP) == 0) {  in ctfs_endpoint_open()
65 		endpt->ctfs_endpt_flags |= CTFS_ENDPT_SETUP;  in ctfs_endpoint_open()
67 			endpt->ctfs_endpt_flags |= CTFS_ENDPT_NBLOCK;  in ctfs_endpoint_open()
68 		cte_add_listener(q, &endpt->ctfs_endpt_listener);  in ctfs_endpoint_open()
70 	mutex_exit(&endpt->ctfs_endpt_lock);  in ctfs_endpoint_open()
82 ctfs_endpoint_inactive(ctfs_endpoint_t *endpt)  in ctfs_endpoint_inactive()  argument
84 	mutex_enter(&endpt->ctfs_endpt_lock);  in ctfs_endpoint_inactive()
85 	if (endpt->ctfs_endpt_flags & CTFS_ENDPT_SETUP) {  in ctfs_endpoint_inactive()
86 		endpt->ctfs_endpt_flags = 0;  in ctfs_endpoint_inactive()
87 		cte_remove_listener(&endpt->ctfs_endpt_listener);  in ctfs_endpoint_inactive()
89 	pollhead_clean(&endpt->ctfs_endpt_listener.ctl_pollhead);  in ctfs_endpoint_inactive()
90 	mutex_exit(&endpt->ctfs_endpt_lock);  in ctfs_endpoint_inactive()
104 ctfs_endpoint_ioctl(ctfs_endpoint_t *endpt, int cmd, intptr_t arg, cred_t *cr,  in ctfs_endpoint_ioctl()  argument
113 		cte_reset_listener(&endpt->ctfs_endpt_listener);  in ctfs_endpoint_ioctl()
121 		return (cte_get_event(&endpt->ctfs_endpt_listener,  in ctfs_endpoint_ioctl()
122 		    endpt->ctfs_endpt_flags & CTFS_ENDPT_NBLOCK,  in ctfs_endpoint_ioctl()
125 		return (cte_get_event(&endpt->ctfs_endpt_listener,  in ctfs_endpoint_ioctl()
126 		    endpt->ctfs_endpt_flags & CTFS_ENDPT_NBLOCK,  in ctfs_endpoint_ioctl()
131 		return (cte_next_event(&endpt->ctfs_endpt_listener, id));  in ctfs_endpoint_ioctl()
133 		return (cte_set_reliable(&endpt->ctfs_endpt_listener, cr));  in ctfs_endpoint_ioctl()
147 ctfs_endpoint_poll(ctfs_endpoint_t *endpt, short events, int anyyet,  in ctfs_endpoint_poll()  argument
150 	if ((events & POLLIN) && endpt->ctfs_endpt_listener.ctl_position) {  in ctfs_endpoint_poll()
155 			*php = &endpt->ctfs_endpt_listener.ctl_pollhead;  in ctfs_endpoint_poll()