Sha256: ba2fc6a52c827e60b0d1a53ede6575e4b220b44fe38ccd7cc1d810a560a4ad1e

Contents?: true

Size: 1.83 KB

Versions: 6

Compression:

Stored size: 1.83 KB

Contents

require_relative '../explicit_require'

Bootsnap::ExplicitRequire.with_gems('msgpack') { require 'msgpack' }
Bootsnap::ExplicitRequire.from_rubylibdir('fileutils')

module Bootsnap
  module LoadPathCache
    class Store
      NestedTransactionError = Class.new(StandardError)
      SetOutsideTransactionNotAllowed = Class.new(StandardError)

      def initialize(store_path)
        @store_path = store_path
        load_data
      end

      def get(key)
        @data[key]
      end

      def fetch(key)
        raise SetOutsideTransactionNotAllowed unless @in_txn
        v = get(key)
        unless v
          @dirty = true
          v = yield
          @data[key] = v
        end
        v
      end

      def set(key, value)
        raise SetOutsideTransactionNotAllowed unless @in_txn
        if value != @data[key]
          @dirty = true
          @data[key] = value
        end
      end

      def transaction
        raise NestedTransactionError if @in_txn
        @in_txn = true
        yield
      ensure
        commit_transaction
        @in_txn = false
      end

      private

      def commit_transaction
        if @dirty
          dump_data
          @dirty = false
        end
      end

      def load_data
        @data = begin
          MessagePack.load(File.binread(@store_path))
        # handle malformed data due to upgrade incompatability
        rescue Errno::ENOENT, MessagePack::MalformedFormatError, MessagePack::UnknownExtTypeError
          {}
        end
      end

      def dump_data
        # Change contents atomically so other processes can't get invalid
        # caches if they read at an inopportune time.
        tmp = "#{@store_path}.#{(rand * 100000).to_i}.tmp"
        FileUtils.mkpath(File.dirname(tmp))
        File.binwrite(tmp, MessagePack.dump(@data))
        FileUtils.mv(tmp, @store_path)
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
bootsnap-0.3.0 lib/bootsnap/load_path_cache/store.rb
bootsnap-0.3.0.pre3 lib/bootsnap/load_path_cache/store.rb
bootsnap-0.3.0.pre2 lib/bootsnap/load_path_cache/store.rb
bootsnap-0.3.0.pre lib/bootsnap/load_path_cache/store.rb
bootsnap-0.2.15 lib/bootsnap/load_path_cache/store.rb
bootsnap-0.2.14 lib/bootsnap/load_path_cache/store.rb