clientBlaster.py

@@ -82,7 +82,7 @@ def sendResponse(connection,data):
 
 senderThreadSleepMin = 0.0333
 senderThreadSleepMax = 1.0
-senderThreadSleepIncr = 0.01
+senderThreadSleepIncr = 0.05
 
 class senderThread(threading.Thread):
 	def __init__(self,connectionThread):
@@ -110,7 +110,7 @@ class senderThread(threading.Thread):
 			with self.lock:
 				sleepTime = self.sleep
 			
-			#print(sleepTime)
+			print(sleepTime)
 			time.sleep(sleepTime)
 			
 			with self.lock:
@@ -153,11 +153,8 @@ class connectionThread(threading.Thread):
 			print("thread closed: " +str(self.threadId)+ " (open: " +str(len(threads))+ ")")
 			self.closed = True
 	
-	def sendResponse(self,data,lock = True):
-		if lock == True:
-			with self.lock:
-				self.senderThread.addToQueue([sendResponse,[self.connection,data],{}])
-		else:
+	def sendResponse(self,data):
+		with self.lock:
 			self.senderThread.addToQueue([sendResponse,[self.connection,data],{}])
 	
 	def run(self):

modules/[text server]/[api]/communication/module.py

@@ -1,29 +0,0 @@
-moduleDepends([
-	p("[text server]","[api]","commands"),
-])
-
-global textSend
-def textSend(self,command,args):
-	if len(args) < 2:
-		return ["error","nonfatal","syntax","Correct syntax: " +command+ ",<user>,<command>,[argument 1],[argument 2],..."]
-	
-	user = args[0].lower()
-	if len(user) < 1:
-		return ["error","nonfatal","name_too_short","Needs to be at least 1 character in length."]
-	
-	me = ""
-	with self.lock:
-		me = self.user
-	
-	if not me:
-		return ["error","nonfatal","not_logged_in"]
-	
-	with threadsLock:
-		for threadId in threads:
-			thread = threads[threadId]
-			with thread.lock:
-				if thread.user != user: continue
-				thread.sendResponse(textListToCommand(["send",me] + args[1:]).encode("utf-8"),lock = False)
-	
-	return ["ok"]
-textCommandAddHandler("send",textSend)

modules/[text server]/main/module.py

@@ -33,6 +33,14 @@ def textOnRequest(event,self,requestLength):
 	
 	text = data.decode("utf-8")
 	print(":".join(map(str,self.address))+ " > " +text)
+	if text == "close":
+		with threadsLock:
+			global close
+			close = True
+		
+		self.closeThread()
+		return True
+	
 	response = textCommandRun(self,textCommandToList(text))
 	print("response: " +textListToCommand(response))
 	self.sendResponse(textListToCommand(response).encode("utf-8"))

serverBlaster.py

@@ -19,17 +19,6 @@ sp = pUp(s)
 
 # script start
 import socket
-import threading
-
-class receiverThread(threading.Thread):
-	def __init__(self,connection):
-		threading.Thread.__init__(self)
-		self.connection = connection
-	
-	def run(self):
-		while True:
-			response = getResponse(connection).decode("utf-8")
-			print("server: " +response)
 
 def sendRequest(connection,data):
 	connection.sendall(len(data).to_bytes(4,"big") + data)
@@ -50,19 +39,23 @@ def main():
 	global connection
 	connection = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 	connection.connect(("127.0.0.1",21779))
-	thread = receiverThread(connection)
-	thread.start()
-	
 	while True:
-		text = input()
+		text = input("data: ")
 		data = text.encode("utf-8")
-		
-		connection.settimeout(15)
 		sendRequest(connection,data)
-		connection.settimeout(None)
+		response = getResponse(connection).decode("utf-8")
+		print("server: " +response)
+		
 		if text == "exit":
 			connection.close()
 			break
+		
+		if text == "close":
+			connection.close()
+			connection = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+			connection.connect(("127.0.0.1",21779))
+			connection.close()
+			break
 
 if __name__ == '__main__':
 	main()