github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

wait for pipeline thread to end before returning from the stop action

Browse source
This commit is contained in:
Colin Surprenant 2017-08-30 12:16:45 -04:00
parent 83166b4ddf
commit d7eec97a80
1 changed files with 1 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
logstash-core/lib/logstash/pipeline_action/stop.rb
View file

@ -14,6 +14,7 @@ module LogStash module PipelineAction
def execute(agent, pipelines)
pipeline = pipelines[pipeline_id]
pipeline.shutdown { LogStash::ShutdownWatcher.start(pipeline) }
pipeline.thread.join
pipelines.delete(pipeline_id)
# If we reach this part of the code we have succeeded because
# the shutdown call will block.