114 CloseConnection(struct thread_context *ctx, int sockid, struct server_vars *sv)  in CloseConnection()  argument
116 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_DEL, sockid, NULL);  in CloseConnection()
117 	mtcp_close(ctx->mctx, sockid);  in CloseConnection()
121 SendUntilAvailable(struct thread_context *ctx, int sockid, struct server_vars *sv)  in SendUntilAvailable()  argument
138 		ret = mtcp_write(ctx->mctx, sockid,    in SendUntilAvailable()
143 						"try: %d, sent: %d\n", sockid, len, ret);  in SendUntilAvailable()
147 		TRACE_APP("Socket %d: mtcp_write try: %d, ret: %d\n", sockid, len, ret);  in SendUntilAvailable()
160 			ev.data.sock = sockid;  in SendUntilAvailable()
161 			mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev);  in SendUntilAvailable()
166 			CloseConnection(ctx, sockid, sv);  in SendUntilAvailable()
174 HandleReadEvent(struct thread_context *ctx, int sockid, struct server_vars *sv)  in HandleReadEvent()  argument
190 	rd = mtcp_read(ctx->mctx, sockid, buf, HTTP_HEADER_LEN);  in HandleReadEvent()
204 				sockid, rd, sv->recv_len,   in HandleReadEvent()
210 	TRACE_APP("Socket %d URL: %s\n", sockid, url);  in HandleReadEvent()
212 	TRACE_APP("Socket %d File name: %s\n", sockid, sv->fname);  in HandleReadEvent()
232 			sockid, sv->fsize, sv->fsize / 1024 / 1024);  in HandleReadEvent()
249 	TRACE_APP("Socket %d HTTP Response: \n%s", sockid, response);  in HandleReadEvent()
250 	sent = mtcp_write(ctx->mctx, sockid, response, len);  in HandleReadEvent()
253 				"try: %d, sent: %d\n", sockid, len, sent);  in HandleReadEvent()
254 		CloseConnection(ctx, sockid, sv);  in HandleReadEvent()
257 			sockid, len, sent);  in HandleReadEvent()
262 	ev.data.sock = sockid;  in HandleReadEvent()
263 	mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev);  in HandleReadEvent()
265 	SendUntilAvailable(ctx, sockid, sv);  in HandleReadEvent()