Class: ZFS::Snapshot

Inherits:
ZFS
  • Object
show all
Defined in:
lib/zfs.rb

Instance Attribute Summary

Attributes inherited from ZFS

#name, #path, #pool

Instance Method Summary collapse

Methods inherited from ZFS

#==, #[], #[]=, #children, #create, #destroy!, #exist?, #initialize, mounts, pools, property, #to_s

Constructor Details

This class inherits a constructor from ZFS

Instance Method Details

#+(path) ⇒ Object

Return sub-filesystem

Raises:



328
329
330
331
332
 
# File 'lib/zfs.rb', line 328

def +(path)
  raise InvalidName if path.match(/@/)

  parent + path + name.sub(/^.+@/, '@')
end

#clone!(clone, opts = {}) ⇒ Object

Clone snapshot

Raises:



361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
 
# File 'lib/zfs.rb', line 361

def clone!(clone, opts={})
  clone = clone.name if clone.is_a? ZFS

  raise AlreadyExists if ZFS(clone).exist?

  cmd = [ZFS.zfs_path].flatten + ['clone']
  cmd << '-p' if opts[:parents]
  cmd << name
  cmd << clone

  out, status = Open3.capture2e(*cmd)

  if status.success? and out.empty?
    return ZFS(clone)
  else
    raise Exception, "something went wrong"
  end
end

#parent ⇒ Object

Just remove the snapshot-name



335
336
337
 
# File 'lib/zfs.rb', line 335

def parent
  ZFS(name.sub(/@.+/, ''))
end

#rename!(newname, opts = {}) ⇒ Object

Rename snapshot

Raises:



340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
 
# File 'lib/zfs.rb', line 340

def rename!(newname, opts={})
  raise AlreadyExists if (parent + "@#{newname}").exist?

  newname = (parent + "@#{newname}").name

  cmd = [ZFS.zfs_path].flatten + ['rename']
  cmd << '-r' if opts[:children]
  cmd << name
  cmd << newname

  out, status = Open3.capture2e(*cmd)

  if status.success? and out.empty?
    initialize(newname)
    return self
  else
    raise Exception, "something went wrong"
  end
end

#send_to(dest, opts = {}) ⇒ Object

Send snapshot to another filesystem



381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
 
# File 'lib/zfs.rb', line 381

def send_to(dest, opts={})
  incr_snap = nil
  dest = ZFS(dest)

  if opts[:incremental] and opts[:intermediary]
    raise ArgumentError, "can't specify both :incremental and :intermediary"
  end

  incr_snap = opts[:incremental] || opts[:intermediary]
  if incr_snap
    if incr_snap.is_a? String and incr_snap.match(/^@/)
      incr_snap = self.parent + incr_snap
    else
      incr_snap = ZFS(incr_snap)
      raise ArgumentError, "incremental snapshot must be in the same filesystem as #{self}" if incr_snap.parent != self.parent
    end

    snapname = incr_snap.name.sub(/^.+@/, '@')

    raise NotFound, "destination must already exist when receiving incremental stream" unless dest.exist?
    raise NotFound, "snapshot #{snapname} must exist at #{self.parent}" if self.parent.snapshots.grep(incr_snap).empty?
    raise NotFound, "snapshot #{snapname} must exist at #{dest}" if dest.snapshots.grep(dest + snapname).empty?
  elsif opts[:use_sent_name]
    raise NotFound, "destination must already exist when using sent name" unless dest.exist?
  elsif dest.exist?
    raise AlreadyExists, "destination must not exist when receiving full stream"
  end

  dest = dest.name if dest.is_a? ZFS
  incr_snap = incr_snap.name if incr_snap.is_a? ZFS

  send_opts = ZFS.zfs_path.flatten + ['send']
  send_opts.concat ['-i', incr_snap] if opts[:incremental]
  send_opts.concat ['-I', incr_snap] if opts[:intermediary]
  send_opts << '-R' if opts[:replication]
  send_opts << name

  receive_opts = ZFS.zfs_path.flatten + ['receive']
  receive_opts << '-d' if opts[:use_sent_name]
  receive_opts << dest

  Open3.popen3(*receive_opts) do |rstdin, rstdout, rstderr, rthr|
    Open3.popen3(*send_opts) do |sstdin, sstdout, sstderr, sthr|
      while !sstdout.eof?
        rstdin.write(sstdout.read(16384))
      end
      raise "stink" unless sstderr.read == ''
    end
  end
end