bsd/kern/sys_generic.c

116 #include <sys/pipe.h>
143 void evpipefree(struct pipe *);
144 void postpipeevent(struct pipe *, int);
1957  * called upon pipe close. deque and free all events for
1958  * the pipe... pipe must be locked by caller
1961 evpipefree(struct pipe *cpipe)
1972 		TAILQ_REMOVE(&cpipe->pipe_evlist, evq, ee_slist); // remove from pipe q
2015  * pipe lock must be taken by the caller
2018 postpipeevent(struct pipe *pipep, int event)
2079 			 * the pipe lock, and we're updating the event outside
2347 		PIPE_LOCK((struct pipe *)fp->f_data);
2348 		np = ((struct pipe *)fp->f_data)->pipe_evlist.tqh_first;
2372 				PIPE_UNLOCK((struct pipe *)fp->f_data);
2394 		TAILQ_INSERT_TAIL(&((struct pipe *)fp->f_data)->pipe_evlist, evq, ee_slist);
2395 		postpipeevent((struct pipe *)fp->f_data, EV_RWBYTES);
2397 		PIPE_UNLOCK((struct pipe *)fp->f_data);
2586 		PIPE_LOCK((struct pipe *)fp->f_data);
2587 		evq = ((struct pipe *)fp->f_data)->pipe_evlist.tqh_first;
2615 			PIPE_UNLOCK((struct pipe *)fp->f_data);
2632 			TAILQ_REMOVE(&((struct pipe *)fp->f_data)->pipe_evlist, evq, ee_slist);
2633 			PIPE_UNLOCK((struct pipe *)fp->f_data);
2668 			PIPE_UNLOCK((struct pipe *)fp->f_data);
2674 	 * since we're holding the socket/pipe lock, the event
2690 	 * we're holding the socket/pipe lock
2703 		postpipeevent((struct pipe *)fp->f_data, flag);
2704 		PIPE_UNLOCK((struct pipe *)fp->f_data);
2727 	        PIPE_LOCK((struct pipe *)fp->f_data);
2728 		evq = ((struct pipe *)fp->f_data)->pipe_evlist.tqh_first;
2747 		        PIPE_UNLOCK((struct pipe *)fp->f_data);
2762 		TAILQ_REMOVE(&((struct pipe *)fp->f_data)->pipe_evlist, evq, ee_slist);
2763 		PIPE_UNLOCK((struct pipe *)fp->f_data);