summaryrefslogtreecommitdiffstats
path: root/nova/volume
diff options
context:
space:
mode:
authorMORITA Kazutaka <morita.kazutaka@gmail.com>2011-05-13 21:07:48 +0900
committerMORITA Kazutaka <morita.kazutaka@gmail.com>2011-05-13 21:07:48 +0900
commit2ecfa05337e7eefbf9791188ffa1d57f0e6ecd19 (patch)
tree442bf5218c6a7f48197875da388cfc2bf3406a62 /nova/volume
parentaad857a18153792d96f300732c3bb5bb16aa02c3 (diff)
parent0576766cdf3480ad02159671d2dfc0bdcb154934 (diff)
downloadnova-2ecfa05337e7eefbf9791188ffa1d57f0e6ecd19.tar.gz
nova-2ecfa05337e7eefbf9791188ffa1d57f0e6ecd19.tar.xz
nova-2ecfa05337e7eefbf9791188ffa1d57f0e6ecd19.zip
Merge trunk
Diffstat (limited to 'nova/volume')
-rw-r--r--nova/volume/api.py7
1 files changed, 7 insertions, 0 deletions
diff --git a/nova/volume/api.py b/nova/volume/api.py
index f5285f31f..c1af30de0 100644
--- a/nova/volume/api.py
+++ b/nova/volume/api.py
@@ -113,6 +113,13 @@ class API(base.Base):
if volume['status'] == "available":
raise exception.ApiError(_("Volume is already detached"))
+ def remove_from_compute(self, context, volume_id, host):
+ """Remove volume from specified compute host."""
+ rpc.call(context,
+ self.db.queue_get_for(context, FLAGS.compute_topic, host),
+ {"method": "remove_volume",
+ "args": {'volume_id': volume_id}})
+
def create_snapshot(self, context, volume_id, name, description):
volume = self.get(context, volume_id)
if volume['status'] != "available":