GCC Code Coverage Report
Directory: ./ Exec Total Coverage
File: node_perf.cc Lines: 159 177 89.8 %
Date: 2022-07-24 04:16:20 Branches: 34 52 65.4 %

Line Branch Exec Source
1
#include "node_perf.h"
2
#include "aliased_buffer.h"
3
#include "env-inl.h"
4
#include "histogram-inl.h"
5
#include "memory_tracker-inl.h"
6
#include "node_buffer.h"
7
#include "node_external_reference.h"
8
#include "node_internals.h"
9
#include "node_process-inl.h"
10
#include "util-inl.h"
11
12
#include <cinttypes>
13
14
namespace node {
15
namespace performance {
16
17
using v8::Context;
18
using v8::DontDelete;
19
using v8::Function;
20
using v8::FunctionCallbackInfo;
21
using v8::FunctionTemplate;
22
using v8::GCCallbackFlags;
23
using v8::GCType;
24
using v8::Int32;
25
using v8::Integer;
26
using v8::Isolate;
27
using v8::Local;
28
using v8::MaybeLocal;
29
using v8::Number;
30
using v8::Object;
31
using v8::PropertyAttribute;
32
using v8::ReadOnly;
33
using v8::String;
34
using v8::Value;
35
36
// Microseconds in a millisecond, as a float.
37
#define MICROS_PER_MILLIS 1e3
38
// Nanoseconds in a millisecond, as a float.
39
#define NANOS_PER_MILLIS 1e6
40
41
uint64_t performance_v8_start;
42
43
6571
PerformanceState::PerformanceState(Isolate* isolate,
44
6571
                                   const PerformanceState::SerializeInfo* info)
45
    : root(isolate,
46
           sizeof(performance_state_internal),
47
           MAYBE_FIELD_PTR(info, root)),
48
      milestones(isolate,
49
                 offsetof(performance_state_internal, milestones),
50
                 NODE_PERFORMANCE_MILESTONE_INVALID,
51
6571
                 root,
52
                 MAYBE_FIELD_PTR(info, milestones)),
53
      observers(isolate,
54
                offsetof(performance_state_internal, observers),
55
                NODE_PERFORMANCE_ENTRY_TYPE_INVALID,
56
6571
                root,
57

6571
                MAYBE_FIELD_PTR(info, observers)) {
58
6571
  if (info == nullptr) {
59
9149
    for (size_t i = 0; i < milestones.Length(); i++) milestones[i] = -1.;
60
  }
61
6571
}
62
63
6
PerformanceState::SerializeInfo PerformanceState::Serialize(
64
    v8::Local<v8::Context> context, v8::SnapshotCreator* creator) {
65
6
  SerializeInfo info{root.Serialize(context, creator),
66
6
                     milestones.Serialize(context, creator),
67
6
                     observers.Serialize(context, creator)};
68
6
  return info;
69
}
70
71
5264
void PerformanceState::Deserialize(v8::Local<v8::Context> context) {
72
5264
  root.Deserialize(context);
73
  // This is just done to set up the pointers, we will actually reset
74
  // all the milestones after deserialization.
75
5264
  milestones.Deserialize(context);
76
5264
  observers.Deserialize(context);
77
5264
}
78
79
6
std::ostream& operator<<(std::ostream& o,
80
                         const PerformanceState::SerializeInfo& i) {
81
  o << "{\n"
82
6
    << "  " << i.root << ",  // root\n"
83
6
    << "  " << i.milestones << ",  // milestones\n"
84
6
    << "  " << i.observers << ",  // observers\n"
85
6
    << "}";
86
6
  return o;
87
}
88
89
38434
void PerformanceState::Mark(PerformanceMilestone milestone, uint64_t ts) {
90
38434
  this->milestones[milestone] = static_cast<double>(ts);
91

43714
  TRACE_EVENT_INSTANT_WITH_TIMESTAMP0(
92
      TRACING_CATEGORY_NODE1(bootstrap),
93
      GetPerformanceMilestoneName(milestone),
94
      TRACE_EVENT_SCOPE_THREAD, ts / 1000);
95
38434
}
96
97
// Allows specific Node.js lifecycle milestones to be set from JavaScript
98
void MarkMilestone(const FunctionCallbackInfo<Value>& args) {
99
  Environment* env = Environment::GetCurrent(args);
100
  PerformanceMilestone milestone =
101
      static_cast<PerformanceMilestone>(args[0].As<Int32>()->Value());
102
  if (milestone != NODE_PERFORMANCE_MILESTONE_INVALID)
103
    env->performance_state()->Mark(milestone);
104
}
105
106
1307
void SetupPerformanceObservers(const FunctionCallbackInfo<Value>& args) {
107
1307
  Environment* env = Environment::GetCurrent(args);
108
1307
  CHECK(args[0]->IsFunction());
109
2614
  env->set_performance_entry_callback(args[0].As<Function>());
110
1307
}
111
112
// Marks the start of a GC cycle
113
1
void MarkGarbageCollectionStart(
114
    Isolate* isolate,
115
    GCType type,
116
    GCCallbackFlags flags,
117
    void* data) {
118
1
  Environment* env = static_cast<Environment*>(data);
119
1
  env->performance_state()->performance_last_gc_start_mark = PERFORMANCE_NOW();
120
1
}
121
122
1
MaybeLocal<Object> GCPerformanceEntryTraits::GetDetails(
123
    Environment* env,
124
    const GCPerformanceEntry& entry) {
125
1
  Local<Object> obj = Object::New(env->isolate());
126
127
2
  if (!obj->Set(
128
          env->context(),
129
          env->kind_string(),
130
          Integer::NewFromUnsigned(
131
              env->isolate(),
132
4
              entry.details.kind)).IsJust()) {
133
    return MaybeLocal<Object>();
134
  }
135
136
2
  if (!obj->Set(
137
          env->context(),
138
          env->flags_string(),
139
          Integer::NewFromUnsigned(
140
              env->isolate(),
141
4
              entry.details.flags)).IsJust()) {
142
    return MaybeLocal<Object>();
143
  }
144
145
1
  return obj;
146
}
147
148
// Marks the end of a GC cycle
149
1
void MarkGarbageCollectionEnd(
150
    Isolate* isolate,
151
    GCType type,
152
    GCCallbackFlags flags,
153
    void* data) {
154
1
  Environment* env = static_cast<Environment*>(data);
155
1
  PerformanceState* state = env->performance_state();
156
  // If no one is listening to gc performance entries, do not create them.
157
1
  if (LIKELY(!state->observers[NODE_PERFORMANCE_ENTRY_TYPE_GC]))
158
    return;
159
160
  double start_time =
161
1
      (state->performance_last_gc_start_mark - env->time_origin()) /
162
1
      NANOS_PER_MILLIS;
163
1
  double duration = (PERFORMANCE_NOW() / NANOS_PER_MILLIS) -
164
2
                    (state->performance_last_gc_start_mark / NANOS_PER_MILLIS);
165
166
  std::unique_ptr<GCPerformanceEntry> entry =
167
      std::make_unique<GCPerformanceEntry>(
168
          "gc",
169
          start_time,
170
          duration,
171
1
          GCPerformanceEntry::Details(static_cast<PerformanceGCKind>(type),
172
1
                                      static_cast<PerformanceGCFlags>(flags)));
173
174
1
  env->SetImmediate([entry = std::move(entry)](Environment* env) {
175
1
    entry->Notify(env);
176
1
  }, CallbackFlags::kUnrefed);
177
}
178
179
4
void GarbageCollectionCleanupHook(void* data) {
180
4
  Environment* env = static_cast<Environment*>(data);
181
4
  env->isolate()->RemoveGCPrologueCallback(MarkGarbageCollectionStart, data);
182
4
  env->isolate()->RemoveGCEpilogueCallback(MarkGarbageCollectionEnd, data);
183
4
}
184
185
4
static void InstallGarbageCollectionTracking(
186
    const FunctionCallbackInfo<Value>& args) {
187
4
  Environment* env = Environment::GetCurrent(args);
188
189
4
  env->isolate()->AddGCPrologueCallback(MarkGarbageCollectionStart,
190
                                        static_cast<void*>(env));
191
4
  env->isolate()->AddGCEpilogueCallback(MarkGarbageCollectionEnd,
192
                                        static_cast<void*>(env));
193
4
  env->AddCleanupHook(GarbageCollectionCleanupHook, env);
194
4
}
195
196
3
static void RemoveGarbageCollectionTracking(
197
  const FunctionCallbackInfo<Value> &args) {
198
3
  Environment* env = Environment::GetCurrent(args);
199
200
3
  env->RemoveCleanupHook(GarbageCollectionCleanupHook, env);
201
3
  GarbageCollectionCleanupHook(env);
202
3
}
203
204
// Gets the name of a function
205
inline Local<Value> GetName(Local<Function> fn) {
206
  Local<Value> val = fn->GetDebugName();
207
  if (val.IsEmpty() || val->IsUndefined()) {
208
    Local<Value> boundFunction = fn->GetBoundFunction();
209
    if (!boundFunction.IsEmpty() && !boundFunction->IsUndefined()) {
210
      val = GetName(boundFunction.As<Function>());
211
    }
212
  }
213
  return val;
214
}
215
216
// Notify a custom PerformanceEntry to observers
217
void Notify(const FunctionCallbackInfo<Value>& args) {
218
  Environment* env = Environment::GetCurrent(args);
219
  Utf8Value type(env->isolate(), args[0]);
220
  Local<Value> entry = args[1];
221
  PerformanceEntryType entry_type = ToPerformanceEntryTypeEnum(*type);
222
  AliasedUint32Array& observers = env->performance_state()->observers;
223
  if (entry_type != NODE_PERFORMANCE_ENTRY_TYPE_INVALID &&
224
      observers[entry_type]) {
225
    USE(env->performance_entry_callback()->
226
      Call(env->context(), Undefined(env->isolate()), 1, &entry));
227
  }
228
}
229
230
// Return idle time of the event loop
231
60
void LoopIdleTime(const FunctionCallbackInfo<Value>& args) {
232
60
  Environment* env = Environment::GetCurrent(args);
233
60
  uint64_t idle_time = uv_metrics_idle_time(env->event_loop());
234
60
  args.GetReturnValue().Set(1.0 * idle_time / 1e6);
235
60
}
236
237
3
void CreateELDHistogram(const FunctionCallbackInfo<Value>& args) {
238
3
  Environment* env = Environment::GetCurrent(args);
239
6
  int64_t interval = args[0].As<Integer>()->Value();
240
3
  CHECK_GT(interval, 0);
241
  BaseObjectPtr<IntervalHistogram> histogram =
242
1767
      IntervalHistogram::Create(env, interval, [](Histogram& histogram) {
243
1767
        uint64_t delta = histogram.RecordDelta();
244

1769
        TRACE_COUNTER1(TRACING_CATEGORY_NODE2(perf, event_loop),
245
                        "delay", delta);
246

1769
        TRACE_COUNTER1(TRACING_CATEGORY_NODE2(perf, event_loop),
247
                      "min", histogram.Min());
248

1769
        TRACE_COUNTER1(TRACING_CATEGORY_NODE2(perf, event_loop),
249
                      "max", histogram.Max());
250

1769
        TRACE_COUNTER1(TRACING_CATEGORY_NODE2(perf, event_loop),
251
                      "mean", histogram.Mean());
252

1769
        TRACE_COUNTER1(TRACING_CATEGORY_NODE2(perf, event_loop),
253
                      "stddev", histogram.Stddev());
254
6
      }, Histogram::Options { 1000 });
255
6
  args.GetReturnValue().Set(histogram->object());
256
3
}
257
258
7844
void GetTimeOrigin(const FunctionCallbackInfo<Value>& args) {
259
7844
  Environment* env = Environment::GetCurrent(args);
260
7844
  args.GetReturnValue().Set(
261
7844
      Number::New(args.GetIsolate(), env->time_origin() / 1e6));
262
7844
}
263
264
7844
void GetTimeOriginTimeStamp(const FunctionCallbackInfo<Value>& args) {
265
7844
  Environment* env = Environment::GetCurrent(args);
266
7844
  args.GetReturnValue().Set(Number::New(
267
7844
      args.GetIsolate(), env->time_origin_timestamp() / MICROS_PER_MILLIS));
268
7844
}
269
270
1307
void Initialize(Local<Object> target,
271
                Local<Value> unused,
272
                Local<Context> context,
273
                void* priv) {
274
1307
  Environment* env = Environment::GetCurrent(context);
275
1307
  Isolate* isolate = env->isolate();
276
1307
  PerformanceState* state = env->performance_state();
277
278
1307
  target->Set(context,
279
              FIXED_ONE_BYTE_STRING(isolate, "observerCounts"),
280
5228
              state->observers.GetJSArray()).Check();
281
1307
  target->Set(context,
282
              FIXED_ONE_BYTE_STRING(isolate, "milestones"),
283
3921
              state->milestones.GetJSArray()).Check();
284
285
  Local<String> performanceEntryString =
286
1307
      FIXED_ONE_BYTE_STRING(isolate, "PerformanceEntry");
287
288
1307
  Local<FunctionTemplate> pe = FunctionTemplate::New(isolate);
289
1307
  pe->SetClassName(performanceEntryString);
290
2614
  Local<Function> fn = pe->GetFunction(context).ToLocalChecked();
291
1307
  target->Set(context, performanceEntryString, fn).Check();
292
1307
  env->set_performance_entry_template(fn);
293
294
1307
  env->SetMethod(target, "markMilestone", MarkMilestone);
295
1307
  env->SetMethod(target, "setupObservers", SetupPerformanceObservers);
296
1307
  env->SetMethod(target,
297
                 "installGarbageCollectionTracking",
298
                 InstallGarbageCollectionTracking);
299
1307
  env->SetMethod(target,
300
                 "removeGarbageCollectionTracking",
301
                 RemoveGarbageCollectionTracking);
302
1307
  env->SetMethod(target, "notify", Notify);
303
1307
  env->SetMethod(target, "loopIdleTime", LoopIdleTime);
304
1307
  env->SetMethod(target, "getTimeOrigin", GetTimeOrigin);
305
1307
  env->SetMethod(target, "getTimeOriginTimestamp", GetTimeOriginTimeStamp);
306
1307
  env->SetMethod(target, "createELDHistogram", CreateELDHistogram);
307
308
1307
  Local<Object> constants = Object::New(isolate);
309
310
3921
  NODE_DEFINE_CONSTANT(constants, NODE_PERFORMANCE_GC_MAJOR);
311
3921
  NODE_DEFINE_CONSTANT(constants, NODE_PERFORMANCE_GC_MINOR);
312
3921
  NODE_DEFINE_CONSTANT(constants, NODE_PERFORMANCE_GC_INCREMENTAL);
313
3921
  NODE_DEFINE_CONSTANT(constants, NODE_PERFORMANCE_GC_WEAKCB);
314
315
3921
  NODE_DEFINE_CONSTANT(
316
    constants, NODE_PERFORMANCE_GC_FLAGS_NO);
317
3921
  NODE_DEFINE_CONSTANT(
318
    constants, NODE_PERFORMANCE_GC_FLAGS_CONSTRUCT_RETAINED);
319
3921
  NODE_DEFINE_CONSTANT(
320
    constants, NODE_PERFORMANCE_GC_FLAGS_FORCED);
321
3921
  NODE_DEFINE_CONSTANT(
322
    constants, NODE_PERFORMANCE_GC_FLAGS_SYNCHRONOUS_PHANTOM_PROCESSING);
323
3921
  NODE_DEFINE_CONSTANT(
324
    constants, NODE_PERFORMANCE_GC_FLAGS_ALL_AVAILABLE_GARBAGE);
325
3921
  NODE_DEFINE_CONSTANT(
326
    constants, NODE_PERFORMANCE_GC_FLAGS_ALL_EXTERNAL_MEMORY);
327
3921
  NODE_DEFINE_CONSTANT(
328
    constants, NODE_PERFORMANCE_GC_FLAGS_SCHEDULE_IDLE);
329
330
#define V(name, _)                                                            \
331
  NODE_DEFINE_HIDDEN_CONSTANT(constants, NODE_PERFORMANCE_ENTRY_TYPE_##name);
332
14377
  NODE_PERFORMANCE_ENTRY_TYPES(V)
333
#undef V
334
335
#define V(name, _)                                                            \
336
  NODE_DEFINE_HIDDEN_CONSTANT(constants, NODE_PERFORMANCE_MILESTONE_##name);
337
15684
  NODE_PERFORMANCE_MILESTONES(V)
338
#undef V
339
340
1307
  PropertyAttribute attr =
341
      static_cast<PropertyAttribute>(ReadOnly | DontDelete);
342
343
1307
  target->DefineOwnProperty(context,
344
                            env->constants_string(),
345
                            constants,
346
2614
                            attr).ToChecked();
347
348
1307
  HistogramBase::Initialize(env, target);
349
1307
}
350
351
5270
void RegisterExternalReferences(ExternalReferenceRegistry* registry) {
352
5270
  registry->Register(MarkMilestone);
353
5270
  registry->Register(SetupPerformanceObservers);
354
5270
  registry->Register(InstallGarbageCollectionTracking);
355
5270
  registry->Register(RemoveGarbageCollectionTracking);
356
5270
  registry->Register(Notify);
357
5270
  registry->Register(LoopIdleTime);
358
5270
  registry->Register(GetTimeOrigin);
359
5270
  registry->Register(GetTimeOriginTimeStamp);
360
5270
  registry->Register(CreateELDHistogram);
361
5270
  HistogramBase::RegisterExternalReferences(registry);
362
5270
  IntervalHistogram::RegisterExternalReferences(registry);
363
5270
}
364
}  // namespace performance
365
}  // namespace node
366
367
5338
NODE_MODULE_CONTEXT_AWARE_INTERNAL(performance, node::performance::Initialize)
368
5270
NODE_MODULE_EXTERNAL_REFERENCE(performance,
369
                               node::performance::RegisterExternalReferences)