Class: BitGirder::Core::WaitCondition

Inherits:

BitGirderClass

• Object
• BitGirderClass
• BitGirder::Core::WaitCondition

Defined in:

lib/bitgirder/core.rb

Constant Summary

Constants included from BitGirderMethods

BitGirderMethods::PARAM_TYPE_ARG, BitGirderMethods::PARAM_TYPE_ENVVAR, BitGirderMethods::PARAM_TYPE_KEY

Class Method Summary

• .create_and_exec(waiter, opts, blk) ⇒ Object
• .wait_backoff(opts, &blk) ⇒ Object
• .wait_poll(opts, &blk) ⇒ Object

Instance Method Summary

• #execute ⇒ Object
• #initialize(f, waiter, opts) ⇒ WaitCondition constructor

  A new instance of WaitCondition.

Methods included from BitGirderMethods

argv_to_argh, check_fail_prefix, class_name_to_sym, code, compares_to, console, ext_to_class_name, ext_to_sym, has_env, has_key, has_keys, nonnegative, not_nil, positive, raisef, set_from_key, set_var, split_argv, sym_to_cli_switch, sym_to_ext_id, to_bool, unpack_argv_array, unpack_argv_hash, warn

Methods included from BitGirderStructure

#==, included

Constructor Details

#initialize(f, waiter, opts) ⇒ WaitCondition

Returns a new instance of WaitCondition.

# File 'lib/bitgirder/core.rb', line 1325

def initialize( f, waiter, opts )

    @f, @waiter = f, waiter
    
    raise "One of :max_tries or :max_wait must be given" unless 
        opts.key?( :max_tries ) || opts.key?( :max_wait )

    @max_tries = opts.key?( :max_tries ) ?
        positive( opts[ :max_tries ] ) : 1 << 63
    
    @max_wait = opts.key?( :max_wait ) ? 
        positive( opts[ :max_wait ] ) : Float::INFINITY
end

Class Method Details

.create_and_exec(waiter, opts, blk) ⇒ Object

# File 'lib/bitgirder/core.rb', line 1359

def self.create_and_exec( waiter, opts, blk )
    
    raise "No block given" unless blk

    self.send( :new, blk, waiter, opts ).execute
end

.wait_backoff(opts, &blk) ⇒ Object

# File 'lib/bitgirder/core.rb', line 1374

def self.wait_backoff( opts, &blk )
    
    seed = positive( has_key( opts, :seed ), :seed )
    waiter = lambda { |rem| sleep( [ seed, rem ].min ); seed *= 2 }

    self.create_and_exec( waiter, opts, blk )
end

.wait_poll(opts, &blk) ⇒ Object

# File 'lib/bitgirder/core.rb', line 1366

def self.wait_poll( opts, &blk )
    
    poll = positive( has_key( opts, :poll ), :poll )
    waiter = lambda { |rem| sleep( [ poll, rem ].min ) }

    self.create_and_exec( waiter, opts, blk )
end

Instance Method Details

#execute ⇒ Object

# File 'lib/bitgirder/core.rb', line 1340

def execute

    res = nil
    
    start = Time.now

    @max_tries.times do |i|

        break if res = @f.call

        remain = @max_wait - ( Time.now - start )
        break if remain <= 0

        @waiter.call( remain ) if i < @max_tries - 1
    end

    res
end