github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

- Default statefile location of ~/.rb_since

Browse source 
- Handle case where statefile does not exist
This commit is contained in:
Jordan Sissel 2009-08-17 08:23:48 +00:00
parent 1b1933c0f5
commit 657266316d
1 changed files with 9 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

14
lib/file/tail/since.rb
View file

@ -23,8 +23,8 @@ class File; module Tail;
class Since < File::Tail::Logfile
attr_accessor :statefile
def initialize(statefile, *args)
@statefile = statefile
def initialize(*args)
@statefile = "#{ENV["HOME"]}/.rb_since"
super(*args)
load_state
end
@ -43,7 +43,11 @@ class File; module Tail;
end
def load_state
statefd = File.open(statefile, "r");
if !File.exist?(@statefile)
return Hash.new
end
statefd = File.open(@statefile, "r");
lock_state(statefd) do
data = (YAML::load(statefd.read()) or Hash.new)
if data.has_key?(path)
@ -59,7 +63,7 @@ class File; module Tail;
end
def save_state
statefd = File.open(statefile, "w+");
statefd = File.open(@statefile, "w+");
lock_state(statefd) do
# TODO(sissel): We should catch load/read exceptions
data = (YAML::load(statefd.read()) or Hash.new)
@ -80,7 +84,7 @@ class File; module Tail;
end; end; # File::Tail
if $0 == __FILE__
File::Tail::Since.new(statefile="/tmp/since.state", "/var/log/messages").tail do |line|
File::Tail::Since.new("/var/log/messages").tail do |line|
puts line
end
end