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