Concurrent access on testing socket file and creating associated process about ansible-keepass HOT 7 CLOSED

 lock_op.acquire() 
 try:
         os.open(lock_file_, os.O_RDWR)
     except FileNotFoundError:
         cmd = [
             "/usr/bin/env",
             "python3",
             os.path.abspath(__file__),
             var_dbx,
             socket_path,
             var_ttl,
         ]
         if var_key:
             cmd.append("--key=%s" % var_key)
         try:
             display.v("KeePass: run socket for %s" % var_dbx)
             subprocess.Popen(cmd)
         except OSError:
             os.remove(lock_file_)
             raise AnsibleError(traceback.format_exc())

         attempts = 10
         success = False
         for _ in range(attempts):
             try:
                 display.vvv("KeePass: try connect to socket %s/%s" % (_, attempts))
                 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
                 sock.connect(socket_path)
                 # send password to the socket for decrypt keepass dbx
                 display.vvv("KeePass: send password to '%s'" % socket_path)
                 sock.send(_rq("password", str(var_psw)))
                 resp = sock.recv(1024).decode().splitlines()

                 if len(resp) == 2 and resp[0] == "password":
                     if resp[1] == "0":
                         success = True
                     else:
                         raise AnsibleError("KeePass: wrong dbx password")
                 sock.close()
                 break
             except FileNotFoundError:
                 # wait until the above command open the socket
                 time.sleep(1)

         if not success:
             raise AnsibleError("KeePass: socket connection failed for %s" % var_dbx)

         display.v("KeePass: open socket for %s -> %s" % (var_dbx, socket_path))

 finally:
     lock_op.release()