blob: f4033752845408a0865a8e832e5fc8d778286fb0 (
plain)
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
|
#include "lldb/DataFormatters/TypeSummary.h"
#include "lldb/Target/Statistics.h"
#include "lldb/Utility/Stream.h"
#include "lldb/lldb-forward.h"
#include "lldb/lldb-private-enumerations.h"
#include "lldb/lldb-private.h"
#include "llvm/Testing/Support/Error.h"
#include "gtest/gtest.h"
#include <thread>
using namespace lldb_private;
using Duration = std::chrono::duration<double>;
class DummySummaryImpl : public lldb_private::TypeSummaryImpl {
public:
DummySummaryImpl()
: TypeSummaryImpl(TypeSummaryImpl::Kind::eSummaryString,
TypeSummaryImpl::Flags()) {}
std::string GetName() override { return "DummySummary"; }
std::string GetSummaryKindName() override { return "dummy"; }
std::string GetDescription() override { return ""; }
bool FormatObject(ValueObject *valobj, std::string &dest,
const TypeSummaryOptions &options) override {
return false;
}
};
TEST(MultithreadFormatting, Multithread) {
SummaryStatisticsCache statistics_cache;
DummySummaryImpl summary;
std::vector<std::thread> threads;
for (int i = 0; i < 10; ++i) {
threads.emplace_back(std::thread([&statistics_cache, &summary]() {
auto sp = statistics_cache.GetSummaryStatisticsForProvider(summary);
{
SummaryStatistics::SummaryInvocation invocation(sp);
std::this_thread::sleep_for(Duration(1));
}
}));
}
for (auto &thread : threads)
thread.join();
auto sp = statistics_cache.GetSummaryStatisticsForProvider(summary);
ASSERT_TRUE(sp->GetDurationReference().get().count() > 10);
ASSERT_TRUE(sp->GetSummaryCount() == 10);
std::string stats_as_json;
llvm::raw_string_ostream ss(stats_as_json);
ss << sp->ToJSON();
ASSERT_THAT(stats_as_json, ::testing::HasSubstr("\"name\":\"DummySummary\""));
ASSERT_THAT(stats_as_json, ::testing::HasSubstr("\"type\":\"dummy\""));
}
|
