class RSwim::Member::TransmissionState::SendingPingRequest
Public Class Methods
new(id, node_member_id, member_pool, source_ids, target_ids)
click to toggle source
Calls superclass method
RSwim::Member::TransmissionState::Base::new
# File lib/rswim/member/transmission_state/sending_ping_request.rb, line 7 def initialize(id, node_member_id, member_pool, source_ids, target_ids) super @done = false end
Public Instance Methods
advance(_elapsed_seconds)
click to toggle source
# File lib/rswim/member/transmission_state/sending_ping_request.rb, line 16 def advance(_elapsed_seconds) if @done then AwaitingAck.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/sending_ping_request.rb, line 12 def member_replied_with_ack logger.debug("out of order ack from member #{@id}") end
prepare_output()
click to toggle source
# File lib/rswim/member/transmission_state/sending_ping_request.rb, line 22 def prepare_output @done = true target_id = @target_ids.shift message = Message.new(@id, @node_member_id, :ping_req, target_id: target_id) [message] end