class IOPromise::Dalli::DalliExecutorPool
Public Class Methods
new(*)
click to toggle source
Calls superclass method
# File lib/iopromise/dalli/executor_pool.rb, line 8 def initialize(*) super @iop_monitor = nil end
Public Instance Methods
close_socket()
click to toggle source
# File lib/iopromise/dalli/executor_pool.rb, line 28 def close_socket unless @iop_monitor.nil? @iop_monitor.close @iop_monitor = nil end end
connected_socket(sock)
click to toggle source
# File lib/iopromise/dalli/executor_pool.rb, line 22 def connected_socket(sock) close_socket @iop_monitor = ::IOPromise::ExecutorContext.current.register_observer_io(self, sock, :r) end
dalli_server()
click to toggle source
# File lib/iopromise/dalli/executor_pool.rb, line 14 def dalli_server @connection_pool end
execute_continue()
click to toggle source
# File lib/iopromise/dalli/executor_pool.rb, line 18 def execute_continue dalli_server.execute_continue end
monitor_ready(monitor, readiness)
click to toggle source
# File lib/iopromise/dalli/executor_pool.rb, line 35 def monitor_ready(monitor, readiness) dalli_server.async_io_ready(monitor.readable?, monitor.writable?) end
set_interest(direction, interested)
click to toggle source
# File lib/iopromise/dalli/executor_pool.rb, line 39 def set_interest(direction, interested) if interested @iop_monitor.add_interest(direction) else @iop_monitor.remove_interest(direction) end end