Commit 7d733705 authored by Barry Warsaw's avatar Barry Warsaw

readerThread(): Add max_retries to both DeadlockWrap() calls. This

may cause some tests to fail but it prevents them from hanging.
parent 1d2217f3
......@@ -267,12 +267,12 @@ class SimpleThreadedBase(BaseThreadedTestCase):
for loop in range(5):
c = d.cursor()
count = 0
rec = dbutils.DeadlockWrap(c.first)
rec = dbutils.DeadlockWrap(c.first, max_retries=10)
while rec:
count += 1
key, data = rec
self.assertEqual(self.makeData(key), data)
rec = dbutils.DeadlockWrap(c.next)
rec = dbutils.DeadlockWrap(c.next, max_retries=10)
if verbose:
print "%s: found %d records" % (name, count)
c.close()
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment