summaryrefslogtreecommitdiffstats
path: root/nova/volume
diff options
context:
space:
mode:
authorKei Masumoto <masumotok@nttdata.co.jp>2011-01-17 04:12:27 +0900
committerKei Masumoto <masumotok@nttdata.co.jp>2011-01-17 04:12:27 +0900
commita56bc070784c7ea23528025463ea7f0bee133150 (patch)
tree67c16becb0b778500d06e0565461f26ecd7c5c33 /nova/volume
parent525544e689334346305ecc11552105fc1b32a5dd (diff)
parent825652456ac826a2108956ba8a9cbdc8221520dc (diff)
merged trunk rev569
Diffstat (limited to 'nova/volume')
-rw-r--r--nova/volume/driver.py49
1 files changed, 49 insertions, 0 deletions
diff --git a/nova/volume/driver.py b/nova/volume/driver.py
index 7611eb0d3..09b93ae91 100644
--- a/nova/volume/driver.py
+++ b/nova/volume/driver.py
@@ -391,3 +391,52 @@ class RBDDriver(VolumeDriver):
def undiscover_volume(self, volume):
"""Undiscover volume on a remote host"""
pass
+
+
+class SheepdogDriver(VolumeDriver):
+ """Executes commands relating to Sheepdog Volumes"""
+
+ def check_for_setup_error(self):
+ """Returns an error if prerequisites aren't met"""
+ try:
+ (out, err) = self._execute("collie cluster info")
+ if not out.startswith('running'):
+ raise exception.Error(_("Sheepdog is not working: %s") % out)
+ except exception.ProcessExecutionError:
+ raise exception.Error(_("Sheepdog is not working"))
+
+ def create_volume(self, volume):
+ """Creates a sheepdog volume"""
+ if int(volume['size']) == 0:
+ sizestr = '100M'
+ else:
+ sizestr = '%sG' % volume['size']
+ self._try_execute("qemu-img create sheepdog:%s %s" %
+ (volume['name'], sizestr))
+
+ def delete_volume(self, volume):
+ """Deletes a logical volume"""
+ self._try_execute("collie vdi delete %s" % volume['name'])
+
+ def local_path(self, volume):
+ return "sheepdog:%s" % volume['name']
+
+ def ensure_export(self, context, volume):
+ """Safely and synchronously recreates an export for a logical volume"""
+ pass
+
+ def create_export(self, context, volume):
+ """Exports the volume"""
+ pass
+
+ def remove_export(self, context, volume):
+ """Removes an export for a logical volume"""
+ pass
+
+ def discover_volume(self, volume):
+ """Discover volume on a remote host"""
+ return "sheepdog:%s" % volume['name']
+
+ def undiscover_volume(self, volume):
+ """Undiscover volume on a remote host"""
+ pass