blob: 6e2fde9f140e6cdcf2aa10609774fdc125e984d2 (
plain)
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
|
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
#ifdef ENABLE_LOGS_PREVIEW
# include "opentelemetry/sdk/logs/simple_log_processor.h"
# include <chrono>
# include <vector>
OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
{
namespace logs
{
/**
* Initialize a simple log processor.
* @param exporter the configured exporter where log records are sent
*/
SimpleLogProcessor::SimpleLogProcessor(std::unique_ptr<LogExporter> &&exporter)
: exporter_(std::move(exporter))
{}
std::unique_ptr<Recordable> SimpleLogProcessor::MakeRecordable() noexcept
{
return exporter_->MakeRecordable();
}
/**
* Batches the log record it receives in a batch of 1 and immediately sends it
* to the configured exporter
*/
void SimpleLogProcessor::OnReceive(std::unique_ptr<Recordable> &&record) noexcept
{
nostd::span<std::unique_ptr<Recordable>> batch(&record, 1);
// Get lock to ensure Export() is never called concurrently
const std::lock_guard<opentelemetry::common::SpinLockMutex> locked(lock_);
if (exporter_->Export(batch) != sdk::common::ExportResult::kSuccess)
{
/* Alert user of the failed export */
}
}
/**
* The simple processor does not have any log records to flush so this method is not used
*/
bool SimpleLogProcessor::ForceFlush(std::chrono::microseconds timeout) noexcept
{
return true;
}
bool SimpleLogProcessor::Shutdown(std::chrono::microseconds timeout) noexcept
{
// Should only shutdown exporter ONCE.
if (!shutdown_latch_.test_and_set(std::memory_order_acquire) && exporter_ != nullptr)
{
return exporter_->Shutdown(timeout);
}
return true;
}
} // namespace logs
} // namespace sdk
OPENTELEMETRY_END_NAMESPACE
#endif
|
