From 5ec59e4b5e2082fb52649893baa0cc0fd310f80b Mon Sep 17 00:00:00 2001
From: UltraQbik <no1skill@yandex.ru>
Date: Mon, 26 Aug 2024 04:15:08 +0300
Subject: Add semaphore

Use semaphore to limit core usage slightly (maybe)

Also changed default configs a bit
---
 main.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

(limited to 'main.py')

diff --git a/main.py b/main.py
index f03b354..574c58b 100644
--- a/main.py
+++ b/main.py
@@ -93,8 +93,9 @@ class HTTPServer:
         self.buf_len: int = packet_size
         self.port: int = port
 
-        # client thread list and server thread
+        # client thread list
         self.client_threads: list[threading.Thread] = []
+        self.semaphore: threading.Semaphore = threading.Semaphore(CLIENT_MAX_PROCESS)
 
         # add signaling
         self.stop_event = threading.Event()
@@ -141,6 +142,7 @@ class HTTPServer:
         :param client: client ssl socket
         """
 
+        self.semaphore.acquire()
         try:
             request = self._recv_request(client)
             if request is not None:
@@ -159,6 +161,7 @@ class HTTPServer:
 
         # Remove self from thread list and close the connection
         self.client_threads.remove(threading.current_thread())
+        self.semaphore.release()
         client.close()
 
     def _client_request_handler(self, client: usocket, request: Request):
@@ -289,7 +292,7 @@ class HTTPServer:
 
 
 def main():
-    init_path_map(True)
+    init_path_map(verbose=True)
     server = HTTPServer(port=13700)
     server.start()
 
-- 
cgit 1.4.1