201 		struct mtcp_epoll *ep, socket_map_t socket)  in RaisePendingStreamEvents()  argument
203 	tcp_stream *stream = socket->stream;  in RaisePendingStreamEvents()
214 	if (socket->epoll & MOS_EPOLLIN) {  in RaisePendingStreamEvents()
217 			TRACE_EPOLL("Socket %d: Has existing payloads\n", socket->id);  in RaisePendingStreamEvents()
218 			AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN);  in RaisePendingStreamEvents()
220 			TRACE_EPOLL("Socket %d: Waiting for close\n", socket->id);  in RaisePendingStreamEvents()
221 			AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN);  in RaisePendingStreamEvents()
226 	if (socket->epoll & MOS_EPOLLOUT) {  in RaisePendingStreamEvents()
230 			if (!(socket->events & MOS_EPOLLOUT)) {  in RaisePendingStreamEvents()
231 				TRACE_EPOLL("Socket %d: Adding write event\n", socket->id);  in RaisePendingStreamEvents()
232 				AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLOUT);  in RaisePendingStreamEvents()
246 	socket_map_t socket;  in mtcp_epoll_ctl()  local
281 	socket = &mtcp->smap[sockid];  in mtcp_epoll_ctl()
284 		if (socket->epoll) {  in mtcp_epoll_ctl()
292 		socket->ep_data = event->data;  in mtcp_epoll_ctl()
293 		socket->epoll = events;  in mtcp_epoll_ctl()
296 			    socket->id, socket->socktype,  in mtcp_epoll_ctl()
297 			    (unsigned long long)socket->epoll & MOS_EPOLLET,   in mtcp_epoll_ctl()
298 			    (unsigned long long)socket->epoll & MOS_EPOLLIN,  in mtcp_epoll_ctl()
299 			    (unsigned long long)socket->epoll & MOS_EPOLLOUT);  in mtcp_epoll_ctl()
301 		if (socket->socktype == MOS_SOCK_STREAM) {  in mtcp_epoll_ctl()
302 			RaisePendingStreamEvents(mtcp, ep, socket);  in mtcp_epoll_ctl()
303 		} else if (socket->socktype == MOS_SOCK_PIPE) {  in mtcp_epoll_ctl()
308 		if (!socket->epoll) {  in mtcp_epoll_ctl()
316 		socket->ep_data = event->data;  in mtcp_epoll_ctl()
317 		socket->epoll = events;  in mtcp_epoll_ctl()
319 		if (socket->socktype == MOS_SOCK_STREAM) {  in mtcp_epoll_ctl()
320 			RaisePendingStreamEvents(mtcp, ep, socket);  in mtcp_epoll_ctl()
321 		} else if (socket->socktype == MOS_SOCK_PIPE) {  in mtcp_epoll_ctl()
326 		if (!socket->epoll) {  in mtcp_epoll_ctl()
331 		socket->epoll = MOS_EPOLLNONE;  in mtcp_epoll_ctl()
545 		int queue_type, socket_map_t socket, uint32_t event)  in AddEpollEvent()  argument
553 	if (!ep || !socket || !event)  in AddEpollEvent()
558 	if (socket->events & event) {  in AddEpollEvent()
584 	socket->events |= event;  in AddEpollEvent()
585 	eq->events[index].sockid = socket->id;  in AddEpollEvent()
587 	eq->events[index].ev.data = socket->ep_data;  in AddEpollEvent()