Class: ConditionVariable

Inherits:
Object show all
Defined in:
lib/phusion_passenger/utils.rb

Instance Method Summary collapse

Instance Method Details

#timed_wait(mutex, secs) ⇒ Object

This is like ConditionVariable.wait(), but allows one to wait a maximum amount of time. Returns true if this condition was signaled, false if a timeout occurred.



511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
 
# File 'lib/phusion_passenger/utils.rb', line 511

def timed_wait(mutex, secs)
  if secs > 100000000
    # NOTE: If one calls timeout() on FreeBSD 5 with an
    # argument of more than 100000000, then MRI will become
    # stuck in an infite loop, blocking all threads. It seems
    # that MRI uses select() to implement sleeping.
    # I think that a value of more than 100000000 overflows
    # select()'s data structures, causing it to behave incorrectly.
    # So we just make sure we can't sleep more than 100000000
    # seconds.
    secs = 100000000
  end
  if defined?(RUBY_ENGINE) && RUBY_ENGINE == "jruby"
    if secs > 0
      return wait(mutex, secs)
    else
      return wait(mutex)
    end
  else
    require 'timeout' unless defined?(Timeout)
    if secs > 0
      Timeout.timeout(secs) do
        wait(mutex)
      end
    else
      wait(mutex)
    end
    return true
  end
rescue Timeout::Error
  return false
end

#timed_wait!(mutex, secs) ⇒ Object

This is like ConditionVariable.wait(), but allows one to wait a maximum amount of time. Raises Timeout::Error if the timeout has elapsed.



546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
 
# File 'lib/phusion_passenger/utils.rb', line 546

def timed_wait!(mutex, secs)
  require 'timeout' unless defined?(Timeout)
  if secs > 100000000
    # See the corresponding note for timed_wait().
    secs = 100000000
  end
  if defined?(RUBY_ENGINE) && RUBY_ENGINE == "jruby"
    if secs > 0
      if !wait(mutex, secs)
        raise Timeout::Error, "Timeout"
      end
    else
      wait(mutex)
    end
  else
    if secs > 0
      Timeout.timeout(secs) do
        wait(mutex)
      end
    else
      wait(mutex)
    end
  end
  return nil
end