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
|
#include <mbgl/test/fixture_log_observer.hpp>
#include <mbgl/test/util.hpp>
#include <mbgl/util/enum.hpp>
namespace mbgl {
FixtureLog::Message::Message(EventSeverity severity_,
Event event_,
int64_t code_,
std::string msg_)
: severity(severity_), event(event_), code(code_), msg(std::move(msg_)) {
}
bool FixtureLog::Message::matches(const Message& rhs, bool substring) const {
return severity == rhs.severity && event == rhs.event && code == rhs.code &&
(substring ? msg.find(rhs.msg) != std::string::npos : msg == rhs.msg);
}
FixtureLog::Observer::Observer(FixtureLog* log_) : log(log_) {
}
FixtureLog::Observer::~Observer() {
if (log) {
log->observer = nullptr;
}
std::cerr << unchecked();
}
bool FixtureLog::Observer::onRecord(EventSeverity severity,
Event event,
int64_t code,
const std::string& msg) {
std::lock_guard<std::mutex> lock(messagesMutex);
messages.emplace_back(severity, event, code, msg);
return true;
}
bool FixtureLog::Observer::empty() const {
std::lock_guard<std::mutex> lock(messagesMutex);
return messages.empty();
}
size_t FixtureLog::Observer::count(const Message& message, bool substring) const {
std::lock_guard<std::mutex> lock(messagesMutex);
size_t message_count = 0;
for (const auto& msg : messages) {
if (msg.matches(message, substring)) {
message_count++;
msg.checked = true;
}
}
return message_count;
}
FixtureLog::FixtureLog() : observer(new FixtureLogObserver(this)) {
Log::setObserver(std::unique_ptr<Log::Observer>(observer));
}
bool FixtureLog::empty() const {
return observer ? observer->empty() : true;
}
size_t FixtureLog::count(const FixtureLog::Message& message, bool substring) const {
return observer ? observer->count(message, substring) : 0;
}
size_t FixtureLog::uncheckedCount() const {
return observer ? observer->uncheckedCount() : 0;
}
FixtureLog::~FixtureLog() {
if (observer) {
Log::removeObserver();
}
}
std::vector<FixtureLog::Message> FixtureLogObserver::unchecked() const {
std::lock_guard<std::mutex> lock(messagesMutex);
std::vector<Message> unchecked_messages;
for (const auto& msg : messages) {
if (!msg.checked) {
unchecked_messages.push_back(msg);
msg.checked = true;
}
}
return unchecked_messages;
}
size_t FixtureLogObserver::uncheckedCount() const {
std::lock_guard<std::mutex> lock(messagesMutex);
size_t result = 0;
for (const auto& msg : messages) {
if (!msg.checked) {
result++;
}
}
return result;
}
::std::ostream& operator<<(::std::ostream& os, const std::vector<FixtureLog::Message>& messages) {
for (const auto& message : messages) {
os << "- " << message;
}
return os;
}
::std::ostream& operator<<(::std::ostream& os, const FixtureLog::Message& message) {
os << R"([")" << Enum<EventSeverity>::toString(message.severity) << R"(", ")";
os << Enum<Event>::toString(message.event) << R"(")";
os << ", " << message.code;
os << R"(, ")" << message.msg << R"(")";
return os << "]" << std::endl;
}
} // namespace mbgl
|
