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
|
#include <syslog.h>
#include "common/Formatter.h"
#include "LogEntry.h"
int clog_type_to_syslog_prio(clog_type t)
{
switch (t) {
case CLOG_DEBUG:
return LOG_DEBUG;
case CLOG_INFO:
return LOG_INFO;
case CLOG_WARN:
return LOG_WARNING;
case CLOG_ERROR:
return LOG_ERR;
case CLOG_SEC:
return LOG_CRIT;
default:
assert(0);
return 0;
}
}
// ----
// LogEntryKey
void LogEntryKey::encode(bufferlist& bl) const
{
::encode(who, bl);
::encode(stamp, bl);
::encode(seq, bl);
}
void LogEntryKey::decode(bufferlist::iterator& bl)
{
::decode(who, bl);
::decode(stamp, bl);
::decode(seq, bl);
}
void LogEntryKey::dump(Formatter *f) const
{
f->dump_stream("who") << who;
f->dump_stream("stamp") << stamp;
f->dump_unsigned("seq", seq);
}
void LogEntryKey::generate_test_instances(list<LogEntryKey*>& o)
{
o.push_back(new LogEntryKey);
o.push_back(new LogEntryKey(entity_inst_t(), utime_t(1,2), 34));
}
// ----
void LogEntry::encode(bufferlist& bl) const
{
ENCODE_START(2, 2, bl);
__u16 t = type;
::encode(who, bl);
::encode(stamp, bl);
::encode(seq, bl);
::encode(t, bl);
::encode(msg, bl);
ENCODE_FINISH(bl);
}
void LogEntry::decode(bufferlist::iterator& bl)
{
DECODE_START_LEGACY_COMPAT_LEN(2, 2, 2, bl);
__u16 t;
::decode(who, bl);
::decode(stamp, bl);
::decode(seq, bl);
::decode(t, bl);
type = (clog_type)t;
::decode(msg, bl);
DECODE_FINISH(bl);
}
void LogEntry::dump(Formatter *f) const
{
f->dump_stream("who") << who;
f->dump_stream("stamp") << stamp;
f->dump_unsigned("seq", seq);
f->dump_stream("type") << type;
f->dump_string("message", msg);
}
void LogEntry::generate_test_instances(list<LogEntry*>& o)
{
o.push_back(new LogEntry);
}
// -----
void LogSummary::encode(bufferlist& bl) const
{
ENCODE_START(2, 2, bl);
::encode(version, bl);
::encode(tail, bl);
ENCODE_FINISH(bl);
}
void LogSummary::decode(bufferlist::iterator& bl)
{
DECODE_START_LEGACY_COMPAT_LEN(2, 2, 2, bl);
::decode(version, bl);
::decode(tail, bl);
DECODE_FINISH(bl);
}
void LogSummary::dump(Formatter *f) const
{
f->dump_unsigned("version", version);
f->open_array_section("tail");
for (list<LogEntry>::const_iterator p = tail.begin(); p != tail.end(); ++p) {
f->open_object_section("entry");
p->dump(f);
f->close_section();
}
f->close_section();
}
void LogSummary::generate_test_instances(list<LogSummary*>& o)
{
o.push_back(new LogSummary);
// more!
}
|
