Method: Fluent::Plugin::Output#synchronize_path_in_workers

Defined in:
lib/fluent/plugin/output.rb

#synchronize_path_in_workers(path) ⇒ Object 



621
622
623
624
625
626
627
628
 
# File 'lib/fluent/plugin/output.rb', line 621

def synchronize_path_in_workers(path)
  need_worker_lock = system_config.workers > 1
  if need_worker_lock
    acquire_worker_lock(path) { yield }
  else
    yield
  end
end