update ceph source to reef 18.1.2

[ceph.git] / ceph / src / jaegertracing / opentelemetry-cpp / sdk / src / metrics / state / sync_metric_storage.cc

diff --git a/ceph/src/jaegertracing/opentelemetry-cpp/sdk/src/metrics/state/sync_metric_storage.cc b/ceph/src/jaegertracing/opentelemetry-cpp/sdk/src/metrics/state/sync_metric_storage.cc
new file mode 100644 (file)
index 0000000..8c79f9d
--- /dev/null
+++ b/ceph/src/jaegertracing/opentelemetry-cpp/sdk/src/metrics/state/sync_metric_storage.cc
@@ -0,0 +1,36 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+#ifndef ENABLE_METRICS_PREVIEW
+
+#  include "opentelemetry/sdk/metrics/state/sync_metric_storage.h"
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace sdk
+{
+namespace metrics
+{
+
+bool SyncMetricStorage::Collect(CollectorHandle *collector,
+                                nostd::span<std::shared_ptr<CollectorHandle>> collectors,
+                                opentelemetry::common::SystemTimestamp sdk_start_ts,
+                                opentelemetry::common::SystemTimestamp collection_ts,
+                                nostd::function_ref<bool(MetricData)> callback) noexcept
+{
+  opentelemetry::common::SystemTimestamp last_collection_ts = sdk_start_ts;
+  auto aggregation_temporarily = collector->GetAggregationTemporality();
+
+  // Add the current delta metrics to `unreported metrics stash` for all the collectors,
+  // this will also empty the delta metrics hashmap, and make it available for
+  // recordings
+  std::shared_ptr<AttributesHashMap> delta_metrics = std::move(attributes_hashmap_);
+  attributes_hashmap_.reset(new AttributesHashMap);
+
+  return temporal_metric_storage_.buildMetrics(collector, collectors, sdk_start_ts, collection_ts,
+                                               std::move(delta_metrics), callback);
+}
+
+}  // namespace metrics
+}  // namespace sdk
+OPENTELEMETRY_END_NAMESPACE
+#endif