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