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