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