70 	mctx_t mctx;  member
116 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_DEL, sockid, NULL);  in CloseConnection()
117 	mtcp_close(ctx->mctx, sockid);  in CloseConnection()
138 		ret = mtcp_write(ctx->mctx, sockid,    in SendUntilAvailable()
161 			mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev);  in SendUntilAvailable()
190 	rd = mtcp_read(ctx->mctx, sockid, buf, HTTP_HEADER_LEN);  in HandleReadEvent()
250 	sent = mtcp_write(ctx->mctx, sockid, response, len);  in HandleReadEvent()
263 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev);  in HandleReadEvent()
273 	mctx_t mctx = ctx->mctx;  in AcceptConnection()  local
278 	c = mtcp_accept(mctx, listener, NULL, NULL);  in AcceptConnection()
291 		mtcp_setsock_nonblock(ctx->mctx, c);  in AcceptConnection()
292 		mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_ADD, c, &ev);  in AcceptConnection()
314 	listener = mtcp_socket(ctx->mctx, AF_INET, SOCK_STREAM, 0);  in CreateListeningSocket()
319 	ret = mtcp_setsock_nonblock(ctx->mctx, listener);  in CreateListeningSocket()
329 	ret = mtcp_bind(ctx->mctx, listener,   in CreateListeningSocket()
337 	ret = mtcp_listen(ctx->mctx, listener, 4096);  in CreateListeningSocket()
346 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_ADD, listener, &ev);  in CreateListeningSocket()
433 InitServer(mctx_t mctx, void **app_ctx)  in InitServer()  argument
443 	ctx->mctx = mctx;  in InitServer()
446 	ctx->ep = mtcp_epoll_create(mctx, MAX_EVENTS);  in InitServer()
472 RunServer(mctx_t mctx, void **app_ctx)  in RunServer()  argument
491 		nevents = mtcp_epoll_wait(mctx, ep, events, MAX_EVENTS, -1);  in RunServer()
512 				if (mtcp_getsockopt(mctx, events[i].data.sock,   in RunServer()
571 RunApplication(mctx_t mctx)   in RunApplication()  argument
581 	TRACE_INFO("run application on core %d\n", mctx->cpu);  in RunApplication()
582 	InitServer(mctx, &(app_ctx));  in RunApplication()
583 	RunServer(mctx, &(app_ctx));  in RunApplication()
590 	mctx_t mctx;  in RunMTCP()  local
595 	mctx = mtcp_create_context(core);  in RunMTCP()
596 	if (!mctx) {  in RunMTCP()
603 	RunApplication(mctx);  in RunMTCP()
606 	mtcp_destroy_context(mctx);  in RunMTCP()