class Falcon::Controller::Serve
Uses {Server} for handling incoming requests.
A generic controller for serving an application.
def create_container
Create the controller as specified by the command.
def create_container @command.container_class.new end
def endpoint
def endpoint @command.endpoint end
def initialize(command, **options)
Initialize the server controller.
def initialize(command, **options) @command = command @endpoint = nil @bound_endpoint = nil @debug_trap = Async::IO::Trap.new(:USR1) super(**options) end
def load_app
def load_app @command.load_app end
def name
def name "Falcon Server" end
def setup(container)
Setup the container with the application instance.
def setup(container) container.run(name: self.name, restart: true, **@command.container_options) do |instance| Async do |task| # Load one app instance per container: app = self.load_app task.async do if @debug_trap.install! Console.logger.info(instance) do "- Per-process status: kill -USR1 #{Process.pid}" end end @debug_trap.trap do Console.logger.info(self) do |buffer| task.reactor.print_hierarchy(buffer) end end end server = Falcon::Server.new(app, @bound_endpoint, protocol: @endpoint.protocol, scheme: @endpoint.scheme) server.run instance.ready! task.children.each(&:wait) end end end
def start
def start @endpoint ||= self.endpoint @bound_endpoint = Async do Async::IO::SharedEndpoint.bound(@endpoint) end.wait Console.logger.info(self) { "Starting #{name} on #{@endpoint.to_url}" } @debug_trap.ignore! super end
def stop(*)
def stop(*) @bound_endpoint&.close @debug_trap.default! super end