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