class RSwim::Member::TransmissionState::Base
Public Class Methods
new(id, node_member_id, member_pool, source_ids, target_ids)
click to toggle source
# File lib/rswim/member/transmission_state/base.rb, line 7 def initialize(id, node_member_id, member_pool, source_ids, target_ids) @member_pool = member_pool @id = id @node_member_id = node_member_id @source_ids = source_ids @target_ids = target_ids logger.debug("Member with id #{id} entered new state: #{self.class}") end
Public Instance Methods
advance(_elapsed_seconds)
click to toggle source
# File lib/rswim/member/transmission_state/base.rb, line 18 def advance(_elapsed_seconds) self end
enqueue_ping()
click to toggle source
# File lib/rswim/member/transmission_state/base.rb, line 26 def enqueue_ping @source_ids << @id end
enqueue_ping_from(source_id)
click to toggle source
# File lib/rswim/member/transmission_state/base.rb, line 30 def enqueue_ping_from(source_id) @source_ids << source_id end
enqueue_ping_request(target_id)
click to toggle source
# File lib/rswim/member/transmission_state/base.rb, line 34 def enqueue_ping_request(target_id) @target_ids << target_id end
member_replied_with_ack()
click to toggle source
# File lib/rswim/member/transmission_state/base.rb, line 16 def member_replied_with_ack; end
prepare_output()
click to toggle source
# File lib/rswim/member/transmission_state/base.rb, line 22 def prepare_output [] end
Protected Instance Methods
logger()
click to toggle source
# File lib/rswim/member/transmission_state/base.rb, line 40 def logger @_logger ||= begin RSwim::Logger.new("Node #{@node_member_id}", STDERR) end end