Fix Threading Stuff

MCPI-Revival · Feb 18, 2021 · af94a84 · af94a84
1 parent 5e625ba
commit af94a84
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/proxy.py b/proxy.py
@@ -46,6 +46,10 @@ def get_options(self):
 		return self.__options;
 
 	def run(self):
+		self.__running_lock.acquire();
+		self.__running += 1;
+		self.__running_lock.release();
+
 		dst_addr = ("0.0.0.0", self.__options["dst_port"]);
 		try:
 			proc_addr = socket.gethostbyname_ex(self.__options["src_addr"])[2][0]
@@ -55,10 +59,6 @@ def run(self):
 		src_addr = (proc_addr, self.__options["src_port"]);
 		client_addr = None;
 
-		self.__running_lock.acquire();
-		self.__running += 1;
-		self.__running_lock.release();
-
 		self.__socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP);
 		self.__socket.bind(dst_addr);
 		self.__socket.setblocking(False);