mirror of
https://github.com/discourse/discourse.git
synced 2025-05-22 22:43:33 +08:00
Merge pull request #4870 from tgxworld/fix_cleanup_sockets_servers
FIX: Ensure we clean up socket servers.
This commit is contained in:
@ -16,7 +16,8 @@ class SocketServer
|
|||||||
end
|
end
|
||||||
|
|
||||||
def stop
|
def stop
|
||||||
@server.close if @server
|
@server&.close rescue nil
|
||||||
|
FileUtils.rm_f(@socket_path)
|
||||||
@server = nil
|
@server = nil
|
||||||
@blk = nil
|
@blk = nil
|
||||||
end
|
end
|
||||||
@ -26,10 +27,15 @@ class SocketServer
|
|||||||
def new_accept_thread
|
def new_accept_thread
|
||||||
server = @server
|
server = @server
|
||||||
Thread.new do
|
Thread.new do
|
||||||
|
begin
|
||||||
done = false
|
done = false
|
||||||
while !done
|
while !done
|
||||||
done = !accept_connection(server)
|
done = !accept_connection(server)
|
||||||
end
|
end
|
||||||
|
ensure
|
||||||
|
self.stop
|
||||||
|
Rails.logger.info("Cleaned up socket server at #{@socket_path}")
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user