Class: Droonga::FluentMessageReceiver::HeartbeatReceiver

Inherits:
Object
  • Object
show all
Includes:
Loggable
Defined in:
lib/droonga/fluent_message_receiver.rb

Instance Method Summary collapse

Constructor Details

#initialize(loop, fd) ⇒ HeartbeatReceiver

Returns a new instance of HeartbeatReceiver.



159
160
161
162
 
# File 'lib/droonga/fluent_message_receiver.rb', line 159

def initialize(loop, fd)
  @loop = loop
  @fd = fd
end

Instance Method Details

#shutdown ⇒ Object 



177
178
179
180
181
182
183
 
# File 'lib/droonga/fluent_message_receiver.rb', line 177

def shutdown
  @socket.close
  @watcher.detach
  logger.trace("shutdown: heartbeat watcher detached",
               :watcher => @watcher,
               :fd      => @fd)
end

#start ⇒ Object 



164
165
166
167
168
169
170
171
172
173
174
175
 
# File 'lib/droonga/fluent_message_receiver.rb', line 164

def start
  @socket = UDPSocket.for_fd(@fd)

  @watcher = Coolio::IOWatcher.new(@socket, "r")
  @watcher.on_readable do
    receive_heartbeat
  end
  @loop.attach(@watcher)
  logger.trace("start: heartbeat IO watcher attached",
               :watcher => @watcher,
               :fd      => @fd)
end