Sha256: 4ed25834448fda4bb2e4023ca013ea23895415fc3168241da29110346a11d7f0

Contents?: true

Size: 1.98 KB

Versions: 9

Compression:

Stored size: 1.98 KB

Contents

require 'log4r'

require 'digest/md5'

module VagrantPlugins
  module Parallels
    module Action
      class PrepareCloneSnapshot
        @@lock = Mutex.new

        def initialize(app, env)
          @app = app
          @logger = Log4r::Logger.new('vagrant_parallels::action::prepare_clone_snapshot')
        end

        def call(env)
          if !env[:clone_id]
            @logger.info('No source VM for cloning, skip snapshot preparing')
            return @app.call(env)
          end

          # If we're not doing a linked clone, snapshots don't matter
          if !env[:machine].provider_config.linked_clone
            return @app.call(env)
          end

          # We lock so that we don't snapshot in parallel
          @@lock.synchronize do
            lock_key = Digest::MD5.hexdigest("#{env[:clone_id]}-snapshot")
            env[:machine].env.lock(lock_key, retry: true) do
              prepare_snapshot(env)
            end
          end

          # Continue
          @app.call(env)
        end

        protected

        def prepare_snapshot(env)
          set_snapshot = env[:machine].provider_config.linked_clone_snapshot
          env[:clone_snapshot] = set_snapshot || 'vagrant_linked_clone'

          # Get the snapshots. We're done if it already exists
          snapshots = env[:machine].provider.driver.list_snapshots(env[:clone_id])

          if snapshots.include?(env[:clone_snapshot])
            env[:clone_snapshot_id] = snapshots[env[:clone_snapshot]]
            @logger.info('Linked clone snapshot already exists, doing nothing')
            return
          end

          # We've specified the snapshot name but it doesn't exist
          if set_snapshot
            raise Errors::SnapshotNotFound, snapshot: set_snapshot
          end

          @logger.info('Creating a new snapshot for linked clone')
          env[:clone_snapshot_id] = env[:machine].provider.driver.create_snapshot(
            env[:clone_id], env[:clone_snapshot])
        end
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
vagrant-parallels-2.2.5 lib/vagrant-parallels/action/prepare_clone_snapshot.rb
vagrant-parallels-2.2.4 lib/vagrant-parallels/action/prepare_clone_snapshot.rb
vagrant-parallels-2.2.3 lib/vagrant-parallels/action/prepare_clone_snapshot.rb
vagrant-parallels-2.2.2 lib/vagrant-parallels/action/prepare_clone_snapshot.rb
vagrant-parallels-2.2.1 lib/vagrant-parallels/action/prepare_clone_snapshot.rb
vagrant-parallels-2.2.0 lib/vagrant-parallels/action/prepare_clone_snapshot.rb
vagrant-parallels-2.1.0 lib/vagrant-parallels/action/prepare_clone_snapshot.rb
vagrant-parallels-2.0.1 lib/vagrant-parallels/action/prepare_clone_snapshot.rb
vagrant-parallels-2.0.0 lib/vagrant-parallels/action/prepare_clone_snapshot.rb