69 	mctx_t mctx;  member
115 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_DEL, sockid, NULL);  in CloseConnection()
116 	mtcp_close(ctx->mctx, sockid);  in CloseConnection()
137 		ret = mtcp_write(ctx->mctx, sockid,    in SendUntilAvailable()
160 			mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev);  in SendUntilAvailable()
189 	rd = mtcp_read(ctx->mctx, sockid, buf, HTTP_HEADER_LEN);  in HandleReadEvent()
249 	sent = mtcp_write(ctx->mctx, sockid, response, len);  in HandleReadEvent()
262 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev);  in HandleReadEvent()
272 	mctx_t mctx = ctx->mctx;  in AcceptConnection()  local
277 	c = mtcp_accept(mctx, listener, NULL, NULL);  in AcceptConnection()
290 		mtcp_setsock_nonblock(ctx->mctx, c);  in AcceptConnection()
291 		mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_ADD, c, &ev);  in AcceptConnection()
313 	listener = mtcp_socket(ctx->mctx, AF_INET, SOCK_STREAM, 0);  in CreateListeningSocket()
318 	ret = mtcp_setsock_nonblock(ctx->mctx, listener);  in CreateListeningSocket()
328 	ret = mtcp_bind(ctx->mctx, listener,   in CreateListeningSocket()
336 	ret = mtcp_listen(ctx->mctx, listener, 4096);  in CreateListeningSocket()
345 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_ADD, listener, &ev);  in CreateListeningSocket()
432 InitServer(mctx_t mctx, void **app_ctx)  in InitServer()  argument
442 	ctx->mctx = mctx;  in InitServer()
445 	ctx->ep = mtcp_epoll_create(mctx, MAX_EVENTS);  in InitServer()
471 RunServer(mctx_t mctx, void **app_ctx)  in RunServer()  argument
490 		nevents = mtcp_epoll_wait(mctx, ep, events, MAX_EVENTS, -1);  in RunServer()
511 				if (mtcp_getsockopt(mctx, events[i].data.sock,   in RunServer()
570 RunApplication(mctx_t mctx)   in RunApplication()  argument
580 	TRACE_INFO("run application on core %d\n", mctx->cpu);  in RunApplication()
581 	InitServer(mctx, &(app_ctx));  in RunApplication()
582 	RunServer(mctx, &(app_ctx));  in RunApplication()
589 	mctx_t mctx;  in RunMTCP()  local
594 	mctx = mtcp_create_context(core);  in RunMTCP()
595 	if (!mctx) {  in RunMTCP()
602 	RunApplication(mctx);  in RunMTCP()
605 	mtcp_destroy_context(mctx);  in RunMTCP()