Status-informations every 5 seconds added (fix)
This commit is contained in:
parent
c8d68f41b1
commit
0de5632516
2 changed files with 2 additions and 2 deletions
|
@ -58,7 +58,7 @@ end
|
||||||
|
|
||||||
class LogAn::AutoValueConvertHash
|
class LogAn::AutoValueConvertHash
|
||||||
include Enumerable
|
include Enumerable
|
||||||
attr_reader :decode, :encode
|
attr_reader :decode, :encode, :source
|
||||||
|
|
||||||
def initialize source, encode = nil, each = nil, &decode
|
def initialize source, encode = nil, each = nil, &decode
|
||||||
@source, @encoder = source, decode.nil? ? encode || Marshal.method( :dump) : nil,
|
@source, @encoder = source, decode.nil? ? encode || Marshal.method( :dump) : nil,
|
||||||
|
|
|
@ -79,7 +79,7 @@ module LogAn::Inc
|
||||||
status = lambda do
|
status = lambda do
|
||||||
@select.at Time.now+5, &status
|
@select.at Time.now+5, &status
|
||||||
$stderr.puts "#{Time.now.strftime"%H:%M:%S"}|INFO|Statistic|#{@select.inspect}"
|
$stderr.puts "#{Time.now.strftime"%H:%M:%S"}|INFO|Statistic|#{@select.inspect}"
|
||||||
@conf[:stores].source.source.flush!
|
@conf[:stores].each{|key, db| db.source.source.flush!}
|
||||||
end
|
end
|
||||||
status.call
|
status.call
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue