blob: 65cd6be3389f2cd8acb004793a2041fe8cb094f9 (
plain) (
blame)
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
|
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
#include "opentelemetry/sdk/metrics/metric_reader.h"
#include "opentelemetry/sdk/common/global_log_handler.h"
#include "opentelemetry/sdk/metrics/export/metric_producer.h"
#include "opentelemetry/version.h"
OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
{
namespace metrics
{
void MetricReader::SetMetricProducer(MetricProducer *metric_producer)
{
metric_producer_ = metric_producer;
OnInitialized();
}
bool MetricReader::Collect(
nostd::function_ref<bool(ResourceMetrics &metric_data)> callback) noexcept
{
if (!metric_producer_)
{
OTEL_INTERNAL_LOG_WARN(
"MetricReader::Collect Cannot invoke Produce(). No MetricProducer registered for "
"collection!")
return false;
}
if (IsShutdown())
{
// Continue with warning, and let pull and push MetricReader state machine handle this.
OTEL_INTERNAL_LOG_WARN("MetricReader::Collect invoked while Shutdown in progress!");
}
auto result = metric_producer_->Produce();
// According to the spec,
// When the Produce operation fails, the MetricProducer MAY return successfully collected
// results and a failed reasons list to the caller.
// So we invoke the callback with whatever points we get back, even if the overall operation may
// have failed.
auto success = callback(result.points_);
return (result.status_ == MetricProducer::Status::kSuccess) && success;
}
bool MetricReader::Shutdown(std::chrono::microseconds timeout) noexcept
{
bool status = true;
if (IsShutdown())
{
OTEL_INTERNAL_LOG_WARN("MetricReader::Shutdown - Cannot invoke shutdown twice!");
}
shutdown_.store(true, std::memory_order_release);
if (!OnShutDown(timeout))
{
status = false;
OTEL_INTERNAL_LOG_WARN("MetricReader::OnShutDown Shutdown failed. Will not be tried again!");
}
return status;
}
/** Flush metric read by this reader **/
bool MetricReader::ForceFlush(std::chrono::microseconds timeout) noexcept
{
bool status = true;
if (IsShutdown())
{
OTEL_INTERNAL_LOG_WARN("MetricReader::Shutdown Cannot invoke Force flush on shutdown reader!");
}
if (!OnForceFlush(timeout))
{
status = false;
OTEL_INTERNAL_LOG_ERROR("MetricReader::OnForceFlush failed!");
}
return status;
}
bool MetricReader::IsShutdown() const noexcept
{
return shutdown_.load(std::memory_order_acquire);
}
} // namespace metrics
} // namespace sdk
OPENTELEMETRY_END_NAMESPACE
|
