Module: Taskinator::Logging
- Defined in:
- lib/taskinator/logger.rb
Defined Under Namespace
Classes: Pretty
Class Method Summary collapse
- .initialize_logger(log_target = STDOUT) ⇒ Object
- .logger ⇒ Object
- .logger=(log) ⇒ Object
-
.reopen_logs ⇒ Object
This reopens ALL logfiles in the process that have been rotated using logrotate(8) (without copytruncate) or similar tools.
- .with_context(msg) ⇒ Object
Instance Method Summary collapse
Class Method Details
.initialize_logger(log_target = STDOUT) ⇒ Object
40 41 42 43 44 45 46 47 |
# File 'lib/taskinator/logger.rb', line 40 def self.initialize_logger(log_target = STDOUT) oldlogger = defined?(@logger) ? @logger : nil @logger = Logger.new(log_target) @logger.level = Logger::INFO @logger.formatter = Pretty.new oldlogger.close if oldlogger && !$TESTING # don't want to close testing's STDOUT logging @logger end |
.logger ⇒ Object
49 50 51 |
# File 'lib/taskinator/logger.rb', line 49 def self.logger defined?(@logger) ? @logger : initialize_logger end |
.logger=(log) ⇒ Object
53 54 55 |
# File 'lib/taskinator/logger.rb', line 53 def self.logger=(log) @logger = (log ? log : Logger.new('/dev/null')) end |
.reopen_logs ⇒ Object
This reopens ALL logfiles in the process that have been rotated using logrotate(8) (without copytruncate) or similar tools. A File
object is considered for reopening if it is:
1) opened with the O_APPEND and O_WRONLY flags
2) the current open file handle does not match its original open path
3) unbuffered (as far as userspace buffering goes, not O_SYNC)
Returns the number of files reopened
64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 |
# File 'lib/taskinator/logger.rb', line 64 def self.reopen_logs to_reopen = [] append_flags = File::WRONLY | File::APPEND ObjectSpace.each_object(File) do |fp| begin if !fp.closed? && fp.stat.file? && fp.sync && (fp.fcntl(Fcntl::F_GETFL) & append_flags) == append_flags to_reopen << fp end rescue IOError, Errno::EBADF end end nr = 0 to_reopen.each do |fp| orig_st = begin fp.stat rescue IOError, Errno::EBADF next end begin b = File.stat(fp.path) next if orig_st.ino == b.ino && orig_st.dev == b.dev rescue Errno::ENOENT end begin File.open(fp.path, 'a') { |tmpfp| fp.reopen(tmpfp) } fp.sync = true nr += 1 rescue IOError, Errno::EBADF # not much we can do... end end nr rescue RuntimeError => ex # RuntimeError: ObjectSpace is disabled; each_object will only work with Class, pass -X+O to enable puts "Unable to reopen logs: #{ex.}" end |
.with_context(msg) ⇒ Object
31 32 33 34 35 36 37 38 |
# File 'lib/taskinator/logger.rb', line 31 def self.with_context(msg) begin Thread.current[:taskinator_context] = msg yield ensure Thread.current[:taskinator_context] = nil end end |
Instance Method Details
#logger ⇒ Object
105 106 107 |
# File 'lib/taskinator/logger.rb', line 105 def logger Taskinator::Logging.logger end |