Contents

# frozen_string_literal: true

require 'timeout'
require 'timers'

module RubyRabbitmqJanus
  module Janus
    module Concurrencies
      # @author VAILLANT Jeremy <[e-mail]>
      #
      # # Manage time for thread
      #
      # Configure all timer used in keepalive class
      class KeepaliveTimer
        # Initialize timer to keeaplive thread.
        # Configure timer with :
        #   - interval for each keepalive message
        #   - timeout for session response
        #   - timeout for publish message
        def initialize
          @time_to_live = Tools::Config.instance.ttl
          @time_publish = @time_to_live + 5
          @timer = Timers::Group.new
        end

        # Execute a loop with timer for sending keepalive message
        # to Janus Instance
        def loop_keepalive(&block)
          @timer.now_and_every(@time_to_live) { prepare_loop(&block) }
          loop { @timer.wait }
        end

        # Test if session is present/exist in Janus Instance
        def session(&block)
          Timeout.timeout(@time_publish) { yield }
        rescue Timeout::Error
          stop_timer
          block.binding.receiver.instance_is_down
        end

        # Stop timer to keepalive thread
        def stop_timer
          @timer.pause
        end

        # Start timer to keepalive thread
        def start_timer
          @timer.resume
        end

        private

        def prepare_loop(&block)
          Timeout.timeout(@time_publish) do
            yield
          end
        rescue Timeout::Error
          stop_timer
          block.binding.receiver.instance_is_down
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ruby_rabbitmq_janus-2.2.0.pre.164	lib/rrj/janus/processus/keepalive/keepalive_timer.rb
ruby_rabbitmq_janus-2.2.0.pre.161	lib/rrj/janus/processus/keepalive/keepalive_timer.rb
ruby_rabbitmq_janus-2.2.0.pre.159	lib/rrj/janus/processus/keepalive/keepalive_timer.rb
ruby_rabbitmq_janus-2.2.0.pre.42	lib/rrj/janus/processus/keepalive/keepalive_timer.rb