Contents

# frozen_string_literal: true

module ThinkingSphinx::Connection
  MAXIMUM_RETRIES = 3

  def self.new
    configuration = ThinkingSphinx::Configuration.instance

    options = {
      :host      => configuration.searchd.address,
      :port      => configuration.searchd.mysql41,
      :socket    => configuration.searchd.socket,
      :reconnect => true
    }.merge(configuration.settings['connection_options'] || {})

    connection_class.new options
  end

  def self.connection_class
    return ThinkingSphinx::Connection::JRuby if RUBY_PLATFORM == 'java'

    ThinkingSphinx::Connection::MRI
  end

  def self.pool
    @pool ||= Innertube::Pool.new(
      Proc.new { ThinkingSphinx::Connection.new },
      Proc.new { |connection| connection.close! }
    )
  end

  def self.take
    retries  = 0
    original = nil
    begin
      pool.take do |connection|
        begin
          yield connection
        rescue ThinkingSphinx::QueryExecutionError, connection.base_error => error
          original = ThinkingSphinx::SphinxError.new_from_mysql error
          retries += MAXIMUM_RETRIES if original.is_a?(ThinkingSphinx::QueryError)
          raise Innertube::Pool::BadResource
        end
      end
    rescue Innertube::Pool::BadResource
      retries += 1
      raise original unless retries < MAXIMUM_RETRIES

      ActiveSupport::Notifications.instrument(
        "message.thinking_sphinx", :message => "Retrying query \"#{original.statement}\" after error: #{original.message}"
      )
      retry
    end
  end

  def self.persistent?
    @persistent
  end

  def self.persistent=(persist)
    @persistent = persist
  end

  @persistent = true
end

require 'thinking_sphinx/connection/client'
require 'thinking_sphinx/connection/jruby'
require 'thinking_sphinx/connection/mri'

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
thinking-sphinx-5.0.0	lib/thinking_sphinx/connection.rb
thinking-sphinx-4.4.1	lib/thinking_sphinx/connection.rb
thinking-sphinx-4.4.0	lib/thinking_sphinx/connection.rb
thinking-sphinx-4.3.2	lib/thinking_sphinx/connection.rb
thinking-sphinx-4.3.1	lib/thinking_sphinx/connection.rb
thinking-sphinx-4.3.0	lib/thinking_sphinx/connection.rb
thinking-sphinx-4.2.0	lib/thinking_sphinx/connection.rb
thinking-sphinx-4.1.0	lib/thinking_sphinx/connection.rb
thinking-sphinx-4.0.0	lib/thinking_sphinx/connection.rb