Sha256: c044f3393de548dce8d78be066daeeb6c61e08d4e98cd8422937c48adf7f0688
Contents?: true
Size: 446 Bytes
Versions: 33
Compression:
Stored size: 446 Bytes
Contents
module Einhorn::Event
class ACKTimer < Timer
include Persistent
def initialize(time, pid, start=nil)
super(time, start) do
Einhorn::Command.register_timer_ack(time, pid)
end
@pid = pid
end
def to_state
{:class => self.class.to_s, :time => @time, :start => @start, :pid => @pid}
end
def self.from_state(state)
self.open(state[:time], state[:pid], state[:start])
end
end
end
Version data entries
33 entries across 33 versions & 1 rubygems