Revision f1501b3f
b/lib/cli.py | ||
---|---|---|
1527 | 1527 |
args = [] |
1528 | 1528 |
if line is None: |
1529 | 1529 |
line = ['-' for _ in fields] |
1530 |
for idx in xrange(len(fields)):
|
|
1530 |
for idx in range(len(fields)): |
|
1531 | 1531 |
if separator is None: |
1532 | 1532 |
args.append(mlens[idx]) |
1533 | 1533 |
args.append(line[idx]) |
b/lib/workerpool.py | ||
---|---|---|
305 | 305 |
|
306 | 306 |
elif current_count < num_workers: |
307 | 307 |
# Create (num_workers - current_count) new workers |
308 |
for _ in xrange(num_workers - current_count):
|
|
308 |
for _ in range(num_workers - current_count): |
|
309 | 309 |
worker = self._worker_class(self, self._NewWorkerIdUnlocked()) |
310 | 310 |
self._workers.append(worker) |
311 | 311 |
worker.start() |
b/qa/qa_cluster.py | ||
---|---|---|
159 | 159 |
try: |
160 | 160 |
try: |
161 | 161 |
num = qa_config.get('options', {}).get('burnin-instances', 1) |
162 |
for _ in xrange(0, num):
|
|
162 |
for _ in range(0, num): |
|
163 | 163 |
instances.append(qa_config.AcquireInstance()) |
164 | 164 |
except qa_error.OutOfInstancesError: |
165 | 165 |
print "Not enough instances, continuing anyway." |
b/test/ganeti.locking_unittest.py | ||
---|---|---|
492 | 492 |
self.sl.acquire() |
493 | 493 |
|
494 | 494 |
# Start shared acquires with timeout between 0 and 20 ms |
495 |
for i in xrange(11):
|
|
495 |
for i in range(11): |
|
496 | 496 |
self._addThread(target=_AcquireWithTimeout, |
497 | 497 |
args=(shared, i * 2.0 / 1000.0)) |
498 | 498 |
|
... | ... | |
503 | 503 |
# Release lock |
504 | 504 |
self.sl.release() |
505 | 505 |
|
506 |
for _ in xrange(11):
|
|
506 |
for _ in range(11): |
|
507 | 507 |
self.assertEqual(self.done.get_nowait(), "timeout") |
508 | 508 |
|
509 | 509 |
self.assertRaises(Queue.Empty, self.done.get_nowait) |
... | ... | |
583 | 583 |
self.assertEqual(shrcnt3, 0) |
584 | 584 |
self.assertEqual(shrcnt3, 0) |
585 | 585 |
|
586 |
for _ in xrange(3):
|
|
586 |
for _ in range(3): |
|
587 | 587 |
self.assertEqual(self.done.get_nowait(), "exclusive 1") |
588 | 588 |
|
589 |
for _ in xrange(3):
|
|
589 |
for _ in range(3): |
|
590 | 590 |
self.assertEqual(self.done.get_nowait(), "exclusive 2") |
591 | 591 |
|
592 | 592 |
self.assertRaises(Queue.Empty, self.done.get_nowait) |
... | ... | |
615 | 615 |
self.sl.release() |
616 | 616 |
|
617 | 617 |
acquires = [] |
618 |
for _ in xrange(3):
|
|
618 |
for _ in range(3): |
|
619 | 619 |
ev = threading.Event() |
620 | 620 |
self._addThread(target=_AcquireShared, args=(ev, )) |
621 | 621 |
acquires.append(ev) |
... | ... | |
675 | 675 |
self.done.put("shared2") |
676 | 676 |
self.sl.release() |
677 | 677 |
|
678 |
for _ in xrange(10):
|
|
678 |
for _ in range(10): |
|
679 | 679 |
self._addThread(target=_AcquireSharedSimple) |
680 | 680 |
|
681 | 681 |
# Tell exclusive lock to release |
... | ... | |
691 | 691 |
self.assertEqual(self.sl._count_pending(), 0) |
692 | 692 |
|
693 | 693 |
# Check sequence |
694 |
for _ in xrange(3):
|
|
694 |
for _ in range(3): |
|
695 | 695 |
self.assertEqual(self.done.get_nowait(), "shared") |
696 | 696 |
|
697 | 697 |
self.assertEqual(self.done.get_nowait(), "exclusive") |
698 | 698 |
|
699 |
for _ in xrange(10):
|
|
699 |
for _ in range(10): |
|
700 | 700 |
self.assertEqual(self.done.get_nowait(), "shared2") |
701 | 701 |
|
702 | 702 |
self.assertRaises(Queue.Empty, self.done.get_nowait) |
b/test/ganeti.workerpool_unittest.py | ||
---|---|---|
64 | 64 |
try: |
65 | 65 |
self._CheckWorkerCount(wp, 3) |
66 | 66 |
|
67 |
for i in xrange(10):
|
|
67 |
for i in range(10): |
|
68 | 68 |
wp.AddTask("Hello world %s" % i) |
69 | 69 |
|
70 | 70 |
wp.Quiesce() |
... | ... | |
101 | 101 |
|
102 | 102 |
ctx = ChecksumContext() |
103 | 103 |
checksum = ChecksumContext.CHECKSUM_START |
104 |
for i in xrange(1, 100):
|
|
104 |
for i in range(1, 100): |
|
105 | 105 |
checksum = ChecksumContext.UpdateChecksum(checksum, i) |
106 | 106 |
wp.AddTask(ctx, i) |
107 | 107 |
|
Also available in: Unified diff