2001-01-12 23:04:02 -04:00
|
|
|
"""
|
|
|
|
Create and delete FILES_PER_THREAD temp files (via tempfile.TemporaryFile)
|
|
|
|
in each of NUM_THREADS threads, recording the number of successes and
|
|
|
|
failures. A failure is a bug in tempfile, and may be due to:
|
|
|
|
|
|
|
|
+ Trying to create more than one tempfile with the same name.
|
|
|
|
+ Trying to delete a tempfile that doesn't still exist.
|
|
|
|
+ Something we've never seen before.
|
|
|
|
|
|
|
|
By default, NUM_THREADS == 20 and FILES_PER_THREAD == 50. This is enough to
|
|
|
|
create about 150 failures per run under Win98SE in 2.0, and runs pretty
|
|
|
|
quickly. Guido reports needing to boost FILES_PER_THREAD to 500 before
|
2007-03-12 14:24:07 -03:00
|
|
|
provoking a 2.0 failure under Linux.
|
2001-01-12 23:04:02 -04:00
|
|
|
"""
|
|
|
|
|
2007-03-12 14:24:07 -03:00
|
|
|
NUM_THREADS = 20
|
|
|
|
FILES_PER_THREAD = 50
|
2001-01-12 23:04:02 -04:00
|
|
|
|
2007-03-12 14:24:07 -03:00
|
|
|
import tempfile
|
|
|
|
|
2015-04-01 06:56:39 -03:00
|
|
|
from test.test_support import start_threads, run_unittest, import_module
|
2010-04-27 20:55:59 -03:00
|
|
|
threading = import_module('threading')
|
2007-03-12 14:24:07 -03:00
|
|
|
import unittest
|
2001-01-12 23:04:02 -04:00
|
|
|
import StringIO
|
|
|
|
from traceback import print_exc
|
|
|
|
|
|
|
|
startEvent = threading.Event()
|
|
|
|
|
|
|
|
class TempFileGreedy(threading.Thread):
|
|
|
|
error_count = 0
|
|
|
|
ok_count = 0
|
|
|
|
|
|
|
|
def run(self):
|
|
|
|
self.errors = StringIO.StringIO()
|
|
|
|
startEvent.wait()
|
|
|
|
for i in range(FILES_PER_THREAD):
|
|
|
|
try:
|
|
|
|
f = tempfile.TemporaryFile("w+b")
|
|
|
|
f.close()
|
|
|
|
except:
|
|
|
|
self.error_count += 1
|
|
|
|
print_exc(file=self.errors)
|
|
|
|
else:
|
|
|
|
self.ok_count += 1
|
|
|
|
|
|
|
|
|
2007-03-12 14:24:07 -03:00
|
|
|
class ThreadedTempFileTest(unittest.TestCase):
|
|
|
|
def test_main(self):
|
2015-04-01 06:56:39 -03:00
|
|
|
threads = [TempFileGreedy() for i in range(NUM_THREADS)]
|
|
|
|
with start_threads(threads, startEvent.set):
|
|
|
|
pass
|
|
|
|
ok = sum(t.ok_count for t in threads)
|
|
|
|
errors = [str(t.getName()) + str(t.errors.getvalue())
|
|
|
|
for t in threads if t.error_count]
|
2007-03-12 15:07:52 -03:00
|
|
|
|
|
|
|
msg = "Errors: errors %d ok %d\n%s" % (len(errors), ok,
|
2007-03-12 14:24:07 -03:00
|
|
|
'\n'.join(errors))
|
2010-11-21 09:34:58 -04:00
|
|
|
self.assertEqual(errors, [], msg)
|
|
|
|
self.assertEqual(ok, NUM_THREADS * FILES_PER_THREAD)
|
2001-01-12 23:04:02 -04:00
|
|
|
|
2007-03-12 14:24:07 -03:00
|
|
|
def test_main():
|
|
|
|
run_unittest(ThreadedTempFileTest)
|
2002-09-25 17:32:28 -03:00
|
|
|
|
2001-01-12 23:04:02 -04:00
|
|
|
if __name__ == "__main__":
|
2002-09-25 17:32:28 -03:00
|
|
|
test_main()
|