From 8b7c0772c1335f7b1367e97ee5267c2008377496 Mon Sep 17 00:00:00 2001
From: none <none>
Date: Sun, 25 Feb 2024 19:01:11 +0300
Subject: [PATCH] =?UTF-8?q?=D0=92=D0=B5=D1=80=D0=BE=D1=8F=D1=82=D0=BD?=
 =?UTF-8?q?=D0=BE=20=D0=B8=D1=81=D0=BF=D1=80=D0=B0=D0=B2=D0=BB=D0=B5=D0=BD?=
 =?UTF-8?q?=D0=B0=20=D0=BF=D1=80=D0=BE=D0=B1=D0=BB=D0=B5=D0=BC=D0=B0=20?=
 =?UTF-8?q?=D1=81=20=D0=BF=D0=BE=D1=82=D0=BE=D0=BA=D0=B0=D0=BC=D0=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 network.py | 34 ++++++++++++++++++++++++++++++++--
 1 file changed, 32 insertions(+), 2 deletions(-)

diff --git a/network.py b/network.py
index 7e706bf..925cf96 100644
--- a/network.py
+++ b/network.py
@@ -88,7 +88,7 @@ def server(http_port):
 		except:
 			print("SERVER FALLED")
 
-def recv(q, s):
+def recv(data):
 	okay = False
 	while not okay:
 		try:
@@ -96,9 +96,11 @@ def recv(q, s):
 			okay = True
 		except:
 			pass
-	q.put(data)
+#	q.put(data)
 
 import multiprocessing as mp
+from time import time
+from threading import Thread
 # op = operation
 def client(port, op = "ping"):
 	host = 'jetwork.404.mn'
@@ -116,6 +118,7 @@ def client(port, op = "ping"):
 
 		s.send(op.encode())
 
+		'''
 		# Канал обмена процесс - наша функция
 		q = mp.Queue()
 		# Стартуем процесс получения ответа
@@ -134,6 +137,30 @@ def client(port, op = "ping"):
 			p.terminate()
 
 		s.close()
+		'''
+
+		data = None
+		ping = Thread(target = recv, args=(data,))
+		ping.daemon = True
+		ping.start()
+
+		'''
+		# Засекаем когда мы начали ждать
+		start = time()
+
+		# Ждём 10 секунд
+		while time() - start < 3:
+			pass
+
+		#try:
+		#	ping._stop()
+		#except:
+		#	pass
+		ping.kill()
+		'''
+
+		ping.join(5)
+
 
 		return data
 	elif op[:4] == "get_":
@@ -234,3 +261,6 @@ def port_check(your_port):
 			ports.append(port)
 
 	return ports
+
+
+#print(client(44, "ping"))