158 			ev.events = MOS_EPOLLIN;  in SendUntilAvailable()
260 	ev.events = MOS_EPOLLIN | MOS_EPOLLOUT;  in HandleReadEvent()
288 		ev.events = MOS_EPOLLIN;  in AcceptConnection()
343 	ev.events = MOS_EPOLLIN;  in CreateListeningSocket()
477 	struct mtcp_epoll_event *events;  in RunServer()  local
482 	events = (struct mtcp_epoll_event *)  in RunServer()
484 	if (!events) {  in RunServer()
490 		nevents = mtcp_epoll_wait(mctx, ep, events, MAX_EVENTS, -1);  in RunServer()
500 			if (events[i].data.sock == ctx->listener) {  in RunServer()
504 			} else if (events[i].events & MOS_EPOLLERR) {  in RunServer()
510 						core, events[i].data.sock);  in RunServer()
511 				if (mtcp_getsockopt(mctx, events[i].data.sock,   in RunServer()
515 								events[i].data.sock, strerror(err));  in RunServer()
519 						strerror(errno), events[i].data.sock);  in RunServer()
522 				CloseConnection(ctx, events[i].data.sock,   in RunServer()
523 						&ctx->svars[events[i].data.sock]);  in RunServer()
525 			} else if (events[i].events & MOS_EPOLLIN) {  in RunServer()
526 				ret = HandleReadEvent(ctx, events[i].data.sock,   in RunServer()
527 						&ctx->svars[events[i].data.sock]);  in RunServer()
531 					CloseConnection(ctx, events[i].data.sock,   in RunServer()
532 							&ctx->svars[events[i].data.sock]);  in RunServer()
536 						CloseConnection(ctx, events[i].data.sock,   in RunServer()
537 								&ctx->svars[events[i].data.sock]);  in RunServer()
541 			} else if (events[i].events & MOS_EPOLLOUT) {  in RunServer()
542 				struct server_vars *sv = &ctx->svars[events[i].data.sock];  in RunServer()
544 					SendUntilAvailable(ctx, events[i].data.sock, sv);  in RunServer()
547 							events[i].data.sock);  in RunServer()