diff options
Diffstat (limited to 'lib/yahns/server.rb')
| -rw-r--r-- | lib/yahns/server.rb | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/lib/yahns/server.rb b/lib/yahns/server.rb index 396b653..d7f1b54 100644 --- a/lib/yahns/server.rb +++ b/lib/yahns/server.rb @@ -341,11 +341,13 @@ class Yahns::Server # :nodoc: # spin up acceptor threads, clients flow into worker queues after this @listeners.each do |l| - ctx = sock_opts(l)[:yahns_app_ctx] + opts = sock_opts(l) + ctx = opts[:yahns_app_ctx] qegg = ctx.qegg || @config.qeggs[:default] + q = queues[qegg] ||= qegg_vivify(qegg, fdmap) # acceptors feed the the queues - l.spawn_acceptor(@logger, ctx, queues[qegg] ||= qegg_vivify(qegg, fdmap)) + l.spawn_acceptor(opts[:threads] || 1, @logger, ctx, q) end fdmap end |