[Abandoned] Move url_open with dependencies to utils.net module.

swarm_get_results.py

 #!/usr/bin/env python
 # Copyright (c) 2012 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.
 
 """Retrieves all the output that the Swarm server has produced for requests with
 that name.
 """
 
 import json
 import logging
 import optparse
 import sys
 import time
 import urllib
 
 from third_party.depot_tools import fix_encoding
 
-import run_isolated
-
+from utils import net
 from utils import threading_utils
 from utils import tools
 
 
 # The default time to wait for a shard to finish running.
 DEFAULT_SHARD_WAIT_TIME = 40 * 60.
 
 
 class Failure(Exception):
   """Generic failure."""
   pass
 
 
 def get_test_keys(swarm_base_url, test_name, _=None):
   """Returns the Swarm test key for each shards of test_name."""
   # TODO(maruel): Remove the parameter '_' once the
   # build/scripts/slave/get_swarm_results.py stops passing it.
   key_data = urllib.urlencode([('name', test_name)])
   url = '%s/get_matching_test_cases?%s' % (swarm_base_url, key_data)
 
-  for i in range(run_isolated.URL_OPEN_MAX_ATTEMPTS):
-    response = run_isolated.url_open(url, retry_404=True)
+  for i in range(net.URL_OPEN_MAX_ATTEMPTS):
+    response = net.url_open(url, retry_404=True)
     if response is None:
       raise Failure(
           'Error: Unable to find any tests with the name, %s, on swarm server'
           % test_name)
 
     result = response.read()
     # TODO(maruel): Compare exact string.
     if 'No matching' in result:
       logging.warning('Unable to find any tests with the name, %s, on swarm '
                       'server' % test_name)
-      if i != run_isolated.URL_OPEN_MAX_ATTEMPTS:
-        run_isolated.HttpService.sleep_before_retry(i, None)
+      if i != net.URL_OPEN_MAX_ATTEMPTS:
+        net.HttpService.sleep_before_retry(i, None)
       continue
     return json.loads(result)
 
   raise Failure(
       'Error: Unable to find any tests with the name, %s, on swarm server'
       % test_name)
 
 
 def now():
   """Exists so it can be mocked easily."""
   return time.time()
 
 
 def retrieve_results(base_url, test_key, timeout, should_stop):
   """Retrieves results for a single test_key."""
   assert isinstance(timeout, float)
   params = [('r', test_key)]
   result_url = '%s/get_result?%s' % (base_url, urllib.urlencode(params))
   start = now()
   while True:
     if timeout and (now() - start) >= timeout:
       logging.error('retrieve_results(%s) timed out', base_url)
       return {}
     # Do retries ourselves.
-    response = run_isolated.url_open(
-        result_url, retry_404=False, retry_50x=False)
+    response = net.url_open(result_url, retry_404=False, retry_50x=False)
     if response is None:
       # Aggressively poll for results. Do not use retry_404 so
       # should_stop is polled more often.
       remaining = min(5, timeout - (now() - start)) if timeout else 5
       if remaining > 0:
-        run_isolated.HttpService.sleep_before_retry(1, remaining)
+        net.HttpService.sleep_before_retry(1, remaining)
     else:
       try:
         data = json.load(response) or {}
       except (ValueError, TypeError):
         logging.warning(
             'Received corrupted data for test_key %s. Retrying.', test_key)
       else:
         if data['output']:
           return data
     if should_stop.get():
@@ skipping 89 matching lines @@
             output['machine_id'], output['machine_tag'], output['exit_codes']))
     print(''.join('  %s\n' % l for l in output['output'].splitlines()))
     exit_code = max(exit_code, max(map(int, output['exit_codes'].split(','))))
 
   return exit_code
 
 
 if __name__ == '__main__':
   fix_encoding.fix_encoding()
   sys.exit(main())