blob: c2c30dec7cf6be42aaae8297c6ad74bf1de8a7a0 [file] [log] [blame]
Tim Peters9fadfb02001-01-13 03:04:02 +00001"""
2Create and delete FILES_PER_THREAD temp files (via tempfile.TemporaryFile)
3in each of NUM_THREADS threads, recording the number of successes and
4failures. A failure is a bug in tempfile, and may be due to:
5
6+ Trying to create more than one tempfile with the same name.
7+ Trying to delete a tempfile that doesn't still exist.
8+ Something we've never seen before.
9
10By default, NUM_THREADS == 20 and FILES_PER_THREAD == 50. This is enough to
11create about 150 failures per run under Win98SE in 2.0, and runs pretty
12quickly. Guido reports needing to boost FILES_PER_THREAD to 500 before
Collin Wintercb637c92007-03-12 17:24:07 +000013provoking a 2.0 failure under Linux.
Tim Peters9fadfb02001-01-13 03:04:02 +000014"""
15
Collin Wintercb637c92007-03-12 17:24:07 +000016NUM_THREADS = 20
17FILES_PER_THREAD = 50
Tim Peters9fadfb02001-01-13 03:04:02 +000018
Collin Wintercb637c92007-03-12 17:24:07 +000019import tempfile
20
Serhiy Storchakabd8c6292015-04-01 12:56:39 +030021from test.test_support import start_threads, run_unittest, import_module
Victor Stinner6a102812010-04-27 23:55:59 +000022threading = import_module('threading')
Collin Wintercb637c92007-03-12 17:24:07 +000023import unittest
Tim Peters9fadfb02001-01-13 03:04:02 +000024import StringIO
25from traceback import print_exc
26
27startEvent = threading.Event()
28
Tim Peters9fadfb02001-01-13 03:04:02 +000029class TempFileGreedy(threading.Thread):
30 error_count = 0
31 ok_count = 0
32
33 def run(self):
34 self.errors = StringIO.StringIO()
35 startEvent.wait()
36 for i in range(FILES_PER_THREAD):
37 try:
38 f = tempfile.TemporaryFile("w+b")
39 f.close()
40 except:
41 self.error_count += 1
42 print_exc(file=self.errors)
43 else:
44 self.ok_count += 1
45
Collin Wintercb637c92007-03-12 17:24:07 +000046
47class ThreadedTempFileTest(unittest.TestCase):
48 def test_main(self):
Serhiy Storchakabd8c6292015-04-01 12:56:39 +030049 threads = [TempFileGreedy() for i in range(NUM_THREADS)]
50 with start_threads(threads, startEvent.set):
51 pass
52 ok = sum(t.ok_count for t in threads)
53 errors = [str(t.getName()) + str(t.errors.getvalue())
54 for t in threads if t.error_count]
Tim Petersea5962f2007-03-12 18:07:52 +000055
56 msg = "Errors: errors %d ok %d\n%s" % (len(errors), ok,
Collin Wintercb637c92007-03-12 17:24:07 +000057 '\n'.join(errors))
Ezio Melotti2623a372010-11-21 13:34:58 +000058 self.assertEqual(errors, [], msg)
59 self.assertEqual(ok, NUM_THREADS * FILES_PER_THREAD)
Collin Wintercb637c92007-03-12 17:24:07 +000060
Tim Petersd8a9d2a2002-09-25 20:32:28 +000061def test_main():
Collin Wintercb637c92007-03-12 17:24:07 +000062 run_unittest(ThreadedTempFileTest)
Tim Petersd8a9d2a2002-09-25 20:32:28 +000063
Tim Peters9fadfb02001-01-13 03:04:02 +000064if __name__ == "__main__":
Tim Petersd8a9d2a2002-09-25 20:32:28 +000065 test_main()