Sha256: 560ca316ddaa85ba46c1dcef285fc38ec1883f887794c29e712c404881538f39

Contents?: true

Size: 1.44 KB

Versions: 7

Compression:

Stored size: 1.44 KB

Contents

require 'thread'
require 'listen/internals/thread_pool'

module Listen
  module Adapter
    # Adapter implementation for Mac OS X `FSEvents`.
    #
    class Darwin < Base
      OS_REGEXP = /darwin(1.+)?$/i

      # The default delay between checking for changes.
      DEFAULTS = { latency: 0.1 }

      private

      # NOTE: each directory gets a DIFFERENT callback!
      def _configure(dir, &callback)
        require 'rb-fsevent'
        opts = { latency: options.latency }

        @workers ||= ::Queue.new
        @workers << FSEvent.new.tap do |worker|
          worker.watch(dir.to_s, opts, &callback)
        end
      end

      # NOTE: _run is called within a thread, so run every other
      # worker in it's own thread
      def _run
        first = @workers.pop
        until @workers.empty?
          next_worker = @workers.pop
          Listen::Internals::ThreadPool.add do
            begin
              next_worker.run
            rescue
              _log_exception 'run() in extra thread(s) failed: %s: %s'
            end
          end
        end
        first.run
      end

      def _process_event(dir, event)
        event.each do |path|
          new_path = Pathname.new(path.sub(/\/$/, ''))
          _log :debug, "fsevent: #{new_path}"
          # TODO: does this preserve symlinks?
          rel_path = new_path.relative_path_from(dir).to_s
          _queue_change(:dir, dir, rel_path, recursive: true)
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 4 rubygems

Version Path
mastermind_adeybee-0.1.4 vendor/bundle/ruby/2.2.0/gems/listen-3.0.3/lib/listen/adapter/darwin.rb
mastermind_adeybee-0.1.3 vendor/bundle/ruby/2.2.0/gems/listen-3.0.3/lib/listen/adapter/darwin.rb
mastermind_adeybee-0.1.2 vendor/bundle/ruby/2.2.0/gems/listen-3.0.3/lib/listen/adapter/darwin.rb
mastermind_adeybee-0.1.1 vendor/bundle/ruby/2.2.0/gems/listen-3.0.3/lib/listen/adapter/darwin.rb
vagrant-cloudstack-1.2.0 vendor/bundle/gems/listen-3.0.3/lib/listen/adapter/darwin.rb
geminfo-0.1.0 path/gems/listen-3.0.3/lib/listen/adapter/darwin.rb
listen-3.0.3 lib/listen/adapter/darwin.rb