Commit 70816045 authored by Tim Peters's avatar Tim Peters

checkPackLotsWhileWriting: remove excess generality. Only one client

thread is interesting here, so removed the hair catering to the possiblity
of N > 1 threads.
parent 968efe37
......@@ -286,18 +286,13 @@ class PackableStorage(PackableStorageBase):
NUM_LOOP_TRIP = 100
timer = ElapsedTimer(time.time())
threads = [ClientThread(db, choices, NUM_LOOP_TRIP, timer, i)
for i in range(1)]
for t in threads:
t.start()
while True in [t.isAlive() for t in threads]:
thread = ClientThread(db, choices, NUM_LOOP_TRIP, timer, 0)
thread.start()
while thread.isAlive():
db.pack(packt)
snooze()
packt = time.time()
for t in threads:
t.join()
thread.join()
# Iterate over the storage to make sure it's sane.
if not hasattr(self._storage, "iterator"):
......
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