'Create a volume snapshot.'

def create_snapshot(self, snapshot):

    (addr, path) = self._get_volume_location(snapshot['volume_id'])
    volume_path = os.path.join(path, snapshot['volume_name'])
    snapshot_name = snapshot['name']
    flags = 0
    client = self._get_rpcclient(addr, self.configuration.coho_rpc_port)
    client.create_snapshot(volume_path, snapshot_name, flags)
