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
|
mod test_utils;
#[cfg(feature = "compress")]
use flexi_logger::{Age, Cleanup, Criterion, Duplicate, FileSpec, Logger, Naming};
#[cfg(feature = "compress")]
use log::*;
#[cfg(feature = "compress")]
const COUNT: u8 = 4;
#[cfg(feature = "compress")]
#[test]
fn test_rotate_immediate_compression() {
if let Some(value) = test_utils::dispatch(COUNT) {
work(value)
}
}
#[cfg(feature = "compress")]
fn work(value: u8) {
match value {
0 => test_variant(
Naming::Timestamps,
Criterion::Age(Age::Second),
Cleanup::KeepCompressedFiles(100),
),
1 => test_variant(
Naming::TimestampsDirect,
Criterion::Age(Age::Second),
Cleanup::KeepCompressedFiles(100),
),
2 => test_variant(
Naming::Numbers,
Criterion::Age(Age::Second),
Cleanup::KeepCompressedFiles(100),
),
3 => test_variant(
Naming::NumbersDirect,
Criterion::Age(Age::Second),
Cleanup::KeepCompressedFiles(100),
),
COUNT..=u8::MAX => unreachable!("asAS"),
}
}
#[cfg(feature = "compress")]
fn test_variant(naming: Naming, criterion: Criterion, cleanup: Cleanup) {
use std::time::{Duration, Instant};
let directory = test_utils::dir();
test_utils::wait_for_start_of_second();
let mut written_lines = 1;
{
let logger = Logger::try_with_str("trace")
.unwrap()
.log_to_file(
FileSpec::default()
.directory(&directory)
.suppress_basename(),
)
.format_for_files(flexi_logger::detailed_format)
.format_for_stderr(flexi_logger::detailed_format)
.duplicate_to_stderr(Duplicate::Info)
.rotate(criterion, naming, cleanup)
.start()
.unwrap_or_else(|e| panic!("Logger initialization failed with {e}"));
info!(
"test correct rotation by {}",
match criterion {
Criterion::Age(_) => "age",
Criterion::AgeOrSize(_, _) => "age or size",
Criterion::Size(_) => "size",
}
);
let start = Instant::now();
let max_runtime = Duration::from_millis(1_200);
let sleep_time = Duration::from_millis(7);
while Instant::now() - start < max_runtime {
written_lines += 1;
if written_lines % 17 == 4 {
logger.trigger_rotation().unwrap();
}
trace!("line_count = {written_lines}");
std::thread::sleep(sleep_time);
}
}
let read_lines = test_utils::count_log_lines(&directory);
assert_eq!(
read_lines, written_lines,
"wrong line count: {read_lines} instead of {written_lines}"
);
}
|
