Module: DeadlockRetry::ClassMethods

Defined in:
lib/deadlock_retry.rb

Constant Summary collapse

DEADLOCK_ERROR_MESSAGES = 
[
  "Deadlock found when trying to get lock",
  "Lock wait timeout exceeded"
]
MAXIMUM_RETRIES_ON_DEADLOCK = 
3

Instance Method Summary collapse

Instance Method Details

#transaction_with_deadlock_handling(*objects, &block) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/deadlock_retry.rb', line 20

def transaction_with_deadlock_handling(*objects, &block)
  retry_count = 0

  begin
    transaction_without_deadlock_handling(*objects, &block)
  rescue ActiveRecord::StatementInvalid => error
    raise if in_nested_transaction?
    if DEADLOCK_ERROR_MESSAGES.any? { |msg| error.message =~ /#{Regexp.escape(msg)}/ }
      raise if retry_count >= MAXIMUM_RETRIES_ON_DEADLOCK
      retry_count += 1
      logger.info "Deadlock detected on retry #{retry_count}, restarting transaction"
      log_innodb_status
      retry
    else
      raise
    end
  end
end