mojo_run: support parallel Android runs of mojo_run.

mojo/devtools/common/devtoolslib/android_shell.py

 # Copyright 2014 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 import atexit
 import hashlib
 import json
 import logging
 import os
 import os.path
@@ skipping 390 matching lines @@
           host_port = self._forward_host_port_to_device(0, device_port)
           print ("Dart observatory available at the host at http://127.0.0.1:%d"
                  % host_port)
 
     logcat_watch_thread = threading.Thread(
         target=_forward_observatories_as_needed)
     logcat_watch_thread.daemon = True
     logcat_watch_thread.start()
 
   @overrides(Shell)
-  def serve_local_directory(self, local_dir_path, port=0):
+  def serve_local_directory(self, local_dir_path, port=0, free_host_port=False):
     assert local_dir_path
     mappings = [('', [local_dir_path])]
-    server_address = start_http_server(mappings, host_port=port)
+    host_port = 0 if free_host_port else port
+    server_address = start_http_server(mappings, host_port=host_port)
 
     return 'http://127.0.0.1:%d/' % self._forward_device_port_to_host(
         port, server_address[1])
 
   @overrides(Shell)
-  def serve_local_directories(self, mappings, port=0):
+  def serve_local_directories(self, mappings, port=0, free_host_port=False):
     assert mappings
-    server_address = start_http_server(mappings, host_port=port)
+    host_port = 0 if free_host_port else port
+    server_address = start_http_server(mappings, host_port=host_port)
 
     return 'http://127.0.0.1:%d/' % self._forward_device_port_to_host(
         port, server_address[1])
 
   @overrides(Shell)
   def forward_host_port_to_shell(self, host_port):
     self._forward_host_port_to_device(host_port, host_port)
 
   @overrides(Shell)
   def run(self, arguments):
@@ skipping 23 matching lines @@
           Results.output = rf.read()
 
     run_thread = threading.Thread(target=do_run)
     run_thread.start()
     run_thread.join(timeout)
 
     if run_thread.is_alive():
       self.stop_shell()
       return None, Results.output, True
     return None, Results.output, False