Class: FileWatch::TailMode::Handlers::Unignore

Inherits:
Base
  • Object
show all
Defined in:
lib/filewatch/tail_mode/handlers/unignore.rb

Instance Attribute Summary

Attributes inherited from Base

#sincedb_collection

Instance Method Summary collapse

Methods inherited from Base

#handle, #initialize, #quit?

Constructor Details

This class inherits a constructor from FileWatch::TailMode::Handlers::Base

Instance Method Details

#get_new_value_specifically(watched_file) ⇒ Object 



12
13
14
15
16
17
18
19
20
 
# File 'lib/filewatch/tail_mode/handlers/unignore.rb', line 12

def get_new_value_specifically(watched_file)
  # for file initially ignored their bytes_read was set to stat.size
  # use this value not the `start_new_files_at` for the position
  # logger.trace("get_new_value_specifically", "watched_file" => watched_file.inspect)
  SincedbValue.new(watched_file.bytes_read).tap do |sincedb_value|
    sincedb_value.set_watched_file(watched_file)
    logger.trace? && logger.trace("get_new_value_specifically: unignore", :watched_file => watched_file.details, :sincedb_value => sincedb_value)
  end
end

#handle_specifically(watched_file) ⇒ Object

a watched file can be put straight into the ignored state before any other handling has been done at a minimum we create or associate a sincedb value



8
9
10
 
# File 'lib/filewatch/tail_mode/handlers/unignore.rb', line 8

def handle_specifically(watched_file)
  add_or_update_sincedb_collection(watched_file)
end

#update_existing_specifically(watched_file, sincedb_value) ⇒ Object 



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/filewatch/tail_mode/handlers/unignore.rb', line 22

def update_existing_specifically(watched_file, sincedb_value)
  # when this watched_file was ignored it had it bytes_read set to eof
  # now the file has changed (watched_file.size_changed?)
  # it has been put into the watched state so when it becomes active
  # we will handle grow or shrink
  # for now we seek to where we were before the file got ignored (grow)
  # or to the start (shrink)
  logger.trace? && logger.trace("update_existing_specifically: unignore", :watched_file => watched_file.details, :sincedb_value => sincedb_value)
  position = 0
  if watched_file.shrunk?
    watched_file.update_bytes_read(0)
  else
    position = watched_file.bytes_read
  end
  sincedb_value.update_position(position)
end