Sha256: ce0fd9f7309bfd3d23a3d642050d21a6798bb45111e8564566858a91e36b6f29
Contents?: true
Size: 1.39 KB
Versions: 14
Compression:
Stored size: 1.39 KB
Contents
# encoding: utf-8
require "logstash/util/loggable"
require 'concurrent/atomic/atomic_reference'
module FileWatch
class Processor
include LogStash::Util::Loggable
attr_reader :watch
def initialize(settings)
@settings = settings
@deletable_paths = Concurrent::AtomicReference.new []
end
def add_watch(watch)
@watch = watch
self
end
def clear_deletable_paths
@deletable_paths.get_and_set []
end
def add_deletable_path(path)
@deletable_paths.get << path
end
def restat(watched_file)
changed = watched_file.restat!
if changed
# the collection (when sorted by modified_at) needs to re-sort every time watched-file is modified,
# we can perform these update operation while processing files (stat interval) instead of having to
# re-sort the whole collection every time an entry is accessed
@watch.watched_files_collection.update(watched_file)
end
end
private
def error_details(error, watched_file)
details = { :path => watched_file.path,
:exception => error.class,
:message => error.message,
:backtrace => error.backtrace }
if logger.debug?
details[:file] = watched_file
else
details[:backtrace] = details[:backtrace].take(8) if details[:backtrace]
end
details
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems