class RSwim::Member::TransmissionState::Ready

Public Class Methods

new(id, node_member_id, member_pool, source_ids = [], target_ids = []) click to toggle source
# File lib/rswim/member/transmission_state/ready.rb, line 7
def initialize(id, node_member_id, member_pool, source_ids = [], target_ids = [])
  super
end

Public Instance Methods

advance(_elapsed_seconds) click to toggle source
# File lib/rswim/member/transmission_state/ready.rb, line 15
def advance(_elapsed_seconds)
  if !@source_ids.empty?
    SendingPing.new(@id, @node_member_id, @member_pool, @source_ids, @target_ids)
  elsif !@target_ids.empty?
    SendingPingRequest.new(@id, @node_member_id, @member_pool, @source_ids, @target_ids)
  else
    self
  end
end
member_replied_with_ack() click to toggle source
# File lib/rswim/member/transmission_state/ready.rb, line 11
def member_replied_with_ack
  logger.debug("out of order ack from member #{@id}")
end