1
0
Fork 0
mirror of https://github.com/pry/pry.git synced 2022-11-09 12:35:05 -05:00

register_ownership -> with_ownership

This commit is contained in:
Nicolas Viennot 2013-06-26 15:05:57 -04:00
parent d213b5c7b6
commit 37bbb66bc0
2 changed files with 6 additions and 6 deletions

View file

@ -35,7 +35,7 @@ class Pry
# Adds ourselves to the ownership list. The last one in the list may access
# the input through interruptible_region().
def __register_ownership(&block)
def __with_ownership(&block)
@mutex.synchronize do
# Three cases:
# 1) There are no owners, in this case we are good to go.
@ -72,16 +72,16 @@ class Pry
end
end
def register_ownership(&block)
# If we already registered the thread (nested pry context), we do nothing.
def with_ownership(&block)
# If we are in a nested with_ownership() call (nested pry context), we do nothing.
nested = @mutex.synchronize { @owners.include?(Thread.current) }
nested ? block.call : __register_ownership(&block)
nested ? block.call : __with_ownership(&block)
end
def interruptible_region(&block)
@mutex.synchronize do
# We patiently wait until we are the owner. This may happen as another
# thread calls register_ownership() because of a binding.pry happening in
# thread calls with_ownership() because of a binding.pry happening in
# another thread.
@cond.wait(@mutex) until @owners.last == Thread.current

View file

@ -38,7 +38,7 @@ class Pry
prologue
while should_try_next_input?
use_next_input
Pry::InputLock.for(input).register_ownership { repl }
Pry::InputLock.for(input).with_ownership { repl }
end
ensure
epilogue