diff options
Diffstat (limited to 'src/ReceiveDictTcp.py')
-rw-r--r-- | src/ReceiveDictTcp.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/ReceiveDictTcp.py b/src/ReceiveDictTcp.py index 3feec31..784afb6 100644 --- a/src/ReceiveDictTcp.py +++ b/src/ReceiveDictTcp.py @@ -5,9 +5,10 @@ from Queue import Queue import sys class ReceiveDictTcp(object): - def __init__(self, host, port): + def __init__(self, host, port, verbose=False): self.host = host self.port = port + self.verbose = verbose self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) self.sock.bind((self.host, self.port)) @@ -21,17 +22,18 @@ class ReceiveDictTcp(object): self.sock.listen(5) while True: client, address = self.sock.accept() - client.settimeout(0) - print("connecting to " + str(client) + " " + str(address)) + client.setblocking(1) + if self.verbose: print("connecting to " + str(client) + " " + str(address)) self.listenToClient(client,address) def listenToClient(self, client, address): size = 1024 while True: + if self.verbose: print("Try receiving") try: data = client.recv(size) if data: - # Set the response to echo back the recieved data + # Set the response to echo back the recieved data jresponse = data response = json.loads(jresponse) client.send(json.dumps(response)) |