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

tests/swarm_get_results_test.py

 #!/usr/bin/env python
 # Copyright (c) 2013 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 json
 import logging
 import os
 import StringIO
 import sys
 import threading
 import unittest
 import urllib2
 
 import auto_stub
 
 ROOT_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
 sys.path.insert(0, ROOT_DIR)
 
-import run_isolated
 import swarm_get_results
+from utils import net
 
 
 TEST_CASE_SUCCESS = (
   '[----------] 2 tests from StaticCookiePolicyTest\n'
   '[ RUN      ] StaticCookiePolicyTest.AllowAllCookiesTest\n'
   '[       OK ] StaticCookiePolicyTest.AllowAllCookiesTest (0 ms)\n'
   '[ RUN      ] StaticCookiePolicyTest.BlockAllCookiesTest\n'
   '[       OK ] StaticCookiePolicyTest.BlockAllCookiesTest (0 ms)\n'
   '[----------] 2 tests from StaticCookiePolicyTest (0 ms total)\n'
   '\n'
@@ skipping 106 matching lines @@
           'http://host:9001', keys, 10., None))
 
 
 class TestCase(auto_stub.TestCase):
   """Base class that defines the url_open mock."""
   def setUp(self):
     super(TestCase, self).setUp()
     self._lock = threading.Lock()
     self.requests = []
     self.mock(
-        swarm_get_results.run_isolated, 'url_open',
+        swarm_get_results.net, 'url_open',
         self._url_open)
 
   def tearDown(self):
     try:
       if not self.has_failed():
         self.assertEqual([], self.requests)
     finally:
       super(TestCase, self).tearDown()
 
   def _url_open(self, url, **kwargs):
@@ skipping 11 matching lines @@
 
 
 class TestGetTestKeys(TestCase):
   def test_no_keys(self):
     self.mock(swarm_get_results.time, 'sleep', lambda x: x)
     self.requests = [
       (
         'http://host:9001/get_matching_test_cases?name=my_test',
         {'retry_404': True},
         StringIO.StringIO('No matching Test Cases'),
-      ) for _ in range(run_isolated.URL_OPEN_MAX_ATTEMPTS)
+      ) for _ in range(net.URL_OPEN_MAX_ATTEMPTS)
     ]
     try:
       swarm_get_results.get_test_keys('http://host:9001', 'my_test')
       self.fail()
     except swarm_get_results.Failure as e:
       msg = (
           'Error: Unable to find any tests with the name, my_test, on swarm '
           'server')
       self.assertEqual(msg, e.args[0])
 
@@ skipping 64 matching lines @@
     expected = [gen_yielded_data(0, SWARM_OUTPUT_WITH_NO_TEST_OUTPUT, '0, 0')]
     actual = get_swarm_results(['key1'])
     self.assertEqual(expected, actual)
 
   def test_no_keys(self):
     actual = get_swarm_results([])
     self.assertEqual([], actual)
 
   def test_url_errors(self):
     # NOTE: get_swarm_results() hardcodes timeout=10. range(12) is because of an
-    # additional time.time() call deep in run_isolated.url_open().
+    # additional time.time() call deep in net.url_open().
     now = {}
     lock = threading.Lock()
     def get_now():
       t = threading.current_thread()
       with lock:
         return now.setdefault(t, range(12)).pop(0)
     self.mock(
-        swarm_get_results.run_isolated.HttpService,
+        swarm_get_results.net.HttpService,
         'sleep_before_retry',
         staticmethod(lambda _x, _y: None))
     self.mock(swarm_get_results, 'now', get_now)
     # The actual number of requests here depends on 'now' progressing to 10
     # seconds. It's called twice per loop.
     self.requests = [
       (
         'http://host:9001/get_result?r=key1',
         {'retry_404': False, 'retry_50x': False},
         None,
@@ skipping 72 matching lines @@
     actual = get_swarm_results(['key1', 'key1-repeat', 'key2', 'key3'])
     self.assertEqual(expected, sorted(actual))
 
 
 if __name__ == '__main__':
   logging.basicConfig(
       level=logging.DEBUG if '-v' in sys.argv else logging.ERROR)
   if '-v' in sys.argv:
     unittest.TestCase.maxDiff = None
   unittest.main()