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 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226
|
# encoding: UTF-8
require File.expand_path('../setup', File.dirname(__FILE__))
module TestLogging
module TestAppenders
class TestBufferedIO < Test::Unit::TestCase
include LoggingTestCase
def setup
super
@appender = Logging.appenders.string_io \
'test_appender',
:auto_flushing => 3,
:immediate_at => :error,
:encoding => 'UTF-8'
@appender.clear
@sio = @appender.sio
@levels = Logging::LEVELS
begin readline rescue EOFError end
end
def test_append
event = Logging::LogEvent.new('TestLogger', @levels['warn'],
[1, 2, 3, 4], false)
@appender.append event
assert_nil(readline)
@appender.append event
assert_nil(readline)
event.level = @levels['debug']
event.data = 'the big log message'
@appender.append event
assert_equal " WARN TestLogger : <Array> #{[1, 2, 3, 4]}\n", readline
assert_equal " WARN TestLogger : <Array> #{[1, 2, 3, 4]}\n", readline
assert_equal "DEBUG TestLogger : the big log message\n", readline
assert_nil(readline)
@appender.close
assert_raise(RuntimeError) {@appender.append event}
end
def test_append_with_write_size
event = Logging::LogEvent.new('TestLogger', @levels['warn'], %w[a b c d], false)
@appender.write_size = 2
@appender.append event
assert_nil(readline)
@appender.append event
assert_nil(readline)
event.level = @levels['debug']
event.data = 'the big log message'
@appender.append event
assert_equal " WARN TestLogger : <Array> #{%w[a b c d]}\n", readline
assert_equal " WARN TestLogger : <Array> #{%w[a b c d]}\n", readline
assert_equal "DEBUG TestLogger : the big log message\n", readline
assert_nil(readline)
end
def test_append_error
# setup an internal logger to capture error messages from the IO
# appender
log = Logging.appenders.string_io('__internal_io')
Logging.logger[Logging].add_appenders(log)
Logging.logger[Logging].level = 'all'
# close the string IO object so we get an error
@sio.close
event = Logging::LogEvent.new('TestLogger', @levels['warn'],
[1, 2, 3, 4], false)
@appender.append event
assert_nil(log.readline)
@appender.append event
assert_nil(log.readline)
@appender.append event
assert_equal "INFO Logging : appender \"test_appender\" has been disabled", log.readline.strip
assert_equal "ERROR Logging : <IOError> not opened for writing", log.readline.strip
assert_equal false, @appender.closed?
assert_equal 5, @appender.level
end
def test_auto_flushing
assert_raise(ArgumentError) {
@appender.auto_flushing = Object.new
}
assert_raise(ArgumentError) {
@appender.auto_flushing = -1
}
@appender.auto_flushing = 0
assert_equal Logging::Appenders::Buffering::DEFAULT_BUFFER_SIZE, @appender.auto_flushing
end
def test_close
assert_equal false, @sio.closed?
assert_equal false, @appender.closed?
@appender.close
assert_equal true, @sio.closed?
assert_equal true, @appender.closed?
[STDIN, STDERR, STDOUT].each do |io|
@appender = Logging.appenders.io('test', io)
@appender.close
assert_equal false, io.closed?
assert_equal true, @appender.closed?
end
end
def test_concat
@appender << "this is a test message\n"
assert_nil(readline)
@appender << "this is another message\n"
assert_nil(readline)
@appender << "some other line\n"
assert_equal "this is a test message\n", readline
assert_equal "this is another message\n", readline
assert_equal "some other line\n", readline
assert_nil(readline)
@appender.close
assert_raise(RuntimeError) {@appender << 'message'}
end
def test_concat_error
# setup an internal logger to capture error messages from the IO
# appender
log = Logging.appenders.string_io('__internal_io')
Logging.logger[Logging].add_appenders(log)
Logging.logger[Logging].level = 'all'
# close the string IO object so we get an error
@sio.close
@appender << 'oopsy'
assert_nil(log.readline)
@appender << 'whoopsy'
assert_nil(log.readline)
@appender << 'pooh'
assert_equal "INFO Logging : appender \"test_appender\" has been disabled", log.readline.strip
assert_equal "ERROR Logging : <IOError> not opened for writing", log.readline.strip
# and the appender does not close itself
assert_equal false, @appender.closed?
assert_equal 5, @appender.level
end
def test_flush
@appender << "this is a test message\n"
assert_nil(readline)
@appender.flush
assert_equal "this is a test message\n", readline
assert_nil(readline)
end
def test_clear
@appender << "this is a test message\n"
@appender << "this is another test message\n"
@appender.clear!
@appender.flush
assert_nil(readline)
end
def test_immediate_at
event = Logging::LogEvent.new('TestLogger', @levels['warn'],
[1, 2, 3, 4], false)
@appender.append event
assert_nil(readline)
event.level = @levels['error']
event.data = 'an error message'
@appender.append event
assert_equal " WARN TestLogger : <Array> #{[1, 2, 3, 4]}\n", readline
assert_equal "ERROR TestLogger : an error message\n", readline
assert_nil(readline)
end
if Object.const_defined?(:Encoding)
def test_force_encoding
a = 'ümlaut'
b = 'hello ümlaut'.force_encoding('BINARY')
event_a = Logging::LogEvent.new('TestLogger', @levels['info'], a, false)
event_b = Logging::LogEvent.new('TestLogger', @levels['info'], b, false)
@appender.append event_a
@appender.append event_b
assert_nil(readline)
@appender.append event_a
assert_equal " INFO TestLogger : #{a}\n", readline
assert_equal " INFO TestLogger : #{b.force_encoding('UTF-8')}\n", readline
assert_equal " INFO TestLogger : #{a}\n", readline
assert_nil(readline)
end
end
private
def readline
@appender.readline
end
end # class TestBufferedIO
end # module TestAppenders
end # module TestLogging
|