1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
module Logging::Appenders
# Accessor / Factory for the IO appender.
#
def self.io( *args )
return ::Logging::Appenders::IO if args.empty?
::Logging::Appenders::IO.new(*args)
end
# This class provides an Appender that can write to any IO stream
# configured for writing.
#
class IO < ::Logging::Appender
include Buffering
# The method that will be used to close the IO stream. Defaults to :close
# but can be :close_read, :close_write or nil. When nil, the IO stream
# will not be closed when the appender's close method is called.
#
attr_accessor :close_method
# call-seq:
# IO.new( name, io )
# IO.new( name, io, :layout => layout )
#
# Creates a new IO Appender using the given name that will use the _io_
# stream as the logging destination.
#
def initialize( name, io, opts = {} )
unless io.respond_to? :write
raise TypeError, "expecting an IO object but got '#{io.class.name}'"
end
@io = io
@io.sync = true if io.respond_to? :sync=
@close_method = :close
super(name, opts)
configure_buffering(opts)
end
# call-seq:
# close( footer = true )
#
# Close the appender and writes the layout footer to the logging
# destination if the _footer_ flag is set to +true+. Log events will
# no longer be written to the logging destination after the appender
# is closed.
#
def close( *args )
return self if @io.nil?
super
io, @io = @io, nil
unless [STDIN, STDERR, STDOUT].include?(io)
io.send(@close_method) if @close_method && io.respond_to?(@close_method)
end
rescue IOError
ensure
return self
end
private
# This method is called by the buffering code when messages need to be
# written to the logging destination.
#
def canonical_write( str )
return self if @io.nil?
str = str.force_encoding(encoding) if encoding && str.encoding != encoding
@io.write str
self
rescue StandardError => err
handle_internal_error(err)
end
def handle_internal_error( err )
return err if off?
self.level = :off
::Logging.log_internal {"appender #{name.inspect} has been disabled"}
::Logging.log_internal_error(err)
end
end # IO
end # Logging::Appenders
|
