wait

Author: jhadvig

bindata/assets/deployments/downloads-deployment.yaml

@@ -80,6 +80,8 @@ spec:
 
               signal.signal(signal.SIGTERM, lambda signum, frame: sys.exit(0))
 
+              ready = threading.Event()
+
               def write_index(path, message):
                 with open(path, 'wb') as f:
                   f.write('\n'.join([
@@ -114,7 +116,8 @@ spec:
                   # https://stackoverflow.com/questions/46210672/
                   httpd.socket = self.socket
                   httpd.server_bind = self.server_close = lambda self: None
-
+                  if self.i == 0:
+                    ready.set()
                   httpd.serve_forever()
 
               temp_dir = tempfile.mkdtemp()
@@ -188,12 +191,13 @@ spec:
                   addr = ('', 8080)
                   sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                 else:
-                  raise    
+                  raise
               sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
               sock.bind(addr)
               sock.listen(5)
 
               [Thread(i, socket=sock) for i in range(100)]
+              ready.wait()
               time.sleep(9e9)
               EOF
               exec python3 /tmp/serve.py