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
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
|
#pragma once
#include <library/cpp/lwtrace/all.h>
#include <util/generic/vector.h>
#define LWACTORID(x) (x).RawX1(), (x).RawX2(), (x).NodeId(), (x).PoolID()
#define LWTYPE_ACTORID ui64, ui64, ui32, ui32
#define LWNAME_ACTORID(n) n "Raw1", n "Raw2", n "NodeId", n "PoolId"
#define ACTORLIB_PROVIDER(PROBE, EVENT, GROUPS, TYPES, NAMES) \
PROBE(SlowEvent, GROUPS("ActorLibSlow"), \
TYPES(ui32, double, TString, TString, TString), \
NAMES("poolId", "eventMs", "eventType", "actorId", "actorType")) \
PROBE(EventSlowDelivery, GROUPS("ActorLibSlow"), \
TYPES(ui32, double, double, ui64, TString, TString, TString), \
NAMES("poolId", "deliveryMs", "sinceActivationMs", "eventProcessedBefore", "eventType", "actorId", "actorType")) \
PROBE(SlowActivation, GROUPS("ActorLibSlow"), \
TYPES(ui32, double), \
NAMES("poolId", "activationMs")) \
PROBE(SlowRegisterNew, GROUPS("ActorLibSlow"), \
TYPES(ui32, double), \
NAMES("poolId", "registerNewMs")) \
PROBE(SlowRegisterAdd, GROUPS("ActorLibSlow"), \
TYPES(ui32, double), \
NAMES("poolId", "registerAddMs")) \
PROBE(MailboxPushedOutByTailSending, GROUPS("ActorLibMailbox", "ActorLibMailboxPushedOut"), \
TYPES(ui32, TString, ui32, TDuration, ui64, TString, TString), \
NAMES("poolId", "pool", "eventsProcessed", "procTimeMs", "workerId", "actorId", "actorType")) \
PROBE(MailboxPushedOutBySoftPreemption, GROUPS("ActorLibMailbox", "ActorLibMailboxPushedOut"), \
TYPES(ui32, TString, ui32, TDuration, ui64, TString, TString), \
NAMES("poolId", "pool", "eventsProcessed", "procTimeMs", "workerId", "actorId", "actorType")) \
PROBE(MailboxPushedOutByTime, GROUPS("ActorLibMailbox", "ActorLibMailboxPushedOut"), \
TYPES(ui32, TString, ui32, TDuration, ui64, TString, TString), \
NAMES("poolId", "pool", "eventsProcessed", "procTimeMs", "workerId", "actorId", "actorType")) \
PROBE(MailboxPushedOutByEventCount, GROUPS("ActorLibMailbox", "ActorLibMailboxPushedOut"), \
TYPES(ui32, TString, ui32, TDuration, ui64, TString, TString), \
NAMES("poolId", "pool", "eventsProcessed", "procTimeMs", "workerId", "actorId", "actorType")) \
PROBE(MailboxEmpty, GROUPS("ActorLibMailbox"), \
TYPES(ui32, TString, ui32, TDuration, ui64, TString, TString), \
NAMES("poolId", "pool", "eventsProcessed", "procTimeMs", "workerId", "actorId", "actorType")) \
PROBE(ActivationBegin, GROUPS(), \
TYPES(ui32, ui32, ui32, double), \
NAMES("cpu", "poolId", "workerId", "expireMs")) \
PROBE(ActivationEnd, GROUPS(), \
TYPES(ui32, ui32, ui32), \
NAMES("cpu", "poolId", "workerId")) \
PROBE(ExecutorThreadStats, GROUPS("ActorLibStats"), \
TYPES(ui32, TString, ui64, ui64, ui64, double, double), \
NAMES("poolId", "pool", "workerId", "execCount", "readyActivationCount", "execMs", "nonExecMs")) \
PROBE(SlowICReadLoopAdjustSize, GROUPS("ActorLibSlowIC"), \
TYPES(double), \
NAMES("icReadLoopAdjustSizeMs")) \
PROBE(SlowICReadFromSocket, GROUPS("ActorLibSlowIC"), \
TYPES(double), \
NAMES("icReadFromSocketMs")) \
PROBE(SlowICReadLoopSend, GROUPS("ActorLibSlowIC"), \
TYPES(double), \
NAMES("icReadLoopSendMs")) \
PROBE(SlowICAllocPacketBuffer, GROUPS("ActorLibSlowIC"), \
TYPES(ui32, double), \
NAMES("peerId", "icAllocPacketBufferMs")) \
PROBE(SlowICFillSendingBuffer, GROUPS("ActorLibSlowIC"), \
TYPES(ui32, double), \
NAMES("peerId", "icFillSendingBufferMs")) \
PROBE(SlowICPushSentPackets, GROUPS("ActorLibSlowIC"), \
TYPES(ui32, double), \
NAMES("peerId", "icPushSentPacketsMs")) \
PROBE(SlowICPushSendQueue, GROUPS("ActorLibSlowIC"), \
TYPES(ui32, double), \
NAMES("peerId", "icPushSendQueueMs")) \
PROBE(SlowICWriteData, GROUPS("ActorLibSlowIC"), \
TYPES(ui32, double), \
NAMES("peerId", "icWriteDataMs")) \
PROBE(SlowICDropConfirmed, GROUPS("ActorLibSlowIC"), \
TYPES(ui32, double), \
NAMES("peerId", "icDropConfirmedMs")) \
PROBE(ActorsystemScheduler, GROUPS("Durations"), \
TYPES(ui64, ui64, ui32, ui32, ui64, ui64), \
NAMES("timeUs", "timerfd_expirations", "eventsGottenFromQueues", "eventsSent", \
"eventsInSendQueue", "eventSchedulingErrorUs")) \
PROBE(ForwardEvent, GROUPS("Orbit", "InterconnectSessionTCP"), \
TYPES(ui32, ui32, ui32, LWTYPE_ACTORID, LWTYPE_ACTORID, ui64, ui32), \
NAMES("peerId", "type", "flags", LWNAME_ACTORID("r"), LWNAME_ACTORID("s"), \
"cookie", "eventSerializedSize")) \
PROBE(EnqueueEvent, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, ui64, TDuration, ui16, ui64, ui64), \
NAMES("peerId", "numEventsInReadyChannels", "enqueueBlockedTotalMs", "channelId", "queueSizeInEvents", "queueSizeInBytes")) \
PROBE(SerializeToPacketBegin, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, ui16, ui64), \
NAMES("peerId", "channelId", "outputQueueSize")) \
PROBE(SerializeToPacketEnd, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, ui16, ui64, ui64), \
NAMES("peerId", "channelId", "outputQueueSize", "offsetInPacket")) \
PROBE(FillSendingBuffer, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, ui32, ui64, TDuration), \
NAMES("peerId", "taskBytesGenerated", "numEventsInReadyChannelsBehind", "fillBlockedTotalMs")) \
PROBE(PacketGenerated, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, ui64, ui64, ui64, ui64), \
NAMES("peerId", "bytesUnwritten", "inflightBytes", "packetsGenerated", "packetSize")) \
PROBE(PacketWrittenToSocket, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, ui64, bool, ui64, ui64, TDuration, int), \
NAMES("peerId", "packetsWrittenToSocket", "triedWriting", "packetDataSize", "bytesUnwritten", "writeBlockedTotalMs", "fd")) \
PROBE(GenerateTraffic, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double, ui64, ui32, ui64), \
NAMES("peerId", "generateTrafficMs", "dataBytesSent", "generatedPackets", "generatedBytes")) \
PROBE(WriteToSocket, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, ui64, ui64, ui64, ui64, TDuration, int), \
NAMES("peerId", "bytesWritten", "packetsWritten", "packetsWrittenToSocket", "bytesUnwritten", "writeBlockedTotalMs", "fd")) \
PROBE(UpdateFromInputSession, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double), \
NAMES("peerId", "pingMs")) \
PROBE(UnblockByDropConfirmed, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double), \
NAMES("peerId", "updateDeliveryMs")) \
PROBE(DropConfirmed, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, ui64, ui64), \
NAMES("peerId", "droppedBytes", "inflightBytes")) \
PROBE(StartRam, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32), \
NAMES("peerId")) \
PROBE(FinishRam, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double), \
NAMES("peerId", "ramMs")) \
PROBE(SkipGenerateTraffic, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double), \
NAMES("peerId", "elapsedSinceRamMs")) \
PROBE(StartBatching, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double), \
NAMES("peerId", "batchPeriodMs")) \
PROBE(FinishBatching, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double), \
NAMES("peerId", "finishBatchDeliveryMs")) \
PROBE(BlockedWrite, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double, ui64), \
NAMES("peerId", "sendQueueSize", "writtenBytes")) \
PROBE(ReadyWrite, GROUPS("InterconnectSessionTCP"), \
TYPES(ui32, double, double), \
NAMES("peerId", "readyWriteDeliveryMs", "blockMs")) \
PROBE(EpollStartWaitIn, GROUPS("EpollThread"), \
TYPES(), \
NAMES()) \
PROBE(EpollFinishWaitIn, GROUPS("EpollThread"), \
TYPES(i32), \
NAMES("eventsCount")) \
PROBE(EpollWaitOut, GROUPS("EpollThread"), \
TYPES(i32), \
NAMES("eventsCount")) \
PROBE(EpollSendReadyRead, GROUPS("EpollThread"), \
TYPES(bool, bool, int), \
NAMES("hangup", "event", "fd")) \
PROBE(EpollSendReadyWrite, GROUPS("EpollThread"), \
TYPES(bool, bool, int), \
NAMES("hangup", "event", "fd")) \
PROBE(HardPreemption, GROUPS("UnitedWorker"), \
TYPES(ui32, ui32, ui32, ui32), \
NAMES("cpu", "prevPoolId", "prevWorkerId", "nextWorkerId")) \
PROBE(SetPreemptionTimer, GROUPS("UnitedWorker", "PreemptionTimer"), \
TYPES(ui32, ui32, int, double, double), \
NAMES("cpu", "workerId", "fd", "nowMs", "preemptMs")) \
PROBE(ResetPreemptionTimer, GROUPS("UnitedWorker", "PreemptionTimer"), \
TYPES(ui32, ui32, int, double, double), \
NAMES("cpu", "workerId", "fd", "nowMs", "preemptMs")) \
PROBE(SlowWorkerActionRace, GROUPS("UnitedWorker"), \
TYPES(ui32, ui32, ui64), \
NAMES("cpu", "poolId", "slowPoolsMask")) \
PROBE(PoolStats, GROUPS("PoolCpuBalancer"), \
TYPES(ui32, TString, ui64, ui8, ui8, double, double, double, ui64, ui64, ui64), \
NAMES("poolId", "pool", "currentCpus", "loadClass", "priority", "scaleFactor", "cpuIdle", "cpuLoad", "importance", "addImportance", "subImportance")) \
PROBE(MoveCpu, GROUPS("PoolCpuBalancer"), \
TYPES(ui32, ui64, TString, TString, ui32), \
NAMES("fromPoolId", "toPoolId", "fromPool", "toPool", "cpu")) \
PROBE(ThreadCount, GROUPS("BasicThreadPool"), \
TYPES(ui32, TString, ui32, ui32, ui32, ui32), \
NAMES("poolId", "pool", "threacCount", "minThreadCount", "maxThreadCount", "defaultThreadCount")) \
PROBE(HarmonizeCheckPool, GROUPS("Harmonizer"), \
TYPES(ui32, TString, double, double, double, double, ui32, ui32, bool, bool, bool), \
NAMES("poolId", "pool", "booked", "consumed", "lastSecondBooked", "lastSecondConsumed", "threadCount", "maxThreadCount", "isStarved", "isNeedy", "isHoggish")) \
PROBE(HarmonizeOperation, GROUPS("Harmonizer"), \
TYPES(ui32, TString, TString, ui32, ui32, ui32), \
NAMES("poolId", "pool", "operation", "newCount", "minCount", "maxCount")) \
PROBE(TryToHarmonize, GROUPS("Harmonizer"), \
TYPES(ui32, TString), \
NAMES("poolId", "pool")) \
PROBE(SavedValues, GROUPS("Harmonizer"), \
TYPES(ui32, TString, TString, double, double, double, double, double, double, double, double), \
NAMES("poolId", "pool", "valueName", "[0]", "[1]", "[2]", "[3]", "[4]", "[5]", "[6]", "[7]")) \
PROBE(RegisterValue, GROUPS("Harmonizer"), \
TYPES(ui64, ui64, ui64, ui64, double, double, double), \
NAMES("ts", "lastTs", "dTs", "8sTs", "us", "lastUs", "dUs")) \
PROBE(TryToHarmonizeFailed, GROUPS("Harmonizer"), \
TYPES(ui64, ui64, bool, bool), \
NAMES("ts", "nextHarmonizeTs", "isDisabled", "withLock")) \
PROBE(TryToHarmonizeSuccess, GROUPS("Harmonizer"), \
TYPES(ui64, ui64, ui64), \
NAMES("ts", "nextHarmonizeTs", "previousNextHarmonizeTs")) \
/**/
LWTRACE_DECLARE_PROVIDER(ACTORLIB_PROVIDER)
namespace NActors {
struct TActorSystemSetup;
TVector<NLWTrace::TDashboard> LWTraceDashboards(TActorSystemSetup* setup);
}
|