mirror of
				https://github.com/python/cpython.git
				synced 2025-10-31 18:28:49 +00:00 
			
		
		
		
	 45df820591
			
		
	
	
		45df820591
		
	
	
	
	
		
			
			svn+ssh://pythondev@svn.python.org/python/trunk ........ r80552 | victor.stinner | 2010-04-27 23:46:03 +0200 (mar., 27 avril 2010) | 3 lines Issue #7449, part 1: fix test_support.py for Python compiled without thread ........ r80553 | victor.stinner | 2010-04-27 23:47:01 +0200 (mar., 27 avril 2010) | 1 line Issue #7449, part 2: regrtest.py -j option requires thread support ........ r80554 | victor.stinner | 2010-04-27 23:51:26 +0200 (mar., 27 avril 2010) | 9 lines Issue #7449 part 3, test_doctest: import trace module in test_coverage() Import trace module fail if the threading module is missing. test_coverage() is only used if test_doctest.py is used with the -c option. This commit allows to execute the test suite without thread support. Move "import trace" in test_coverage() and use test_support.import_module('trace'). ........ r80555 | victor.stinner | 2010-04-27 23:56:26 +0200 (mar., 27 avril 2010) | 6 lines Issue #7449, part 4: skip test_multiprocessing if thread support is disabled import threading after _multiprocessing to raise a more revelant error message: "No module named _multiprocessing". _multiprocessing is not compiled without thread support. ........ r80556 | victor.stinner | 2010-04-28 00:01:24 +0200 (mer., 28 avril 2010) | 8 lines Issue #7449, part 5: split Test.test_open() of ctypes/test/test_errno.py * Split Test.test_open() in 2 functions: test_open() and test_thread_open() * Skip test_open() and test_thread_open() if we are unable to find the C library * Skip test_thread_open() if thread support is disabled * Use unittest.skipUnless(os.name == "nt", ...) on test_GetLastError() ........ r80564 | victor.stinner | 2010-04-28 00:59:35 +0200 (mer., 28 avril 2010) | 4 lines Issue #7449, part 6: fix test_hashlib for missing threading module Move @test_support.reap_thread decorator from test_main() to test_threaded_hashing(). ........ r80565 | victor.stinner | 2010-04-28 01:01:29 +0200 (mer., 28 avril 2010) | 6 lines Issue #7449, part 7: simplify threading detection in test_capi * Skip TestPendingCalls if threading module is missing * Test if threading module is present or not, instead of test the presence of _testcapi._test_thread_state ........ r80566 | victor.stinner | 2010-04-28 01:03:16 +0200 (mer., 28 avril 2010) | 4 lines Issue #7449, part 8: don't skip the whole test_asynchat if threading is missing TestFifo can be executed without the threading module ........ r80568 | victor.stinner | 2010-04-28 01:14:58 +0200 (mer., 28 avril 2010) | 6 lines Issue #7449, part 9: fix test_xmlrpclib for missing threading module * Skip testcases using threads if threading module is missing * Use "http://" instead of URL in ServerProxyTestCase if threading is missing because URL is not set in this case ........ r80569 | victor.stinner | 2010-04-28 01:33:58 +0200 (mer., 28 avril 2010) | 6 lines Partial revert of r80556 (Issue #7449, part 5, fix ctypes test) Rewrite r80556: the thread test have to be executed just after the test on libc_open() and so the test cannot be splitted in two functions (without duplicating code, and I don't want to duplicate code). ........ r80570 | victor.stinner | 2010-04-28 01:51:16 +0200 (mer., 28 avril 2010) | 8 lines Issue #7449, part 10: test_cmd imports trace module using test_support.import_module() Use test_support.import_module() instead of import to raise a SkipTest exception if the import fail. Import trace fails if the threading module is missing. See also part 3: test_doctest: import trace module in test_coverage(). ........ r80571 | victor.stinner | 2010-04-28 01:55:59 +0200 (mer., 28 avril 2010) | 6 lines Issue #7449, last part (11): fix many tests if thread support is disabled * Use try/except ImportError or test_support.import_module() to import thread and threading modules * Add @unittest.skipUnless(threading, ...) to testcases using threads ........
		
			
				
	
	
		
			75 lines
		
	
	
	
		
			2.1 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
			
		
		
	
	
			75 lines
		
	
	
	
		
			2.1 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
| """This test case provides support for checking forking and wait behavior.
 | |
| 
 | |
| To test different wait behavior, override the wait_impl method.
 | |
| 
 | |
| We want fork1() semantics -- only the forking thread survives in the
 | |
| child after a fork().
 | |
| 
 | |
| On some systems (e.g. Solaris without posix threads) we find that all
 | |
| active threads survive in the child after a fork(); this is an error.
 | |
| """
 | |
| 
 | |
| import os, sys, time, unittest
 | |
| import test.support as support
 | |
| _thread = support.import_module('_thread')
 | |
| 
 | |
| LONGSLEEP = 2
 | |
| SHORTSLEEP = 0.5
 | |
| NUM_THREADS = 4
 | |
| 
 | |
| class ForkWait(unittest.TestCase):
 | |
| 
 | |
|     def setUp(self):
 | |
|         self.alive = {}
 | |
|         self.stop = 0
 | |
| 
 | |
|     def f(self, id):
 | |
|         while not self.stop:
 | |
|             self.alive[id] = os.getpid()
 | |
|             try:
 | |
|                 time.sleep(SHORTSLEEP)
 | |
|             except IOError:
 | |
|                 pass
 | |
| 
 | |
|     def wait_impl(self, cpid):
 | |
|         for i in range(10):
 | |
|             # waitpid() shouldn't hang, but some of the buildbots seem to hang
 | |
|             # in the forking tests.  This is an attempt to fix the problem.
 | |
|             spid, status = os.waitpid(cpid, os.WNOHANG)
 | |
|             if spid == cpid:
 | |
|                 break
 | |
|             time.sleep(2 * SHORTSLEEP)
 | |
| 
 | |
|         self.assertEquals(spid, cpid)
 | |
|         self.assertEquals(status, 0, "cause = %d, exit = %d" % (status&0xff, status>>8))
 | |
| 
 | |
|     def test_wait(self):
 | |
|         for i in range(NUM_THREADS):
 | |
|             _thread.start_new(self.f, (i,))
 | |
| 
 | |
|         time.sleep(LONGSLEEP)
 | |
| 
 | |
|         a = sorted(self.alive.keys())
 | |
|         self.assertEquals(a, list(range(NUM_THREADS)))
 | |
| 
 | |
|         prefork_lives = self.alive.copy()
 | |
| 
 | |
|         if sys.platform in ['unixware7']:
 | |
|             cpid = os.fork1()
 | |
|         else:
 | |
|             cpid = os.fork()
 | |
| 
 | |
|         if cpid == 0:
 | |
|             # Child
 | |
|             time.sleep(LONGSLEEP)
 | |
|             n = 0
 | |
|             for key in self.alive:
 | |
|                 if self.alive[key] != prefork_lives[key]:
 | |
|                     n += 1
 | |
|             os._exit(n)
 | |
|         else:
 | |
|             # Parent
 | |
|             self.wait_impl(cpid)
 | |
|             # Tell threads to die
 | |
|             self.stop = 1
 | |
|             time.sleep(2*SHORTSLEEP) # Wait for threads to die
 |