Sha256: 3e80b0b6b59613a70f80cf871d459a450730baf57a5a2b5055ea7d63cdb05163
Contents?: true
Size: 1.76 KB
Versions: 17
Compression:
Stored size: 1.76 KB
Contents
module Einhorn::Event
class Connection < AbstractTextDescriptor
include Persistent
def initialize(*args)
@subscriptions = {}
super
end
def parse_record
split = @read_buffer.split("\n", 2)
if split.length > 1
split
else
nil
end
end
def consume_record(command)
Einhorn::Command::Interface.process_command(self, command)
end
def to_state
state = {:class => self.class.to_s, :socket => @socket.fileno}
# Don't include by default because it's not that pretty
state[:read_buffer] = @read_buffer if @read_buffer.length > 0
state[:write_buffer] = @write_buffer if @write_buffer.length > 0
state[:subscriptions] = @subscriptions
state
end
def self.from_state(state)
fd = state[:socket]
socket = Socket.for_fd(fd)
conn = self.open(socket)
conn.read_buffer = state[:read_buffer] if state[:read_buffer]
conn.write_buffer = state[:write_buffer] if state[:write_buffer]
# subscriptions could be empty if upgrading from an older version of einhorn
state.fetch(:subscriptions, {}).each do |tag, id|
conn.subscribe(tag, id)
end
conn
end
def subscribe(tag, request_id)
if request_id
@subscriptions[tag] = request_id
end
end
def subscription(tag)
@subscriptions[tag]
end
def unsubscribe(tag)
@subscriptions.delete(tag)
end
def register!
log_info("client connected")
Einhorn::Event.register_connection(self, @socket.fileno)
super
end
def deregister!
log_info("client disconnected") if Einhorn::TransientState.whatami == :master
Einhorn::Event.deregister_connection(@socket.fileno)
super
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems