jaculabilis/danbooru
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

when PostKeeperManager.check_and_update fails, retry (fixes #3699)

Browse Source
This commit is contained in:
Albert Yi
2018-05-09 17:09:04 -07:00
parent c658e7d22a
commit bc4010fe6c
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
app/logical/post_keeper_manager.rb
View File

@@ -17,6 +17,9 @@ class PostKeeperManager
def self.check_and_update(post, updater_id = nil, increment_tags = nil) def self.check_and_update(post, updater_id = nil, increment_tags = nil)
check_and_assign(post, updater_id, increment_tags) check_and_assign(post, updater_id, increment_tags)
post.update_column(:keeper_data, post.keeper_data) post.update_column(:keeper_data, post.keeper_data)
rescue ActiveRecord::StatementInvalid => e
PostArchive.check_for_retry(e.message)
raise
end end
def self.check_and_assign(post, updater_id = nil, increment_tags = nil) def self.check_and_assign(post, updater_id = nil, increment_tags = nil)

6
app/models/post_archive.rb
View File

@@ -11,6 +11,12 @@ class PostArchive < ApplicationRecord
establish_connection (ENV["ARCHIVE_DATABASE_URL"] || "archive_#{Rails.env}".to_sym) if enabled? establish_connection (ENV["ARCHIVE_DATABASE_URL"] || "archive_#{Rails.env}".to_sym) if enabled?
self.table_name = "post_versions" self.table_name = "post_versions"
def self.check_for_retry(msg)
if msg =~ /can't get socket descriptor/ && msg =~ /post_versions/
connection.reconnect!
end
end
module SearchMethods module SearchMethods
def for_user(user_id) def for_user(user_id)
if user_id if user_id