Sha256: 1ccb4bc89a341c3de612afe3ea523718202ae9f569ccad1fc39b442d631aa971
Contents?: true
Size: 1.7 KB
Versions: 8
Compression:
Stored size: 1.7 KB
Contents
# frozen_string_literal: true module SplitIoClient module SSE module Workers class SplitsWorker def initialize(synchronizer, config, splits_repository) @synchronizer = synchronizer @config = config @splits_repository = splits_repository @queue = Queue.new end def start perform_thread perform_passenger_forked if defined?(PhusionPassenger) end def add_to_queue(change_number) @config.logger.debug("SplitsWorker add to queue #{change_number}") @queue.push(change_number) end def kill_split(change_number, split_name, default_treatment) @config.logger.debug("SplitsWorker kill #{split_name}, #{change_number}") @splits_repository.kill(change_number, split_name, default_treatment) add_to_queue(change_number) end def stop SplitIoClient::Helpers::ThreadHelper.stop(:split_update_worker, @config) end private def perform while (change_number = @queue.pop) since = @splits_repository.get_change_number unless since.to_i >= change_number @config.logger.debug("SplitsWorker fetch_splits with #{since}") @synchronizer.fetch_splits end end end def perform_thread @config.threads[:split_update_worker] = Thread.new do @config.logger.debug('Starting splits worker ...') perform end end def perform_passenger_forked PhusionPassenger.on_event(:starting_worker_process) { |forked| perform_thread if forked } end end end end end
Version data entries
8 entries across 8 versions & 1 rubygems