Revert "Fix volume_rpcapi calls for chance/simple scheds"

This reverts commit d5cd652. Closes-Bug: #1229867 Change-Id: Iee866ddb08d52642bc36bd6ae82bd0d7283cad8e
openstack · Sep 24, 2013 · f4dc301 · f4dc301
1 parent c07a31d
commit f4dc301
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 10 deletions.
diff --git a/cinder/scheduler/chance.py b/cinder/scheduler/chance.py
@@ -76,9 +76,7 @@ def schedule_create_volume(self, context, request_spec, filter_properties):
 
         updated_volume = driver.volume_update_db(context, volume_id, host)
         self.volume_rpcapi.create_volume(context, updated_volume, host,
-                                         allow_reschedule=False,
-                                         snapshot_id=snapshot_id,
-                                         image_id=image_id)
+                                         snapshot_id, image_id)
 
     def host_passes_filters(self, context, host, request_spec,
                             filter_properties):

diff --git a/cinder/scheduler/simple.py b/cinder/scheduler/simple.py
@@ -62,10 +62,11 @@ def schedule_create_volume(self, context, request_spec, filter_properties):
             if not utils.service_is_up(service):
                 raise exception.WillNotSchedule(host=host)
             updated_volume = driver.volume_update_db(context, volume_id, host)
-            self.volume_rpcapi.create_volume(context, updated_volume, host,
-                                             allow_reschedule=False,
-                                             snapshot_id=snapshot_id,
-                                             image_id=image_id)
+            self.volume_rpcapi.create_volume(context,
+                                             updated_volume,
+                                             host,
+                                             snapshot_id,
+                                             image_id)
             return None
 
         results = db.service_get_all_volume_sorted(elevated)
@@ -83,9 +84,8 @@ def schedule_create_volume(self, context, request_spec, filter_properties):
                 self.volume_rpcapi.create_volume(context,
                                                  updated_volume,
                                                  service['host'],
-                                                 allow_reschedule=False,
-                                                 snapshot_id=snapshot_id,
-                                                 image_id=image_id)
+                                                 snapshot_id,
+                                                 image_id)
                 return None
         msg = _("Is the appropriate service running?")
         raise exception.NoValidHost(reason=msg)