allow multiple blocking threads per listen socket

This is probably not needed and just adds contention, but it makes
experimenting easier.

While we're at it, validate minimum values of for sndbuf/rcvbuf
along with this new threads value, too.

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