113 CloseConnection(struct thread_context *ctx, int sockid, struct server_vars *sv)  in CloseConnection()  argument
115 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_DEL, sockid, NULL);  in CloseConnection()
116 	mtcp_close(ctx->mctx, sockid);  in CloseConnection()
120 SendUntilAvailable(struct thread_context *ctx, int sockid, struct server_vars *sv)  in SendUntilAvailable()  argument
137 		ret = mtcp_write(ctx->mctx, sockid,    in SendUntilAvailable()
142 						"try: %d, sent: %d\n", sockid, len, ret);  in SendUntilAvailable()
146 		TRACE_APP("Socket %d: mtcp_write try: %d, ret: %d\n", sockid, len, ret);  in SendUntilAvailable()
159 			ev.data.sock = sockid;  in SendUntilAvailable()
160 			mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev);  in SendUntilAvailable()
165 			CloseConnection(ctx, sockid, sv);  in SendUntilAvailable()
173 HandleReadEvent(struct thread_context *ctx, int sockid, struct server_vars *sv)  in HandleReadEvent()  argument
189 	rd = mtcp_read(ctx->mctx, sockid, buf, HTTP_HEADER_LEN);  in HandleReadEvent()
203 				sockid, rd, sv->recv_len,   in HandleReadEvent()
209 	TRACE_APP("Socket %d URL: %s\n", sockid, url);  in HandleReadEvent()
211 	TRACE_APP("Socket %d File name: %s\n", sockid, sv->fname);  in HandleReadEvent()
231 			sockid, sv->fsize, sv->fsize / 1024 / 1024);  in HandleReadEvent()
248 	TRACE_APP("Socket %d HTTP Response: \n%s", sockid, response);  in HandleReadEvent()
249 	sent = mtcp_write(ctx->mctx, sockid, response, len);  in HandleReadEvent()
252 				"try: %d, sent: %d\n", sockid, len, sent);  in HandleReadEvent()
253 		CloseConnection(ctx, sockid, sv);  in HandleReadEvent()
256 			sockid, len, sent);  in HandleReadEvent()
261 	ev.data.sock = sockid;  in HandleReadEvent()
262 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev);  in HandleReadEvent()
264 	SendUntilAvailable(ctx, sockid, sv);  in HandleReadEvent()