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

don't put nulls in the map

Browse source 
Fixes #10872
This commit is contained in:
Dan Hermann 2019-06-27 19:16:07 -05:00
parent f48da1e461
commit e925b4c48d
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
logstash-core/lib/logstash/pipelines_registry.rb
View file

@ -64,7 +64,7 @@ module LogStash
@states.put(pipeline_id, state)
else
success = yield
@states.put(pipeline_id, success ? PipelineState.new(pipeline_id, pipeline) : nil)
@states.put(pipeline_id, PipelineState.new(pipeline_id, pipeline)) if success
end
success
@ -86,7 +86,7 @@ module LogStash
state = @states.get(pipeline_id)
if state.nil?
logger.error("Attempted to terminate a pipeline that does not exists", :pipeline_id => pipeline_id)
@states.put(pipeline_id, nil)
@states.remote(pipeline_id)
else
yield(state.pipeline)
@states.put(pipeline_id, state)
@ -112,7 +112,7 @@ module LogStash
state = @states.get(pipeline_id)
if state.nil?
logger.error("Attempted to reload a pipeline that does not exists", :pipeline_id => pipeline_id)
@states.put(pipeline_id, nil)
@states.remove(pipeline_id)
else
state.set_reloading(true)
begin