Sha256: 9b390fc8d3fdbb9fbfb52acbe1e12982728e438ae1a9ad3e0439a6f0cfe79fef

Contents?: true

Size: 1.5 KB

Versions: 1

Compression:

Stored size: 1.5 KB

Contents

require 'mongoid'
require 'mongoid/lock/synch_methods'
module Mongoid
  module Lock
#------------------------------------------------------------------------------
# => Embedded class for Unsynchronized use Exceptions
#------------------------------------------------------------------------------
    class UnsynchronizedAccess < StandardError
      attr_reader :used_by
      def initialize(used_by, *args)
        @used_by = used_by
        super(*args)
      end
    end
#------------------------------------------------------------------------------
# => Volatile Instance Attribute Accessor
#------------------------------------------------------------------------------
    def lock_used_by
      self.save
      self.reload
      return super
    end
    
    def lock_acquired_at
      self.save
      self.reload
      return super
    end
#------------------------------------------------------------------------------
# => Module inclusion hook
#------------------------------------------------------------------------------
    def self.included(base)
      super if defined?(super)
      base.class_eval do
        # => Extend Document, If not Already Extended
        unless (base.included_modules.include?(Mongoid::Document))
          include Mongoid::Document
        end
        # => Add special field
        field :lock_used_by, :type => String, :default => nil
        field :lock_acquired_at, :type => Time, :default => nil
        index [[:lock_acquired_at, -1]], :sparse => true
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
mongoid-lock-0.0.7 lib/mongoid/lock.rb