Sha256: 961810c16f76a24dcd5ed7565b82d1683053f4739cb7add17aaaf408f166816e
Contents?: true
Size: 1.09 KB
Versions: 4
Compression:
Stored size: 1.09 KB
Contents
# frozen_string_literal: true require 'griffin/server' module Griffin module Engine class Single def self.create(config) serv = Griffin::Server.new( min_pool_size: config[:min_pool_size], max_pool_size: config[:max_pool_size], min_connection_size: config[:min_connection_size], max_connection_size: config[:max_connection_size], interceptors: config[:interceptors], ) new(serv, config) end def initialize(server, config) @server = server @config = config @sock = TCPServer.new(@config[:bind], @config[:port]) @sock.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, 1) end def run @config[:services].each do |s| @server.handle(s) end install_handler @server.before_run @sock.listen(Socket::SOMAXCONN) @server.run(@sock) end def install_handler trap('INT') do @server.shutdown end trap('TERM') do @server.shutdown end end end end end
Version data entries
4 entries across 4 versions & 1 rubygems
Version | Path |
---|---|
griffin-0.2.4 | lib/griffin/engine/single.rb |
griffin-0.2.3 | lib/griffin/engine/single.rb |
griffin-0.2.2 | lib/griffin/engine/single.rb |
griffin-0.2.1 | lib/griffin/engine/single.rb |