module Fluent::PluginHelper::EventLoop

def event_loop_attach(watcher)
  @_event_loop_mutex.synchronize do
    @_event_loop.attach(watcher)
    @_event_loop_attached_watchers << watcher
    watcher
  end
end