Associate label sets with wall profiles

binding.gyp

@@ -22,9 +22,11 @@
                             "bindings/location.cc",
                             "bindings/per-isolate-data.cc",
                             "bindings/sample.cc",
+                            "bindings/translate-time-profile.cc",
                             "bindings/binding.cc"
                         ],
                         "include_dirs": [
+                            "bindings",
                             "<!(node -e \"require('nan')\")"
                         ]
                     }
@@ -47,6 +49,7 @@
                             "bindings/location.cc",
                             "bindings/per-isolate-data.cc",
                             "bindings/sample.cc",
+                            "bindings/translate-time-profile.cc",
                             "bindings/test/binding.cc",
                             "bindings/test/profilers/cpu.test.cc",
                             "bindings/test/code-event-record.test.cc",
@@ -56,6 +59,7 @@
                             "bindings/test/sample.test.cc"
                         ],
                         "include_dirs": [
+                            "bindings",
                             "<!(node -e \"require('nan')\")"
                         ]
                     }

bindings/binding.cc

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #include <nan.h>
 #include <node.h>
 #include <v8.h>

bindings/buffer.hh

@@ -0,0 +1,86 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#pragma once
+
+namespace dd {
+template <class T>
+class RingBuffer {
+ public:
+  explicit RingBuffer(size_t capacity)
+      : buffer(std::make_unique<T[]>(capacity)),
+        capacity_(capacity),
+        size_(0),
+        back_index_(0),
+        front_index_(0) {}
+
+  size_t capacity() const { return capacity_; }
+  bool full() const { return size_ == capacity_; }
+  bool empty() const { return size_ == 0; }
+  size_t size() const { return size_; }
+
+  T& front() { return buffer[front_index_]; }
+  const T& front() const { return buffer[front_index_]; }
+
+  void push_back(const T& t) { push_back_(t); }
+  void push_back(T&& t) { push_back_(std::move(t)); }
+
+  void clear() {
+    while (!empty()) {
+      pop_front();
+    }
+  }
+
+  T pop_front() {
+    auto idx = front_index_;
+    increment(front_index_);
+    --size_;
+    return std::move(buffer[idx]);
+  }
+
+ private:
+  template <typename U>
+  void push_back_(U&& t) {
+    const bool is_full = full();
+
+    if (is_full && empty()) {
+      return;
+    }
+    buffer[back_index_] = std::forward<U>(t);
+    increment(back_index_);
+
+    if (is_full) {
+      // move buffer head
+      front_index_ = back_index_;
+    } else {
+      ++size_;
+    }
+  }
+
+  void increment(size_t& idx) const {
+    idx = idx + 1 == capacity_ ? 0 : idx + 1;
+  }
+  void decrement(size_t& idx) const {
+    idx = idx == 0 ? capacity_ - 1 : idx - 1;
+  }
+
+  std::unique_ptr<T[]> buffer;
+  size_t capacity_;
+  size_t size_;
+  size_t back_index_;
+  size_t front_index_;
+};
+}  // namespace dd

bindings/code-event-record.cc

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #include <node.h>
 
 #include "code-event-record.hh"

bindings/code-event-record.hh

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #pragma once
 
 #include <string>

bindings/code-map.cc

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #include <unordered_map>
 
 #include <node.h>

bindings/code-map.hh

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #pragma once
 
 #include <cstdint>

bindings/cpu-time.cc

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #include "cpu-time.hh"
 
 #ifdef __linux__

bindings/cpu-time.hh

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #pragma once
 
 #include <cstdint>

bindings/labelsets.hh

@@ -0,0 +1,31 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#pragma once
+
+#include <nan.h>
+#include <v8-profiler.h>
+#include <unordered_map>
+
+namespace dd {
+
+struct NodeInfo {
+  v8::Local<v8::Array> labelSets;
+  uint32_t hitcount;
+};
+
+using LabelSetsByNode = std::unordered_map<const v8::CpuProfileNode*, NodeInfo>;
+}  // namespace dd

bindings/location.cc

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #include <utility>
 
 #include <node.h>

bindings/location.hh

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #pragma once
 
 #include <nan.h>

bindings/per-isolate-data.cc

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #include <mutex>
 #include <unordered_map>
 #include <utility>

bindings/per-isolate-data.hh

@@ -1,3 +1,19 @@
+/*
+ * Copyright 2023 Datadog, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 #pragma once
 
 #include <nan.h>