101 CleanServerVariable(struct server_vars *sv)  in CleanServerVariable()  argument
103 	sv->recv_len = 0;  in CleanServerVariable()
104 	sv->request_len = 0;  in CleanServerVariable()
105 	sv->total_read = 0;  in CleanServerVariable()
106 	sv->total_sent = 0;  in CleanServerVariable()
107 	sv->done = 0;  in CleanServerVariable()
108 	sv->rspheader_sent = 0;  in CleanServerVariable()
109 	sv->keep_alive = 0;  in CleanServerVariable()
113 CloseConnection(struct thread_context *ctx, int sockid, struct server_vars *sv)  in CloseConnection()  argument
120 SendUntilAvailable(struct thread_context *ctx, int sockid, struct server_vars *sv)  in SendUntilAvailable()  argument
126 	if (sv->done || !sv->rspheader_sent) {  in SendUntilAvailable()
133 		len = MIN(SNDBUF_SIZE, sv->fsize - sv->total_sent);  in SendUntilAvailable()
138 				fcache[sv->fidx].file + sv->total_sent, len);  in SendUntilAvailable()
148 		sv->total_sent += ret;  in SendUntilAvailable()
151 	if (sv->total_sent >= fcache[sv->fidx].size) {  in SendUntilAvailable()
153 		sv->done = TRUE;  in SendUntilAvailable()
156 		if (sv->keep_alive) {  in SendUntilAvailable()
162 			CleanServerVariable(sv);  in SendUntilAvailable()
165 			CloseConnection(ctx, sockid, sv);  in SendUntilAvailable()
173 HandleReadEvent(struct thread_context *ctx, int sockid, struct server_vars *sv)  in HandleReadEvent()  argument
193 	memcpy(sv->request + sv->recv_len,   in HandleReadEvent()
194 			(char *)buf, MIN(rd, HTTP_HEADER_LEN - sv->recv_len));  in HandleReadEvent()
195 	sv->recv_len += rd;  in HandleReadEvent()
198 	sv->request_len = find_http_header(sv->request, sv->recv_len);  in HandleReadEvent()
199 	if (sv->request_len <= 0) {  in HandleReadEvent()
203 				sockid, rd, sv->recv_len,   in HandleReadEvent()
204 				sv->request_len, strlen(sv->request), sv->request);  in HandleReadEvent()
208 	http_get_url(sv->request, sv->request_len, url, URL_LEN);  in HandleReadEvent()
210 	sprintf(sv->fname, "%s%s", www_main, url);  in HandleReadEvent()
211 	TRACE_APP("Socket %d File name: %s\n", sockid, sv->fname);  in HandleReadEvent()
214 	sv->keep_alive = FALSE;  in HandleReadEvent()
215 	if (http_header_str_val(sv->request, CONN_HDR_FLD,   in HandleReadEvent()
217 		sv->keep_alive = !strcasecmp(keepalive_str, KEEP_ALIVE_STR);  in HandleReadEvent()
223 		if (strcmp(sv->fname, fcache[i].fullname) == 0) {  in HandleReadEvent()
224 			sv->fsize = fcache[i].size;  in HandleReadEvent()
225 			sv->fidx = i;  in HandleReadEvent()
231 			sockid, sv->fsize, sv->fsize / 1024 / 1024);  in HandleReadEvent()
236 	if (sv->keep_alive)  in HandleReadEvent()
246 			scode, StatusCodeToString(scode), t_str, sv->fsize, keepalive_str);  in HandleReadEvent()
253 		CloseConnection(ctx, sockid, sv);  in HandleReadEvent()
258 	sv->rspheader_sent = TRUE;  in HandleReadEvent()
264 	SendUntilAvailable(ctx, sockid, sv);  in HandleReadEvent()
273 	struct server_vars *sv;  in AcceptConnection()  local
285 		sv = &ctx->svars[c];  in AcceptConnection()
286 		CleanServerVariable(sv);  in AcceptConnection()
542 				struct server_vars *sv = &ctx->svars[events[i].data.sock];  in RunServer()  local
543 				if (sv->rspheader_sent) {  in RunServer()
544 					SendUntilAvailable(ctx, events[i].data.sock, sv);  in RunServer()