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
|
#include "selfping_actor.h"
#include <library/cpp/actors/core/actor_bootstrapped.h>
#include <library/cpp/actors/core/hfunc.h>
#include <library/cpp/containers/stack_vector/stack_vec.h>
#include <library/cpp/sliding_window/sliding_window.h>
namespace NActors {
namespace {
struct TEvPing: public TEventLocal<TEvPing, TEvents::THelloWorld::Ping> {
TEvPing(double timeStart)
: TimeStart(timeStart)
{}
const double TimeStart;
};
template <class TValueType_>
struct TAvgOperation {
struct TValueType {
ui64 Count = 0;
TValueType_ Sum = TValueType_();
};
using TValueVector = TVector<TValueType>;
static constexpr TValueType InitialValue() {
return TValueType(); // zero
}
// Updates value in current bucket and returns window value
static TValueType UpdateBucket(TValueType windowValue, TValueVector& buckets, size_t index, TValueType newVal) {
Y_ASSERT(index < buckets.size());
buckets[index].Sum += newVal.Sum;
buckets[index].Count += newVal.Count;
windowValue.Sum += newVal.Sum;
windowValue.Count += newVal.Count;
return windowValue;
}
static TValueType ClearBuckets(TValueType windowValue, TValueVector& buckets, size_t firstElemIndex, size_t bucketsToClear) {
Y_ASSERT(!buckets.empty());
Y_ASSERT(firstElemIndex < buckets.size());
Y_ASSERT(bucketsToClear <= buckets.size());
const size_t arraySize = buckets.size();
for (size_t i = 0; i < bucketsToClear; ++i) {
TValueType& curVal = buckets[firstElemIndex];
windowValue.Sum -= curVal.Sum;
windowValue.Count -= curVal.Count;
curVal = InitialValue();
firstElemIndex = (firstElemIndex + 1) % arraySize;
}
return windowValue;
}
};
class TSelfPingActor : public TActorBootstrapped<TSelfPingActor> {
private:
const TDuration SendInterval;
const NMonitoring::TDynamicCounters::TCounterPtr Counter;
const NMonitoring::TDynamicCounters::TCounterPtr CalculationTimeCounter;
NSlidingWindow::TSlidingWindow<NSlidingWindow::TMaxOperation<ui64>> SlidingWindow;
NSlidingWindow::TSlidingWindow<TAvgOperation<ui64>> CalculationSlidingWindow;
THPTimer Timer;
public:
static constexpr auto ActorActivityType() {
return SELF_PING_ACTOR;
}
TSelfPingActor(TDuration sendInterval, const NMonitoring::TDynamicCounters::TCounterPtr& counter,
const NMonitoring::TDynamicCounters::TCounterPtr& calculationTimeCounter)
: SendInterval(sendInterval)
, Counter(counter)
, CalculationTimeCounter(calculationTimeCounter)
, SlidingWindow(TDuration::Seconds(15), 100)
, CalculationSlidingWindow(TDuration::Seconds(15), 100)
{
}
void Bootstrap(const TActorContext& ctx)
{
Become(&TSelfPingActor::RunningState);
SchedulePing(ctx, Timer.Passed());
}
STFUNC(RunningState)
{
switch (ev->GetTypeRewrite()) {
HFunc(TEvPing, HandlePing);
default:
Y_FAIL("TSelfPingActor::RunningState: unexpected event 0x%08" PRIx32, ev->GetTypeRewrite());
}
}
ui64 MeasureTaskDurationNs() {
// Prepare worm test data
// 11 * 11 * 3 * 8 = 2904 bytes, fits in L1 cache
constexpr ui64 Size = 11;
// Align the data to reduce random alignment effects
alignas(64) TStackVec<ui64, Size * Size * 3> data;
ui64 s = 0;
NHPTimer::STime beginTime;
NHPTimer::STime endTime;
// Prepare the data
data.resize(Size * Size * 3);
for (ui64 matrixIdx = 0; matrixIdx < 3; ++matrixIdx) {
for (ui64 y = 0; y < Size; ++y) {
for (ui64 x = 0; x < Size; ++x) {
data[matrixIdx * (Size * Size) + y * Size + x] = y * Size + x;
}
}
}
// Warm-up the cache
NHPTimer::GetTime(&beginTime);
for (ui64 idx = 0; idx < data.size(); ++idx) {
s += data[idx];
}
NHPTimer::GetTime(&endTime);
s += (ui64)(1000000.0 * NHPTimer::GetSeconds(endTime - beginTime));
// Measure the CPU performance
// C = A * B with injected dependency to s
NHPTimer::GetTime(&beginTime);
for (ui64 y = 0; y < Size; ++y) {
for (ui64 x = 0; x < Size; ++x) {
for (ui64 i = 0; i < Size; ++i) {
s += data[y * Size + i] * data[Size * Size + i * Size + x];
}
data[2 * Size * Size + y * Size + x] = s;
s = 0;
}
}
for (ui64 idx = 0; idx < data.size(); ++idx) {
s += data[idx];
}
NHPTimer::GetTime(&endTime);
// Prepare the result
double d = 1000000000.0 * (NHPTimer::GetSeconds(endTime - beginTime) + 0.000000001 * (s & 1));
return (ui64)d;
}
void HandlePing(TEvPing::TPtr &ev, const TActorContext &ctx)
{
const auto now = ctx.Now();
const double hpNow = Timer.Passed();
const auto& e = *ev->Get();
const double passedTime = hpNow - e.TimeStart;
const ui64 delayUs = passedTime > 0.0 ? static_cast<ui64>(passedTime * 1e6) : 0;
*Counter = SlidingWindow.Update(delayUs, now);
ui64 d = MeasureTaskDurationNs();
auto res = CalculationSlidingWindow.Update({1, d}, now);
*CalculationTimeCounter = double(res.Sum) / double(res.Count + 1);
SchedulePing(ctx, hpNow);
}
private:
void SchedulePing(const TActorContext &ctx, double hpNow) const
{
ctx.Schedule(SendInterval, new TEvPing(hpNow));
}
};
} // namespace
IActor* CreateSelfPingActor(
TDuration sendInterval,
const NMonitoring::TDynamicCounters::TCounterPtr& counter,
const NMonitoring::TDynamicCounters::TCounterPtr& calculationTimeCounter)
{
return new TSelfPingActor(sendInterval, counter, calculationTimeCounter);
}
} // NActors
|
