Discource-C/discourse
1
0
Fork 0
mirror of https://github.com/discourse/discourse.git synced 2025-02-06 11:28:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Only initialize distributed cache once.

Browse Source
This commit is contained in:
Guo Xiang Tan 2017-10-20 07:15:47 +08:00
parent 42162c38b3
commit 24e3e321e1
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lib/active_record/connection_adapters/postgresql_fallback_adapter.rb
View File

@ -6,8 +6,9 @@ require 'sidekiq/pausable'
class PostgreSQLFallbackHandler
include Singleton
@@masters_down = DistributedCache.new('masters_down')
def initialize
@masters_down = DistributedCache.new('masters_down')
@mutex = Mutex.new
end
@ -19,7 +20,7 @@ class PostgreSQLFallbackHandler
begin
thread = Thread.new { initiate_fallback_to_master }
thread.join
break if synchronize { @masters_down.empty? }
break if synchronize { @@masters_down.empty? }
sleep 10
ensure
thread.kill
@ -29,22 +30,22 @@ class PostgreSQLFallbackHandler
end
def master_down?
synchronize { @masters_down[namespace] }
synchronize { @@masters_down[namespace] }
end
def master_down=(args)
synchronize do
@masters_down[namespace] = args
@@masters_down[namespace] = args
Sidekiq.pause! if args
end
end
def master_up(namespace)
synchronize { @masters_down.delete(namespace) }
synchronize { @@masters_down.delete(namespace) }
end
def initiate_fallback_to_master
@masters_down.keys.each do |key|
@@masters_down.keys.each do |key|
RailsMultisite::ConnectionManagement.with_connection(key) do
begin
logger.warn "#{log_prefix}: Checking master server..."
@ -69,7 +70,7 @@ class PostgreSQLFallbackHandler
# Use for testing
def setup!
@masters_down = {}
@@masters_down = {}
disable_readonly_mode
end