--- parser3/src/main/pa_http.C	2020/11/13 16:55:48	1.103
+++ parser3/src/main/pa_http.C	2020/12/17 11:50:44	1.112
@@ -1,7 +1,7 @@
 /** @file
 	Parser: http support functions.
 
-	Copyright (c) 2001-2017 Art. Lebedev Studio (http://www.artlebedev.com)
+	Copyright (c) 2001-2020 Art. Lebedev Studio (http://www.artlebedev.com)
 	Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
  */
 
@@ -14,7 +14,7 @@
 #include "pa_vfile.h"
 #include "pa_random.h"
 
-volatile const char * IDENT_PA_HTTP_C="$Id: pa_http.C,v 1.103 2020/11/13 16:55:48 moko Exp $" IDENT_PA_HTTP_H; 
+volatile const char * IDENT_PA_HTTP_C="$Id: pa_http.C,v 1.112 2020/12/17 11:50:44 moko Exp $" IDENT_PA_HTTP_H; 
 
 #ifdef _MSC_VER
 #include <windows.h>
@@ -913,6 +913,13 @@ File_read_http_result pa_internal_file_r
 
 /* ********************** httpd *************************** */
 
+#ifdef HTTPD_DEBUG
+void pa_log(const char* fmt, ...);
+#define LOG(action) action
+#else
+#define LOG(action)
+#endif
+
 enum EscapeState {
         Initial,
         Default,
@@ -953,7 +960,7 @@ static bool check_uri(const char *uri){
 			case EscapeSecond:
 				if(isxdigit(c)){
 					state=Default;
-					c=escapedValue + hex_value[c];
+					c=(uchar)(escapedValue + hex_value[c]);
 
 					// implementing Apache AllowEncodedSlashes Off just in case
 					if(c=='/' || c=='\\')
@@ -981,7 +988,7 @@ public:
 
 	HTTPD_request() : HTTP_response(), method(NULL), uri(NULL){};
 
-	ssize_t pa_recv(int sockfd, void *buf, size_t len);
+	ssize_t pa_recv(int sockfd, char *buf, size_t len);
 
 	bool read(int sock, size_t size){
 		if(length + size > buf_size)
@@ -991,7 +998,7 @@ public:
 			return false;
 		if(received_size < 0) {
 			if(int no = pa_socks_errno())
-				throw Exception("httpd.timeout", 0, "error receiving request: %s (%d)", pa_socks_strerr(no), no);
+				throw Exception("httpd.read", 0, "error receiving request: %s (%d)", pa_socks_strerr(no), no);
 			return false;
 		}
 		length+=received_size;
@@ -1018,7 +1025,7 @@ public:
 	}
 
 
-	void read_header(int);
+	bool read_header(int);
 	size_t read_post(int, char *, size_t);
 };
 
@@ -1027,23 +1034,34 @@ enum HTTPD_request_state {
 	HTTPD_HEADERS
 };
 
-ssize_t HTTPD_request::pa_recv(int sockfd, void *buf, size_t len){
+ssize_t HTTPD_request::pa_recv(int sockfd, char *buffer, size_t len){
+	LOG(pa_log("httpd [%d] recv %d appending to %d ...", sockfd, len, length));
+	if(HTTPD_Server::mode == HTTPD_Server::MULTITHREADED){
+		ssize_t result=recv(sockfd, buffer, len, 0);
+		LOG(pa_log("httpd [%d] recv got %d bytes", sockfd, result));
+		return result;
+	}
+
 #ifdef PA_USE_ALARM
 	signal(SIGALRM, timeout_handler);
 	if(sigsetjmp(timeout_env, 1)) {
-		throw Exception("httpd.timeout", 0, "timeout occurred while receiving request");
-		return 0; // never
+		LOG(pa_log("httpd [%d] recv got %d sec timeout", sockfd, pa_httpd_timeout));
+		if(length) // timeout on "void" connection is normal
+			throw Exception("httpd.timeout", 0, "timeout occurred while receiving request");
+		return 0;
 	} else
 #endif
 	{
 		ALARM(pa_httpd_timeout);
-		ssize_t result=recv(sockfd, buf, len, 0);
+		ssize_t result=recv(sockfd, buffer, len, 0);
 		ALARM(0);
+		LOG(pa_log("httpd [%d] recv got %d bytes", sockfd, result));
+		LOG(pa_log("httpd [%d] %s", sockfd, buffer));
 		return result;
 	}
 }
 
-void HTTPD_request::read_header(int sock) {
+bool HTTPD_request::read_header(int sock) {
 	enum HTTPD_request_state state = HTTPD_METHOD;
 
 	size_t chunk_size = 0x400*4;
@@ -1076,11 +1094,16 @@ void HTTPD_request::read_header(int sock
 					break;
 
 				parse_headers();
-				return;
+				return true;
 			}
 		}
 	}
 
+	if(!length){ // browsers open connections in advance and they will be empty unless user requests more pages
+		LOG(pa_log("httpd [%d] void request", sock));
+		return false;
+	}
+
 	if(state == HTTPD_METHOD)
 		throw Exception("httpd.request", 0, "bad request from host - no method found (size=%u)", length);
 
@@ -1088,6 +1111,8 @@ void HTTPD_request::read_header(int sock
 		parse_headers();
 		body_offset=length;
 	}
+
+	return true;
 }
 
 size_t HTTPD_request::read_post(int sock, char *body, size_t max_bytes) {
@@ -1100,7 +1125,7 @@ size_t HTTPD_request::read_post(int sock
 			return total_read;
 		if(received_size < 0) {
 			if(int no = pa_socks_errno())
-				throw Exception("httpd.timeout", new String(uri), "error receiving request body: %s (%d)", pa_socks_strerr(no), no);
+				throw Exception("httpd.read", new String(uri), "error receiving request body: %s (%d)", pa_socks_strerr(no), no);
 			return total_read;
 		}
 		total_read += received_size;
@@ -1130,9 +1155,13 @@ uint64_t HTTPD_Connection::content_lengt
 	return request->headers.content_length;
 }
 
-void HTTPD_Connection::read_header(){
+bool HTTPD_Connection::read_header(){
 	request = new HTTPD_request();
-	request->read_header(sock);
+	bool result = request->read_header(sock);
+	LOG(if(result){
+		pa_log("httpd [%d] got %s \"%s\"", sock, method(), uri());
+	})
+	return result;
 }
 
 size_t HTTPD_Connection::read_post(char *body, size_t max_bytes) {
@@ -1140,16 +1169,20 @@ size_t HTTPD_Connection::read_post(char
 }
 
 size_t HTTPD_Connection::send_body(const void *buf, size_t size) {
+	LOG(pa_log("httpd [%d] response %d bytes", sock, size));
+	LOG(pa_log("httpd [%d] %s", sock, buf));
 	if(send(sock, (const char*)buf, size, 0) != (ssize_t)size) {
 		int no=pa_socks_errno();
-		throw Exception("httpd.timeout", 0, "error sending response: %s (%d)", pa_socks_strerr(no), no);
+		throw Exception("httpd.write", 0, "error sending response: %s (%d)", pa_socks_strerr(no), no);
 	}
 	return size;
 }
 
 HTTPD_Connection::~HTTPD_Connection(){
-	if(sock != -1)
+	if(sock != -1){
+		LOG(pa_log("httpd [%d] closed", sock));
 		closesocket(sock);
+	}
 }
 
 static int sock_ready(int fd,int operation,int timeout_value){
@@ -1186,9 +1219,23 @@ bool HTTPD_Connection::accept(int server
 	}
 
 	remote_addr = pa_strdup(inet_ntoa(addr.sin_addr));
+	LOG(pa_log("httpd [%d] accepted from %s", sock, remote_addr));
 	return true;
 }
 
+HTTPD_Server::HTTPD_MODE HTTPD_Server::mode = HTTPD_Server::SEQUENTIAL;
+
+void HTTPD_Server::set_mode(const String &value){
+                if(value == "sequental") mode = SEQUENTIAL;
+                else if (value == "threaded") mode = MULTITHREADED;
+#ifdef _MSC_VER
+		else throw Exception("httpd.mode", &value, "$main:HTTPD.mode must be 'sequental' or 'threaded'");
+#else
+                else if (value == "parallel") mode = PARALLEL;
+		else throw Exception("httpd.mode", &value, "$main:HTTPD.mode must be 'sequental', 'parallel' or 'threaded'");
+#endif
+}
+
 int HTTPD_Server::bind(const char *host_port){
 	struct sockaddr_in me;
 
@@ -1201,7 +1248,7 @@ int HTTPD_Server::bind(const char *host_
 		port = host_port;
 	}
 
-	if(!set_addr(&me, host, pa_atoui(port))){
+	if(!set_addr(&me, host, (short)pa_atoui(port))){
 		if (host)
 			throw Exception("httpd.bind", 0, "can not resolve hostname \"%s\"", host);
 		me.sin_addr.s_addr=INADDR_ANY;