class Orchestrator::Proxy

Constants

COMMANDS

Public Class Methods

new(thread) click to toggle source
# File lib/orchestrator/remote/proxy.rb, line 8
def initialize(thread)
    @thread = thread

    @accept_connection = method :accept_connection
    @new_connection =    method :new_connection
    @bind_error =        method :bind_error

    @shutdown = true
    @edge_nodes = ::ThreadSafe::Cache.new # id => connection
    @req_map    = {} # connection => ::Set.new (defers)
    @req_map    = {}

    @signal_bind   = @thread.async method(:bind_actual)
    @signal_unbind = @thread.async method(:unbind_actual)
end