Module: Synctest::Patches::MonitorPatch

Defined in:

lib/synctest/patches.rb

Instance Method Summary

• #enter ⇒ Object
• #exit ⇒ Object
• #initialize ⇒ Object
• #mon_enter ⇒ Object
• #mon_exit ⇒ Object
• #mon_owned? ⇒ Boolean
• #mon_synchronize(&block) ⇒ Object
• #mon_try_enter ⇒ Object
• #synchronize ⇒ Object
• #try_enter ⇒ Object
• #try_mon_enter ⇒ Object
• #wait_for_cond(condition, timeout) ⇒ Object

Instance Method Details

#enter ⇒ Object

# File 'lib/synctest/patches.rb', line 304

def enter
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_enter(self)
  nil
end

#exit ⇒ Object

# File 'lib/synctest/patches.rb', line 341

def exit
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_exit(self)
  nil
end

#initialize ⇒ Object

# File 'lib/synctest/patches.rb', line 299

def initialize(...)
  super
  Synctest.associate(self)
end

#mon_enter ⇒ Object

# File 'lib/synctest/patches.rb', line 312

def mon_enter
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_enter(self)
  nil
end

#mon_exit ⇒ Object

# File 'lib/synctest/patches.rb', line 349

def mon_exit
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_exit(self)
  nil
end

#mon_owned? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/synctest/patches.rb', line 357

def mon_owned?
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_owned?(self)
end

#mon_synchronize(&block) ⇒ Object

# File 'lib/synctest/patches.rb', line 378

def mon_synchronize(&block)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  synchronize(&block)
end

#mon_try_enter ⇒ Object

# File 'lib/synctest/patches.rb', line 327

def mon_try_enter
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_try_enter(self)
end

#synchronize ⇒ Object

# File 'lib/synctest/patches.rb', line 364

def synchronize
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  entered = false
  begin
    bubble.monitor_enter(self)
    entered = true
    yield
  ensure
    bubble.monitor_exit(self) if entered
  end
end

#try_enter ⇒ Object

# File 'lib/synctest/patches.rb', line 320

def try_enter
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_try_enter(self)
end

#try_mon_enter ⇒ Object

# File 'lib/synctest/patches.rb', line 334

def try_mon_enter
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_try_enter(self)
end

#wait_for_cond(condition, timeout) ⇒ Object

# File 'lib/synctest/patches.rb', line 385

def wait_for_cond(condition, timeout)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.monitor_wait(self, condition, timeout)
end