Sha256: 249546a16383a2da8766a8bb9562516898ac56f6bc40ac2efbae6a5aaf5f838b
Contents?: true
Size: 1.49 KB
Versions: 7
Compression:
Stored size: 1.49 KB
Contents
#:nodoc:
class Object
#:nodoc:
def tap
yield self
self
end unless respond_to? :tap
end
#:nodoc:
module Enumerable
#:nodoc:
def each_with_object(memo)
each { |element| yield(element, memo) }
memo
end unless [].respond_to?(:each_with_object)
end
#:nodoc:
class Hash
#:nodoc:
def assert_valid_keys(*valid_keys)
unknown_keys = keys - [valid_keys].flatten
raise(ArgumentError, "Unknown key(s): #{unknown_keys.join(", ")}") unless unknown_keys.empty?
end
end
#:nodoc:
class String
#:nodoc:
def to_bson_code
BSON::Code.new(self)
end
end
#:nodoc:
class Class
def mongo_thread_local_accessor name, options = {}
m = Module.new
m.module_eval do
class_variable_set :"@@#{name}", Hash.new {|h,k| h[k] = options[:default] }
end
m.module_eval %{
def #{name}
@@#{name}[Thread.current.object_id]
end
def #{name}=(val)
@@#{name}[Thread.current.object_id] = val
end
}
class_eval do
include m
extend m
end
end
end
# Fix a bug in the interaction of
# mutexes and timeouts in Ruby 1.9.
# See https://jira.mongodb.org/browse/RUBY-364 for details.
if RUBY_VERSION > '1.9'
class Mutex
def lock_with_hack
lock_without_hack
rescue ThreadError => e
if e.message != "deadlock; recursive locking"
raise
else
unlock
lock_without_hack
end
end
alias_method :lock_without_hack, :lock
alias_method :lock, :lock_with_hack
end
end
Version data entries
7 entries across 7 versions & 1 rubygems