Sha256: 1cc782f307f769ae31b5da2ee00cf68d365db2e5cbcc4c3c7f2d094f0f1b9b8c
Contents?: true
Size: 1.67 KB
Versions: 5
Compression:
Stored size: 1.67 KB
Contents
# frozen_string_literal: true
require 'timeout'
require 'timers'
module RubyRabbitmqJanus
module Janus
module Concurrencies
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
#
# # 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
block.binding.receiver.restart_session if yield
end
rescue Timeout::Error
stop_timer
block.binding.receiver.instance_is_down
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems