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