mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
parent
91b5128338
commit
bc4cdcb0a4
1 changed files with 8 additions and 2 deletions
|
@ -389,14 +389,20 @@ class LogStash::Agent
|
||||||
def start_webserver
|
def start_webserver
|
||||||
options = {:http_host => @http_host, :http_ports => @http_port, :http_environment => @http_environment }
|
options = {:http_host => @http_host, :http_ports => @http_port, :http_environment => @http_environment }
|
||||||
@webserver = LogStash::WebServer.new(@logger, self, options)
|
@webserver = LogStash::WebServer.new(@logger, self, options)
|
||||||
Thread.new(@webserver) do |webserver|
|
@webserver_thread = Thread.new(@webserver) do |webserver|
|
||||||
LogStash::Util.set_thread_name("Api Webserver")
|
LogStash::Util.set_thread_name("Api Webserver")
|
||||||
webserver.run
|
webserver.run
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def stop_webserver
|
def stop_webserver
|
||||||
@webserver.stop if @webserver
|
if @webserver
|
||||||
|
@webserver.stop
|
||||||
|
if @webserver_thread.join(5).nil?
|
||||||
|
@webserver_thread.kill
|
||||||
|
@webserver_thread.join
|
||||||
|
end
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def configure_metrics_collectors
|
def configure_metrics_collectors
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue