159 			ev.events = MOS_EPOLLIN;  in SendUntilAvailable()
261 	ev.events = MOS_EPOLLIN | MOS_EPOLLOUT;  in HandleReadEvent()
289 		ev.events = MOS_EPOLLIN;  in AcceptConnection()
344 	ev.events = MOS_EPOLLIN;  in CreateListeningSocket()
478 	struct mtcp_epoll_event *events;  in RunServer()  local
483 	events = (struct mtcp_epoll_event *)  in RunServer()
485 	if (!events) {  in RunServer()
491 		nevents = mtcp_epoll_wait(mctx, ep, events, MAX_EVENTS, -1);  in RunServer()
501 			if (events[i].data.sock == ctx->listener) {  in RunServer()
505 			} else if (events[i].events & MOS_EPOLLERR) {  in RunServer()
511 						core, events[i].data.sock);  in RunServer()
512 				if (mtcp_getsockopt(mctx, events[i].data.sock,   in RunServer()
516 								events[i].data.sock, strerror(err));  in RunServer()
520 						strerror(errno), events[i].data.sock);  in RunServer()
523 				CloseConnection(ctx, events[i].data.sock,   in RunServer()
524 						&ctx->svars[events[i].data.sock]);  in RunServer()
526 			} else if (events[i].events & MOS_EPOLLIN) {  in RunServer()
527 				ret = HandleReadEvent(ctx, events[i].data.sock,   in RunServer()
528 						&ctx->svars[events[i].data.sock]);  in RunServer()
532 					CloseConnection(ctx, events[i].data.sock,   in RunServer()
533 							&ctx->svars[events[i].data.sock]);  in RunServer()
537 						CloseConnection(ctx, events[i].data.sock,   in RunServer()
538 								&ctx->svars[events[i].data.sock]);  in RunServer()
542 			} else if (events[i].events & MOS_EPOLLOUT) {  in RunServer()
543 				struct server_vars *sv = &ctx->svars[events[i].data.sock];  in RunServer()
545 					SendUntilAvailable(ctx, events[i].data.sock, sv);  in RunServer()
548 							events[i].data.sock);  in RunServer()