# File lib/listen/adapter/bsd.rb, line 46 def self.usable? return false unless super Kernel.warn BSD_EXPERIMENTAL require 'rb-kqueue' require 'find' true rescue LoadError Kernel.warn BUNDLER_DECLARE_GEM false end
# File lib/listen/adapter/bsd.rb, line 88 def _change(event_flags) { modified: [:attrib, :extend], added: [:write], removed: [:rename, :delete] }.each do |change, flags| return change unless (flags & event_flags).empty? end nil end
# File lib/listen/adapter/bsd.rb, line 59 def _configure(directory, &_callback) @worker ||= KQueue::Queue.new # use Record to make a snapshot of dir, so we # can detect new files _find(directory.to_s) { |path| _watch_file(path, @worker) } end
# File lib/listen/adapter/bsd.rb, line 98 def _event_path(event) Pathname.new(event.watcher.path) end
Quick rubocop workaround
# File lib/listen/adapter/bsd.rb, line 116 def _find(*paths) Find.send(:find, *paths) end
# File lib/listen/adapter/bsd.rb, line 70 def _process_event(dir, event) full_path = _event_path(event) if full_path.directory? # Force dir content tracking to kick in, or we won't have # names of added files _queue_change(:dir, dir, '.', recursive: true) else path = full_path.relative_path_from(dir) _queue_change(:file, dir, path, change: _change(event.flags)) end # If it is a directory, and it has a write flag, it means a # file has been added so find out which and deal with it. # No need to check for removed files, kqueue will forget them # when the vfs does. _watch_for_new_file(event) if path.directory? end
# File lib/listen/adapter/bsd.rb, line 66 def _run @worker.run end
# File lib/listen/adapter/bsd.rb, line 111 def _watch_file(path, queue) queue.watch_file(path, *options.events, &_worker_callback) end
# File lib/listen/adapter/bsd.rb, line 102 def _watch_for_new_file(event) queue = event.watcher.queue _find(_event_path(event).to_s) do |file_path| unless queue.watchers.detect { |_, v| v.path == file_path.to_s } _watch_file(file_path, queue) end end end