← Back to branch summary

~vladimir.p/nova/admin-vm

« back to all changes in this revision

Viewing changes to nova/tests/scheduler/test_scheduler.py

  • Committer: vladimir.p
  • Date: 2011-06-07 21:18:30 UTC
  • mfrom: (1102.1.57 nova)
  • Revision ID: vladimir@zadarastorage.com-20110607211830-5bf4gg0zv1x8jvk4
Admin-VM: merged with nova trunk-1159

Show diffs side-by-side

added added

removed removed

Lines of Context:
nova/tests/scheduler/test_scheduler.py
61
61
    """Test case for scheduler"""
62
62
    def setUp(self):
63
63
        super(SchedulerTestCase, self).setUp()
64
 
        self.flags(scheduler_driver='nova.tests.test_scheduler.TestDriver')
 
64
        driver = 'nova.tests.scheduler.test_scheduler.TestDriver'
 
65
        self.flags(scheduler_driver=driver)
65
66
 
66
67
    def _create_compute_service(self):
67
68
        """Create compute-manager(ComputeNode and Service record)."""
196
197
        service.topic = 'compute'
197
198
        service.id = kwargs['id']
198
199
        service.availability_zone = kwargs['zone']
199
 
        service.created_at = datetime.datetime.utcnow()
 
200
        service.created_at = utils.utcnow()
200
201
        return service
201
202
 
202
203
    def test_with_two_zones(self):
290
291
        dic['host'] = kwargs.get('host', 'dummy')
291
292
        s_ref = db.service_create(self.context, dic)
292
293
        if 'created_at' in kwargs.keys() or 'updated_at' in kwargs.keys():
293
 
            t = datetime.datetime.utcnow() - datetime.timedelta(0)
 
294
            t = utils.utcnow() - datetime.timedelta(0)
294
295
            dic['created_at'] = kwargs.get('created_at', t)
295
296
            dic['updated_at'] = kwargs.get('updated_at', t)
296
297
            db.service_update(self.context, s_ref['id'], dic)
401
402
                                   FLAGS.compute_manager)
402
403
        compute1.start()
403
404
        s1 = db.service_get_by_args(self.context, 'host1', 'nova-compute')
404
 
        now = datetime.datetime.utcnow()
 
405
        now = utils.utcnow()
405
406
        delta = datetime.timedelta(seconds=FLAGS.service_down_time * 2)
406
407
        past = now - delta
407
408
        db.service_update(self.context, s1['id'], {'updated_at': past})
542
543
    def test_wont_sechedule_if_specified_host_is_down(self):
543
544
        compute1 = self.start_service('compute', host='host1')
544
545
        s1 = db.service_get_by_args(self.context, 'host1', 'nova-compute')
545
 
        now = datetime.datetime.utcnow()
 
546
        now = utils.utcnow()
546
547
        delta = datetime.timedelta(seconds=FLAGS.service_down_time * 2)
547
548
        past = now - delta
548
549
        db.service_update(self.context, s1['id'], {'updated_at': past})
692
693
        dic = {'instance_id': instance_id, 'size': 1}
693
694
        v_ref = db.volume_create(self.context, {'instance_id': instance_id,
694
695
                                                'size': 1})
695
 
        t1 = datetime.datetime.utcnow() - datetime.timedelta(1)
 
696
        t1 = utils.utcnow() - datetime.timedelta(1)
696
697
        dic = {'created_at': t1, 'updated_at': t1, 'binary': 'nova-volume',
697
698
               'topic': 'volume', 'report_count': 0}
698
699
        s_ref = db.service_create(self.context, dic)
709
710
        """Confirms src-compute node is alive."""
710
711
        instance_id = self._create_instance()
711
712
        i_ref = db.instance_get(self.context, instance_id)
712
 
        t = datetime.datetime.utcnow() - datetime.timedelta(10)
 
713
        t = utils.utcnow() - datetime.timedelta(10)
713
714
        s_ref = self._create_compute_service(created_at=t, updated_at=t,
714
715
                                             host=i_ref['host'])
715
716
 
737
738
        """Confirms exception raises in case dest host does not exist."""
738
739
        instance_id = self._create_instance()
739
740
        i_ref = db.instance_get(self.context, instance_id)
740
 
        t = datetime.datetime.utcnow() - datetime.timedelta(10)
 
741
        t = utils.utcnow() - datetime.timedelta(10)
741
742
        s_ref = self._create_compute_service(created_at=t, updated_at=t,
742
743
                                             host=i_ref['host'])
743
744
 
796
797
        # mocks for live_migration_common_check()
797
798
        instance_id = self._create_instance()
798
799
        i_ref = db.instance_get(self.context, instance_id)
799
 
        t1 = datetime.datetime.utcnow() - datetime.timedelta(10)
 
800
        t1 = utils.utcnow() - datetime.timedelta(10)
800
801
        s_ref = self._create_compute_service(created_at=t1, updated_at=t1,
801
802
                                             host=dest)
802
803