From 919a6926dd8157363e8715a6709a4fb7524e213c Mon Sep 17 00:00:00 2001 From: Antoine Millet Date: Mon, 2 May 2011 13:38:52 +0200 Subject: [PATCH] Added a base class for migration jobs. --- ccserver/jobs.py | 24 ++++++++++++++++-------- 1 file changed, 16 insertions(+), 8 deletions(-) diff --git a/ccserver/jobs.py b/ccserver/jobs.py index 215cbcd..79f7539 100644 --- a/ccserver/jobs.py +++ b/ccserver/jobs.py @@ -243,7 +243,22 @@ class KillOldCliJob(BaseJob): time.sleep(delay) -class ColdMigrationJob(BaseJob): +class BaseMigrationJob(BaseJob): + + ''' + Base class for migration jobs. + ''' + + def _check_status(self, vm_id, status): + ''' + Check the status of the VM. + ''' + + answer = self.manager.server.list('id=%s&status=%s' % (vm_id, status)) + return bool(answer) + + +class ColdMigrationJob(BaseMigrationJob): ''' A cold vm migration job. @@ -362,13 +377,6 @@ class ColdMigrationJob(BaseJob): logging.info('Job-%s: Migration completed with success', self['id']) - def _check_status(self, vm_id, status): - ''' - Check the status of the VM. - ''' - - answer = self.manager.server.list('id=%s&status=%s' % (vm_id, status)) - return bool(answer) def _copy_disk(self, source, dest, vm, disk): ''' -- GitLab