1856
1856
class TestConcurrency(tests.TestCase):
1859
super(TestConcurrency, self).setUp()
1860
orig = osutils._cached_local_concurrency
1862
osutils._cached_local_concurrency = orig
1863
self.addCleanup(restore)
1858
1865
def test_local_concurrency(self):
1859
1866
concurrency = osutils.local_concurrency()
1860
1867
self.assertIsInstance(concurrency, int)
1869
def test_local_concurrency_environment_variable(self):
1870
os.environ['BZR_CONCURRENCY'] = '2'
1871
self.assertEqual(2, osutils.local_concurrency(use_cache=False))
1872
os.environ['BZR_CONCURRENCY'] = '3'
1873
self.assertEqual(3, osutils.local_concurrency(use_cache=False))
1874
os.environ['BZR_CONCURRENCY'] = 'foo'
1875
self.assertEqual(1, osutils.local_concurrency(use_cache=False))
1877
def test_option_concurrency(self):
1878
os.environ['BZR_CONCURRENCY'] = '1'
1879
self.run_bzr('rocks --concurrency 42')
1880
# Command line overrides envrionment variable
1881
self.assertEquals('42', os.environ['BZR_CONCURRENCY'])
1882
self.assertEquals(42, osutils.local_concurrency(use_cache=False))
1863
1885
class TestFailedToLoadExtension(tests.TestCase):