Method: ASIR::RetryBehavior#with_retry

Defined in:
lib/asir/retry_behavior.rb

#with_retry ⇒ Object

Yields:

:try, n_try - for each attempt.
:rescue, exc - for any rescued exception.
:retry, exc - before each retry.
:failed, last_exc - when too many retrys occurred.



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/asir/retry_behavior.rb', line 22

def with_retry
  n_try = 0
  @try_sleep_value ||= ::ASIR::AdaptiveValue.new
  @try_sleep_value.init = try_sleep
  @try_sleep_value.reset!
  result = done = last_exception = nil
  begin
    n_try += 1
    result = yield :try, n_try
    done = true
  rescue *Error::Unrecoverable.modules
    raise
  rescue *Error::Unforwardable.modules
    raise
  rescue ::Exception => exc
    last_exc = exc
    yield :rescue, exc
    if ! try_max || try_max > n_try
      yield :retry, exc
      if try_sleep
        sleep_secs = @try_sleep_value.value
        sleep sleep_secs if sleep_secs > 0
        @try_sleep_value.init = try_sleep
        @try_sleep_value.add  = try_sleep_increment
        @try_sleep_value.max  = try_sleep_max
        @try_sleep_value.adapt!
      end
      retry
    end
  end
  unless done
    unless yield :failed, last_exc
      exc = last_exc
      raise RetryError, "Retry failed: #{exc.inspect}", exc.backtrace
    end
  end
  result
end