module Griffin::Engine::Worker
Public Class Methods
new()
click to toggle source
# File lib/griffin/engine/worker.rb, line 6 def initialize @socket_manager = ServerEngine::SocketManager::Client.new(server.socket_manager_path) end
Public Instance Methods
before_fork()
click to toggle source
# File lib/griffin/engine/worker.rb, line 10 def before_fork server.core.before_run(worker_id) end
install_signal_handlers()
click to toggle source
Overwrite to identify the kind of signal in stop
github.com/treasure-data/serverengine/blob/a005f3535affaa5b15d1e66486d9349443398dd2/lib/serverengine/worker.rb#L61-L78
# File lib/griffin/engine/worker.rb, line 34 def install_signal_handlers w = self ServerEngine::SignalThread.new do |st| st.trap(ServerEngine::Signals::GRACEFUL_STOP) { |s| w.stop(s) } st.trap(ServerEngine::Signals::IMMEDIATE_STOP, 'SIG_DFL') st.trap(ServerEngine::Signals::GRACEFUL_RESTART) { |s| w.stop(s) } st.trap(ServerEngine::Signals::IMMEDIATE_RESTART, 'SIG_DFL') st.trap(ServerEngine::Signals::RELOAD) { w.logger.reopen! w.reload } st.trap(ServerEngine::Signals::DETACH) { |s| w.stop(s) } st.trap(ServerEngine::Signals::DUMP) { w.dump } end end
run()
click to toggle source
# File lib/griffin/engine/worker.rb, line 14 def run @lsock = @socket_manager.listen_tcp(config[:bind], config[:port]) @lsock.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, 1) server.core.run(@lsock) ensure @lsock.close if @lsock end
stop(signal = nil)
click to toggle source
# File lib/griffin/engine/worker.rb, line 22 def stop(signal = nil) kind = case signal when ServerEngine::Signals::GRACEFUL_STOP then Griffin::Server::GRACEFUL_SHUTDOWN when ServerEngine::Signals::IMMEDIATE_STOP then Griffin::Server::FORCE_SHUTDOWN when ServerEngine::Signals::GRACEFUL_RESTART then Griffin::Server::GRACEFUL_RESTART else Griffin::Server::GRACEFUL_SHUTDOWN end server.core.shutdown(kind) end