X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/f17a26ca512ae0083ea5ad608ad6cfbb7fd247ee..794cecd80b3fc3c9812687fa9e4e269fb1e79c60:/services/api/app/middlewares/rack_socket.rb diff --git a/services/api/app/middlewares/rack_socket.rb b/services/api/app/middlewares/rack_socket.rb index 8f82e585df..1b301e27ab 100644 --- a/services/api/app/middlewares/rack_socket.rb +++ b/services/api/app/middlewares/rack_socket.rb @@ -1,3 +1,7 @@ +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: AGPL-3.0 + require 'rack' require 'faye/websocket' require 'eventmachine' @@ -44,18 +48,26 @@ class RackSocket if forked && EM.reactor_running? EM.stop end - Thread.new { - EM.run - } + Thread.new do + begin + EM.run + ensure + ActiveRecord::Base.connection.close + end + end die_gracefully_on_signal end else # faciliates debugging Thread.abort_on_exception = true # just spawn a thread and start it up - Thread.new { - EM.run - } + Thread.new do + begin + EM.run + ensure + ActiveRecord::Base.connection.close + end + end end # Create actual handler instance object from handler class.