27 	socket_map_t socket[2];  member
42 	socket_map_t socket[2];  in mtcp_pipe()  local
46 	socket[0] = AllocateSocket(mctx, MOS_SOCK_PIPE);  in mtcp_pipe()
47 	if (!socket[0]) {  in mtcp_pipe()
51 	socket[1] = AllocateSocket(mctx, MOS_SOCK_PIPE);  in mtcp_pipe()
52 	if (!socket[1]) {  in mtcp_pipe()
53 		FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
61 		FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
62 		FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
70 		FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
71 		FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
79 		FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
80 		FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
89 		FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
90 		FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE);  in mtcp_pipe()
98 	pp->socket[0] = socket[0];  in mtcp_pipe()
99 	pp->socket[1] = socket[1];  in mtcp_pipe()
100 	socket[0]->pp = pp;  in mtcp_pipe()
101 	socket[1]->pp = pp;  in mtcp_pipe()
103 	pipeid[0] = socket[0]->id;  in mtcp_pipe()
104 	pipeid[1] = socket[1]->id;  in mtcp_pipe()
111 RaiseEventToPair(mtcp_manager_t mtcp, socket_map_t socket, uint32_t event)  in RaiseEventToPair()  argument
113 	struct pipe *pp = socket->pp;  in RaiseEventToPair()
116 	if (pp->socket[0] == socket)  in RaiseEventToPair()
117 		pair_socket = pp->socket[1];  in RaiseEventToPair()
119 		pair_socket = pp->socket[0];  in RaiseEventToPair()
134 	socket_map_t socket;  in PipeRead()  local
144 	socket = GetSocket(mctx, pipeid);  in PipeRead()
145 	if (!socket) {  in PipeRead()
148 	if (socket->socktype != MOS_SOCK_PIPE) {  in PipeRead()
152 	pp = socket->pp;  in PipeRead()
166 		if (socket->opts & MTCP_NONBLOCK) {  in PipeRead()
175 	if (!(socket->opts & MTCP_NONBLOCK)) {  in PipeRead()
215 		RaiseEventToPair(mtcp, socket, MOS_EPOLLOUT);  in PipeRead()
222 		if ((socket->epoll & MOS_EPOLLIN) && !(socket->epoll & MOS_EPOLLET)) {  in PipeRead()
224 					USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN);  in PipeRead()
227 		AddEpollEvent(mtcp->ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN);  in PipeRead()
237 	socket_map_t socket;  in PipeWrite()  local
247 	socket = GetSocket(mctx, pipeid);  in PipeWrite()
248 	if (!socket) {  in PipeWrite()
251 	if (socket->socktype != MOS_SOCK_PIPE) {  in PipeWrite()
255 	pp = socket->pp;  in PipeWrite()
270 		if (socket->opts & MTCP_NONBLOCK) {  in PipeWrite()
279 	if (!(socket->opts & MTCP_NONBLOCK)) {  in PipeWrite()
317 		RaiseEventToPair(mtcp, socket, MOS_EPOLLIN);  in PipeWrite()
324 		if ((socket->epoll & MOS_EPOLLOUT) && !(socket->epoll & MOS_EPOLLET)) {  in PipeWrite()
326 					USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLOUT);  in PipeWrite()
337 	socket_map_t socket = GetSocket(mctx, pipeid);  in RaisePendingPipeEvents()  local
338 	struct pipe *pp = socket->pp;  in RaisePendingPipeEvents()
347 	if (socket->epoll & MOS_EPOLLIN) {  in RaisePendingPipeEvents()
349 			AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN);  in RaisePendingPipeEvents()
351 			AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN);  in RaisePendingPipeEvents()
356 	if (socket->epoll & MOS_EPOLLOUT) {  in RaisePendingPipeEvents()
358 			AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLOUT);  in RaisePendingPipeEvents()
369 	socket_map_t socket;  in PipeClose()  local
376 	socket = GetSocket(mctx, pipeid);  in PipeClose()
377 	if (!socket) {  in PipeClose()
380 	if (socket->socktype != MOS_SOCK_PIPE) {  in PipeClose()
384 	pp = socket->pp;  in PipeClose()
396 		RaiseEventToPair(mtcp, socket, MOS_EPOLLIN);  in PipeClose()
403 	if (pp->socket[0])  in PipeClose()
404 		pp->socket[0]->pp = NULL;  in PipeClose()
405 	if (pp->socket[1])  in PipeClose()
406 		pp->socket[1]->pp = NULL;  in PipeClose()