diff options
| author | Kei Masumoto <masumotok@nttdata.co.jp> | 2011-01-17 04:12:27 +0900 |
|---|---|---|
| committer | Kei Masumoto <masumotok@nttdata.co.jp> | 2011-01-17 04:12:27 +0900 |
| commit | a56bc070784c7ea23528025463ea7f0bee133150 (patch) | |
| tree | 67c16becb0b778500d06e0565461f26ecd7c5c33 /nova/volume | |
| parent | 525544e689334346305ecc11552105fc1b32a5dd (diff) | |
| parent | 825652456ac826a2108956ba8a9cbdc8221520dc (diff) | |
merged trunk rev569
Diffstat (limited to 'nova/volume')
| -rw-r--r-- | nova/volume/driver.py | 49 |
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 |
