Method: RunLoop::Core.validate_index_written

Defined in:

lib/run_loop/core.rb

.validate_index_written(run_loop, index, logger) ⇒ Object

# File 'lib/run_loop/core.rb', line 401

def self.validate_index_written(run_loop, index, logger)
  begin
    Timeout::timeout(10, RunLoop::TimeoutError) do
      Core.read_response(run_loop, index, 10, 'last_index')
    end
    RunLoop::Logging.log_debug(logger, "validate index written for index #{index} ok")
    return true
  rescue RunLoop::TimeoutError => _
    RunLoop::Logging.log_debug(logger, "validate index written for index #{index} failed. Retrying.")
    return false
  end
end