Bump version to 1.9 and adjust HTTP worker count

- Updated server version from 1.8 to 1.9.
- Reduced default HTTP worker count from 64 to 32.
- Added new HTTP status code 502 (Bad Gateway) to state codes.
- Introduced a status code map for cleaner response handling.
- Consolidated error response handling into a new function `send_error_response`.
- Implemented checks for too many 1xx interim responses in the HTTP client.
- Simplified response status handling in the HTTP server.

Author: mikecovlee

NETUTILS.md

@@ -1,6 +1,6 @@
 # CovScript NetUtils 协议文档
 
-版本：1.8
+版本：1.9
 
 作者：Covariant Script OSC
 
@@ -27,7 +27,7 @@
 ## 2. 基本常量与工具函数
 
 * `server_name = "CovScript-NetUtils"`
-* `server_version = "1.8"`
+* `server_version = "1.9"`
 
 与协议/实现相关的重要工具函数：
 

README.md

@@ -9,7 +9,7 @@ A high-performance network extension for the [Covariant Script](http://covscript
 | Package | Type | Version | Description |
 |---|---|---|---|
 | `network` | C++ Extension | `1.38.0_v6.4` | TCP/UDP sockets, TLS/SSL, async I/O, event loop |
-| `netutils` | CovScript | `1.8` | HTTP server/client framework with single-process, distributed master/slave, and OpenAI API modes |
+| `netutils` | CovScript | `1.9` | HTTP server/client framework with single-process, distributed master/slave, and OpenAI API modes |
 | `argparse` | CovScript | `1.1` | Lightweight command-line argument parser |
 
 > **Note:** `netutils` and `argparse` are provided as both source (`.ecs`), compiled package (`.csp`), and bytecode module (`.csym`) — place them in your project's `imports/` directory.

csbuild/netutils.json

@@ -3,7 +3,7 @@
     "Name": "netutils",
     "Info": "Network Utilities",
     "Author": "CovScript Organization",
-    "Version": "1.8",
+    "Version": "1.9",
     "Source": "netutils.ecs",
     "Target": "netutils.csp",
     "Dependencies": [

netutils.csp

@@ -1,6 +1,6 @@
 # Generated by Extended CovScript Compiler
 # DO NOT MODIFY
-# Date: Tue Jul 14 21:24:55 2026
+# Date: Wed Jul 15 10:47:49 2026
 @charset: utf8
 import ecs as netutils_ecs
 struct __netutils_ecs_lambda_impl_1__
@@ -79,38 +79,11 @@ struct __netutils_ecs_lambda_impl_3__
 			if resp["headers"].exist("content-type")
 				content_type = resp["headers"]["content-type"]
 			end
-			var status = "200 OK"
-			if resp["status_code"] != 200
-				var code_str = to_string(resp["status_code"])
-				switch resp["status_code"]
-					case 400
-						status = code_str + " Bad Request"
-					end
-					case 403
-						status = code_str + " Forbidden"
-					end
-					case 404
-						status = code_str + " Not Found"
-					end
-					case 408
-						status = code_str + " Request Timeout"
-					end
-					case 431
-						status = code_str + " Request Header Fields Too Large"
-					end
-					case 500
-						status = code_str + " Internal Server Error"
-					end
-					case 502
-						status = code_str + " Bad Gateway"
-					end
-					case 503
-						status = code_str + " Service Unavailable"
-					end
-					default
-						status = code_str + " Unknown"
-					end
-				end
+			var status = resp["status_code"]
+			if status_code_map.exist(status)
+				status = status_code_map[status]
+			else
+				status = to_string(status) + " Unknown"
 			end
 			session.send_response(status, resp["body"], content_type)
 		end
@@ -122,7 +95,7 @@ import network; using network
 import regex
 import codec.json as json
 constant server_name = "CovScript-NetUtils"
-constant server_version = "1.8"
+constant server_version = "1.9"
 constant http_client_read_chunk = 8192
 constant http_max_header_line_size = 8192
 constant http_max_header_size = 65536
@@ -131,20 +104,22 @@ constant framing_hex_size = 16
 constant default_http_port = 80
 constant default_https_port = 443
 constant default_http_thread_count = 4
-constant default_http_worker_count = 64
+constant default_http_worker_count = 32
 var request_line_reg = regex.build_optimize("^([A-Z]+) ([^ ?]+)(?:\\?([^ ]*))? HTTP/([0-9.]+)$")
 var request_header_reg = regex.build_optimize("^([^:]*): ?(.*)$")
 namespace state_codes
 	constant code_200 = "200 OK"
 	constant code_400 = "400 Bad Request"
-	constant code_431 = "431 Request Header Fields Too Large"
 	constant code_403 = "403 Forbidden"
 	constant code_404 = "404 Not Found"
 	constant code_408 = "408 Request Timeout"
+	constant code_431 = "431 Request Header Fields Too Large"
 	constant code_500 = "500 Internal Server Error"
+	constant code_502 = "502 Bad Gateway"
 	constant code_503 = "503 Service Unavailable"
 	constant code_eof = "000 End of file"
 end
+constant status_code_map = {200 : state_codes.code_200, 400 : state_codes.code_400, 403 : state_codes.code_403, 404 : state_codes.code_404, 408 : state_codes.code_408, 431 : state_codes.code_431, 500 : state_codes.code_500, 502 : state_codes.code_502, 503 : state_codes.code_503, 0 : state_codes.code_eof}.to_hash_map()
 var wday_map = {"Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"}
 var mon_map = {"Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"}
 function time_padding(obj, width)
@@ -164,6 +139,10 @@ end
 function compose_response(code)
 	return "HTTP/1.1 " + code + "\r\n" + "Connection: close\r\n" + "Content-Length: 0\r\n\r\n"
 end
+function send_error_response(sock, code)
+	var state = async.write(sock, compose_response(code))
+	state.wait()
+end
 var log_stream = null
 function log(msg)
 	if log_stream != null
@@ -538,16 +517,14 @@ function read_http_header(sock, state, keep_alive_timeout)
 	end
 	if error_code != null
 		if error_code != state_codes.code_eof
-			var err_state = async.write(sock, compose_response(error_code))
-			err_state.wait()
+			send_error_response(sock, error_code)
 		end
 		return null
 	end
 	var session = create_http_session(header)
 	if session == null
 		log("Parse request header error.")
-		var err_state = async.write(sock, compose_response(state_codes.code_400))
-		err_state.wait()
+		send_error_response(sock, state_codes.code_400)
 		return null
 	end
 	log("Received: Method = " + session.method + ", URL = " + session.url + ", Host = " + session.host + ", Connection = " + session.connection)
@@ -584,8 +561,7 @@ function read_http_header(sock, state, keep_alive_timeout)
 		end
 		if error_code != null
 			if error_code != state_codes.code_eof
-				var err_state = async.write(sock, compose_response(error_code))
-				err_state.wait()
+				send_error_response(sock, error_code)
 			end
 			return null
 		end
@@ -659,8 +635,7 @@ function call_http_handler(session, server)
 		if server->url_map.exist(error_code)
 			server->url_map[error_code](*server, session)
 		else
-			var err_state = async.write(session.sock, compose_response(error_code))
-			err_state.wait()
+			send_error_response(session.sock, error_code)
 		end
 		return false
 	else
@@ -696,8 +671,7 @@ function simple_worker(self)
 			end
 			if ++request_count > self->server->max_keep_alive
 				log("Keep-alive exceeded max request count.")
-				var err_state = async.write(sock, compose_response(state_codes.code_408))
-				err_state.wait()
+				send_error_response(sock, state_codes.code_408)
 				break
 			end
 			var session = read_http_header(sock, read_state, last_request_time + self->server->keep_alive_timeout)
@@ -903,8 +877,7 @@ function master_response_worker(self)
 		end
 		if conn->request_queue.empty() && !conn->keep_alive
 			if !conn->close
-				var err_state = async.write(conn->sock, compose_response(state_codes.code_408))
-				err_state.wait()
+				send_error_response(conn->sock, state_codes.code_408)
 			end
 			if !conn->sock.safe_shutdown()
 				log("safe_shutdown returned false — async jobs may still be pending")
@@ -1613,6 +1586,7 @@ class http_client
 			end
 		end
 		var meta = null
+		var interim_count = 0
 		loop
 			var headers_raw = read_until_limited("\r\n\r\n", http_max_header_size)
 			if headers_raw == null
@@ -1633,6 +1607,12 @@ class http_client
 					close()
 					return null
 				end
+				++interim_count
+				if interim_count > 10
+					log("HTTP too many 1xx interim responses, aborting.")
+					close()
+					return null
+				end
 				continue
 			end
 			break