add missing lock statement

Fixes elastic#10872
andsel · Jun 29, 2019 · e0135c4 · e0135c4
1 parent b9da367
commit e0135c4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/logstash-core/lib/logstash/pipelines_registry.rb b/logstash-core/lib/logstash/pipelines_registry.rb
@@ -106,6 +106,7 @@ def terminate_pipeline(pipeline_id, &stop_block)
     def reload_pipeline(pipeline_id, &reload_block)
       lock = get_lock(pipeline_id)
       begin
+        lock.lock
         success = false
 
         state = @states.get(pipeline_id)