class Zold::Routines::Reconnect
Reconnect
routine.
- Author
-
Yegor Bugayenko (yegor256@gmail.com)
- Copyright
-
Copyright © 2018 Yegor Bugayenko
- License
-
MIT
Public Class Methods
new(opts, remotes, farm = Zold::Farm::Empty.new, log: Log::NULL)
click to toggle source
# File lib/zold/commands/routines/reconnect.rb, line 33 def initialize(opts, remotes, farm = Zold::Farm::Empty.new, log: Log::NULL) @opts = opts @remotes = remotes @farm = farm @log = log end
Public Instance Methods
exec(step = 0)
click to toggle source
# File lib/zold/commands/routines/reconnect.rb, line 40 def exec(step = 0) sleep(60) unless @opts['routine-immediately'] cmd = Zold::Remote.new(remotes: @remotes, log: @log, farm: @farm) args = ['remote', "--network=#{Shellwords.escape(@opts['network'])}", '--ignore-ping'] score = @farm.best[0] args << "--ignore-node=#{Shellwords.escape("#{score.host}:#{score.port}")}" if score cmd.run(args + ['masters']) unless @opts['routine-immediately'] return if @opts['routine-immediately'] && @remotes.all.empty? cmd.run(args + ['select']) if (step % 10).zero? @log.info("It is round ##{step}, time to update the list of remotes") update(cmd, args) end if @remotes.all.any? { |r| r[:errors] > Zold::Remotes::TOLERANCE } @log.info('There are a few remote nodes with too many errors, it\'s time to update') update(cmd, args) else @log.debug("All #{@remotes.all.count} remote nodes are still more or less error-free, won't update") end if @remotes.all.count < Zold::Remotes::MAX_NODES / 2 @log.info("There are just #{@remotes.all.count} remotes in the list, time to update") update(cmd, args) end cmd.run(args + ['trim']) cmd.run(args + ['select']) @log.info("Reconnected, there are #{@remotes.all.count} remote notes: \ #{@remotes.all.map { |r| "#{r[:host]}:#{r[:port]}/#{r[:score]}/#{r[:errors]}" }.join(', ')}") end
Private Instance Methods
update(cmd, args)
click to toggle source
# File lib/zold/commands/routines/reconnect.rb, line 71 def update(cmd, args) cmd.run(args + ['update'] + (@opts['never-reboot'] ? [] : ['--reboot'])) end