* Introduced retries on connecting

* Modified tests, sending 50 commands now, one after another, as a stress test
* Added a shutdown of connection before closing [link](https://docs.python.org/2/library/socket.html#socket.socket.close)
* Added a 1s. timeout

Author: p4vv37

command_port.py

@@ -107,6 +107,7 @@ def run(self):
                                     connection.sendall(output.encode())
                     else:
                         connection.sendall('OK'.encode())
+                    connection.shutdown(socket.SHUT_RDWR)
                     connection.close()
             except socket.timeout:
                 pass
@@ -190,7 +191,7 @@ def execute(self, context):
                             exec(command, globals(), _locals)
                             globals().update(_locals)
                         else:
-                            exec(command, _globals, {})
+                            exec(command, globals(), {})
                     result = output_duplicator.last_line
                 except Exception as e:
                     result = '\n'.join([str(v) for v in e.args])

execute_file_in_blender.py

@@ -1,22 +1,35 @@
 import socket
 import sys
 import os
+import time
 
 
+# noinspection PyUnboundLocalVariable
 def send_command(command, host='localhost', port=None):
     if port is None:
         port = sys.argv[2]
 
     clientsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-    clientsocket.connect((host, int(port)))
+    for i in range(3):
+        # Retry 3 times, wait from 0 to .5 s. before retries, raise last Exception, if no success
+        # noinspection PyBroadException
+        try:
+            clientsocket.connect((host, int(port)))
+            break
+        except Exception as e:
+            time.sleep(i / 2.0)
+    else:
+        raise e
     clientsocket.sendall(command.encode())
+    clientsocket.settimeout(1)
     result = ""
     while True:
         res = clientsocket.recv(4096)
         if not res:
             break
         print(res.decode())
         result += res.decode()
+    clientsocket.shutdown(socket.SHUT_RDWR)
     clientsocket.close()
     return result
 

tests/test_blender_command_port.py

@@ -11,7 +11,13 @@ class TestCommandPort(TestCase):
     Port need to be opened in Blender with port 5000 on localhost and "Share environment" set to True.
     """
     def test_send_command(self):
-        send_command("""print("test passed")""", port=5000)
+        result = send_command("""print("TEST PASSED")""", port=5000)
+        self.assertTrue("TEST PASSED" in result)
+
+        for i in range(30):
+            send_command("""print("test passed")""", port=5000)
+        result = send_command("""print("TEST PASSED")""", port=5000)
+        self.assertTrue("TEST PASSED" in result)
 
     def test_execute_file(self):
         with NamedTemporaryFile(mode="w", suffix='.py', delete=True) as f: