mirror of
https://github.com/zerotier/ZeroTierOne.git
synced 2026-04-29 16:28:19 -07:00
include the otel header-only part directly for ease of use
This commit is contained in:
Grant Limberg
parent
8895ad182f
commit
7f835b414a
241 changed files with 49967 additions and 3 deletions
|
|
@ -0,0 +1,20 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
/**
|
||||
* Manage the ownership of a dynamically loaded library.
|
||||
*/
|
||||
class DynamicLibraryHandle
|
||||
{
|
||||
public:
|
||||
virtual ~DynamicLibraryHandle() = default;
|
||||
};
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,73 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <dlfcn.h>
|
||||
#include <algorithm>
|
||||
#include <memory>
|
||||
|
||||
#include "opentelemetry/plugin/detail/dynamic_library_handle.h"
|
||||
#include "opentelemetry/plugin/detail/loader_info.h"
|
||||
#include "opentelemetry/plugin/detail/utility.h"
|
||||
#include "opentelemetry/plugin/factory.h"
|
||||
#include "opentelemetry/plugin/hook.h"
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
class DynamicLibraryHandleUnix final : public DynamicLibraryHandle
|
||||
{
|
||||
public:
|
||||
explicit DynamicLibraryHandleUnix(void *handle) noexcept : handle_{handle} {}
|
||||
|
||||
~DynamicLibraryHandleUnix() override { ::dlclose(handle_); }
|
||||
|
||||
private:
|
||||
void *handle_;
|
||||
};
|
||||
|
||||
inline std::unique_ptr<Factory> LoadFactory(const char *plugin, std::string &error_message) noexcept
|
||||
{
|
||||
dlerror(); // Clear any existing error.
|
||||
|
||||
auto handle = ::dlopen(plugin, RTLD_NOW | RTLD_LOCAL);
|
||||
if (handle == nullptr)
|
||||
{
|
||||
detail::CopyErrorMessage(dlerror(), error_message);
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
std::shared_ptr<DynamicLibraryHandle> library_handle{new (std::nothrow)
|
||||
DynamicLibraryHandleUnix{handle}};
|
||||
if (library_handle == nullptr)
|
||||
{
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
auto make_factory_impl =
|
||||
reinterpret_cast<OpenTelemetryHook *>(::dlsym(handle, "OpenTelemetryMakeFactoryImpl"));
|
||||
if (make_factory_impl == nullptr)
|
||||
{
|
||||
detail::CopyErrorMessage(dlerror(), error_message);
|
||||
return nullptr;
|
||||
}
|
||||
if (*make_factory_impl == nullptr)
|
||||
{
|
||||
detail::CopyErrorMessage("Invalid plugin hook", error_message);
|
||||
return nullptr;
|
||||
}
|
||||
LoaderInfo loader_info;
|
||||
nostd::unique_ptr<char[]> plugin_error_message;
|
||||
auto factory_impl = (**make_factory_impl)(loader_info, plugin_error_message);
|
||||
if (factory_impl == nullptr)
|
||||
{
|
||||
detail::CopyErrorMessage(plugin_error_message.get(), error_message);
|
||||
return nullptr;
|
||||
}
|
||||
return std::unique_ptr<Factory>{new (std::nothrow)
|
||||
Factory{std::move(library_handle), std::move(factory_impl)}};
|
||||
}
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,96 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <memory>
|
||||
|
||||
#include "opentelemetry/plugin/detail/dynamic_library_handle.h"
|
||||
#include "opentelemetry/plugin/detail/loader_info.h"
|
||||
#include "opentelemetry/plugin/detail/utility.h"
|
||||
#include "opentelemetry/plugin/factory.h"
|
||||
#include "opentelemetry/plugin/hook.h"
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
#include <Windows.h>
|
||||
|
||||
#include <WinBase.h>
|
||||
#include <errhandlingapi.h>
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
namespace detail
|
||||
{
|
||||
inline void GetLastErrorMessage(std::string &error_message) noexcept
|
||||
{
|
||||
auto error_code = ::GetLastError();
|
||||
// See https://stackoverflow.com/a/455533/4447365
|
||||
LPTSTR error_text = nullptr;
|
||||
auto size = ::FormatMessage(
|
||||
FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_IGNORE_INSERTS,
|
||||
nullptr, error_code, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
|
||||
reinterpret_cast<LPTSTR>(&error_text), 0, nullptr);
|
||||
if (size == 0)
|
||||
{
|
||||
return;
|
||||
}
|
||||
CopyErrorMessage(error_text, error_message);
|
||||
::LocalFree(error_text);
|
||||
}
|
||||
} // namespace detail
|
||||
|
||||
class DynamicLibraryHandleWindows final : public DynamicLibraryHandle
|
||||
{
|
||||
public:
|
||||
explicit DynamicLibraryHandleWindows(HINSTANCE handle) : handle_{handle} {}
|
||||
|
||||
~DynamicLibraryHandleWindows() override { ::FreeLibrary(handle_); }
|
||||
|
||||
private:
|
||||
HINSTANCE handle_;
|
||||
};
|
||||
|
||||
inline std::unique_ptr<Factory> LoadFactory(const char *plugin, std::string &error_message) noexcept
|
||||
{
|
||||
auto handle = ::LoadLibrary(plugin);
|
||||
if (handle == nullptr)
|
||||
{
|
||||
detail::GetLastErrorMessage(error_message);
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
std::shared_ptr<DynamicLibraryHandle> library_handle{new (std::nothrow)
|
||||
DynamicLibraryHandleWindows{handle}};
|
||||
if (library_handle == nullptr)
|
||||
{
|
||||
detail::CopyErrorMessage("Allocation failure", error_message);
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
auto make_factory_impl = reinterpret_cast<OpenTelemetryHook *>(
|
||||
::GetProcAddress(handle, "OpenTelemetryMakeFactoryImpl"));
|
||||
if (make_factory_impl == nullptr)
|
||||
{
|
||||
detail::GetLastErrorMessage(error_message);
|
||||
return nullptr;
|
||||
}
|
||||
if (*make_factory_impl == nullptr)
|
||||
{
|
||||
detail::CopyErrorMessage("Invalid plugin hook", error_message);
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
LoaderInfo loader_info;
|
||||
nostd::unique_ptr<char[]> plugin_error_message;
|
||||
auto factory_impl = (**make_factory_impl)(loader_info, plugin_error_message);
|
||||
if (factory_impl == nullptr)
|
||||
{
|
||||
detail::CopyErrorMessage(plugin_error_message.get(), error_message);
|
||||
return nullptr;
|
||||
}
|
||||
return std::unique_ptr<Factory>{new (std::nothrow)
|
||||
Factory{std::move(library_handle), std::move(factory_impl)}};
|
||||
}
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,24 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include "opentelemetry/nostd/string_view.h"
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
/**
|
||||
* LoaderInfo describes the versioning of the loader.
|
||||
*
|
||||
* Plugins can check against this information and properly error out if they were built against an
|
||||
* incompatible OpenTelemetry API.
|
||||
*/
|
||||
struct LoaderInfo
|
||||
{
|
||||
nostd::string_view opentelemetry_version = OPENTELEMETRY_VERSION;
|
||||
nostd::string_view opentelemetry_abi_version = OPENTELEMETRY_ABI_VERSION;
|
||||
};
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,27 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace trace
|
||||
{
|
||||
class Tracer;
|
||||
} // namespace trace
|
||||
|
||||
namespace plugin
|
||||
{
|
||||
/**
|
||||
* Manage the ownership of a dynamically loaded tracer.
|
||||
*/
|
||||
class TracerHandle
|
||||
{
|
||||
public:
|
||||
virtual ~TracerHandle() = default;
|
||||
|
||||
virtual trace::Tracer &tracer() const noexcept = 0;
|
||||
};
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,36 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#if __EXCEPTIONS
|
||||
# include <new>
|
||||
#endif // __EXCEPTIONS
|
||||
|
||||
#include <string>
|
||||
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
namespace detail
|
||||
{
|
||||
inline void CopyErrorMessage(const char *source, std::string &destination) noexcept
|
||||
#if __EXCEPTIONS
|
||||
try
|
||||
#endif
|
||||
{
|
||||
if (source == nullptr)
|
||||
{
|
||||
return;
|
||||
}
|
||||
destination.assign(source);
|
||||
}
|
||||
#if __EXCEPTIONS
|
||||
catch (const std::bad_alloc &)
|
||||
{}
|
||||
#endif
|
||||
} // namespace detail
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,30 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <memory>
|
||||
#include <string>
|
||||
|
||||
#include "opentelemetry/plugin/factory.h"
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
#ifdef _WIN32
|
||||
# include "opentelemetry/plugin/detail/dynamic_load_windows.h" // IWYU pragma: export
|
||||
#else
|
||||
# include "opentelemetry/plugin/detail/dynamic_load_unix.h" // IWYU pragma: export
|
||||
#endif
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
|
||||
/**
|
||||
* Load an OpenTelemetry implementation as a plugin.
|
||||
* @param plugin the path to the plugin to load
|
||||
* @param error_message on failure this is set to an error message
|
||||
* @return a Factory that can be used to create OpenTelemetry objects or nullptr on failure.
|
||||
*/
|
||||
std::unique_ptr<Factory> LoadFactory(const char *plugin, std::string &error_message) noexcept;
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,65 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <memory>
|
||||
#include <string>
|
||||
|
||||
#include "opentelemetry/plugin/detail/utility.h" // IWYU pragma: export
|
||||
#include "opentelemetry/plugin/tracer.h"
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
/**
|
||||
* Factory creates OpenTelemetry objects from configuration strings.
|
||||
*/
|
||||
class Factory final
|
||||
{
|
||||
public:
|
||||
class FactoryImpl
|
||||
{
|
||||
public:
|
||||
virtual ~FactoryImpl() {}
|
||||
|
||||
virtual nostd::unique_ptr<TracerHandle> MakeTracerHandle(
|
||||
nostd::string_view tracer_config,
|
||||
nostd::unique_ptr<char[]> &error_message) const noexcept = 0;
|
||||
};
|
||||
|
||||
Factory(std::shared_ptr<DynamicLibraryHandle> library_handle,
|
||||
std::unique_ptr<FactoryImpl> &&factory_impl) noexcept
|
||||
: library_handle_{std::move(library_handle)}, factory_impl_{std::move(factory_impl)}
|
||||
{}
|
||||
|
||||
/**
|
||||
* Construct a tracer from a configuration string.
|
||||
* @param tracer_config a representation of the tracer's config as a string.
|
||||
* @param error_message on failure this will contain an error message.
|
||||
* @return a Tracer on success or nullptr on failure.
|
||||
*/
|
||||
std::shared_ptr<trace::Tracer> MakeTracer(nostd::string_view tracer_config,
|
||||
std::string &error_message) const noexcept
|
||||
{
|
||||
nostd::unique_ptr<char[]> plugin_error_message;
|
||||
auto tracer_handle = factory_impl_->MakeTracerHandle(tracer_config, plugin_error_message);
|
||||
if (tracer_handle == nullptr)
|
||||
{
|
||||
detail::CopyErrorMessage(plugin_error_message.get(), error_message);
|
||||
return nullptr;
|
||||
}
|
||||
return std::shared_ptr<trace::Tracer>{new (std::nothrow)
|
||||
Tracer{library_handle_, std::move(tracer_handle)}};
|
||||
}
|
||||
|
||||
private:
|
||||
// Note: The order is important here.
|
||||
//
|
||||
// It's undefined behavior to close the library while a loaded FactoryImpl is still active.
|
||||
std::shared_ptr<DynamicLibraryHandle> library_handle_;
|
||||
std::unique_ptr<FactoryImpl> factory_impl_;
|
||||
};
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,51 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include "opentelemetry/nostd/unique_ptr.h"
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
#ifdef _WIN32
|
||||
|
||||
/**
|
||||
* Cross-platform helper macro to declare the symbol used to load an OpenTelemetry implementation
|
||||
* as a plugin.
|
||||
*
|
||||
* Note: The symbols use weak linkage so as to support using an OpenTelemetry both as a regular
|
||||
* library and a dynamically loaded plugin. The weak linkage allows for multiple implementations to
|
||||
* be linked in without getting multiple definition errors.
|
||||
*/
|
||||
# define OPENTELEMETRY_DEFINE_PLUGIN_HOOK(X) \
|
||||
extern "C" { \
|
||||
extern __declspec(dllexport) opentelemetry::plugin::OpenTelemetryHook const \
|
||||
OpenTelemetryMakeFactoryImpl; \
|
||||
\
|
||||
__declspec(selectany) opentelemetry::plugin::OpenTelemetryHook const \
|
||||
OpenTelemetryMakeFactoryImpl = X; \
|
||||
} // extern "C"
|
||||
|
||||
#else
|
||||
|
||||
# define OPENTELEMETRY_DEFINE_PLUGIN_HOOK(X) \
|
||||
extern "C" { \
|
||||
__attribute(( \
|
||||
weak)) extern opentelemetry::plugin::OpenTelemetryHook const OpenTelemetryMakeFactoryImpl; \
|
||||
\
|
||||
opentelemetry::plugin::OpenTelemetryHook const OpenTelemetryMakeFactoryImpl = X; \
|
||||
} // extern "C"
|
||||
|
||||
#endif
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
|
||||
struct LoaderInfo;
|
||||
class FactoryImpl;
|
||||
|
||||
using OpenTelemetryHook =
|
||||
nostd::unique_ptr<Factory::FactoryImpl> (*)(const LoaderInfo &loader_info,
|
||||
nostd::unique_ptr<char[]> &error_message);
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
|
|
@ -0,0 +1,133 @@
|
|||
// Copyright The OpenTelemetry Authors
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
#pragma once
|
||||
|
||||
#include <memory>
|
||||
|
||||
#include "opentelemetry/common/key_value_iterable.h"
|
||||
#include "opentelemetry/plugin/detail/tracer_handle.h" // IWYU pragma: export
|
||||
#include "opentelemetry/trace/span_context_kv_iterable.h"
|
||||
#include "opentelemetry/trace/tracer.h"
|
||||
#include "opentelemetry/version.h"
|
||||
|
||||
OPENTELEMETRY_BEGIN_NAMESPACE
|
||||
namespace plugin
|
||||
{
|
||||
|
||||
class DynamicLibraryHandle;
|
||||
|
||||
class Span final : public trace::Span
|
||||
{
|
||||
public:
|
||||
Span(std::shared_ptr<trace::Tracer> &&tracer, const nostd::shared_ptr<trace::Span> &span) noexcept
|
||||
: tracer_{std::move(tracer)}, span_{span}
|
||||
{}
|
||||
|
||||
// trace::Span
|
||||
void SetAttribute(nostd::string_view name, const common::AttributeValue &value) noexcept override
|
||||
{
|
||||
span_->SetAttribute(name, value);
|
||||
}
|
||||
|
||||
void AddEvent(nostd::string_view name) noexcept override { span_->AddEvent(name); }
|
||||
|
||||
void AddEvent(nostd::string_view name, common::SystemTimestamp timestamp) noexcept override
|
||||
{
|
||||
span_->AddEvent(name, timestamp);
|
||||
}
|
||||
|
||||
void AddEvent(nostd::string_view name,
|
||||
const common::KeyValueIterable &attributes) noexcept override
|
||||
{
|
||||
span_->AddEvent(name, attributes);
|
||||
}
|
||||
|
||||
void AddEvent(nostd::string_view name,
|
||||
common::SystemTimestamp timestamp,
|
||||
const common::KeyValueIterable &attributes) noexcept override
|
||||
{
|
||||
span_->AddEvent(name, timestamp, attributes);
|
||||
}
|
||||
|
||||
#if OPENTELEMETRY_ABI_VERSION_NO >= 2
|
||||
void AddLink(const trace::SpanContext &target,
|
||||
const common::KeyValueIterable &attrs) noexcept override
|
||||
{
|
||||
span_->AddLink(target, attrs);
|
||||
}
|
||||
|
||||
void AddLinks(const trace::SpanContextKeyValueIterable &links) noexcept override
|
||||
{
|
||||
span_->AddLinks(links);
|
||||
}
|
||||
#endif
|
||||
|
||||
void SetStatus(trace::StatusCode code, nostd::string_view description) noexcept override
|
||||
{
|
||||
span_->SetStatus(code, description);
|
||||
}
|
||||
|
||||
void UpdateName(nostd::string_view name) noexcept override { span_->UpdateName(name); }
|
||||
|
||||
void End(const trace::EndSpanOptions &options = {}) noexcept override { span_->End(options); }
|
||||
|
||||
bool IsRecording() const noexcept override { return span_->IsRecording(); }
|
||||
|
||||
trace::SpanContext GetContext() const noexcept override { return span_->GetContext(); }
|
||||
|
||||
private:
|
||||
std::shared_ptr<trace::Tracer> tracer_;
|
||||
nostd::shared_ptr<trace::Span> span_;
|
||||
};
|
||||
|
||||
class Tracer final : public trace::Tracer, public std::enable_shared_from_this<Tracer>
|
||||
{
|
||||
public:
|
||||
Tracer(std::shared_ptr<DynamicLibraryHandle> library_handle,
|
||||
std::unique_ptr<TracerHandle> &&tracer_handle) noexcept
|
||||
: library_handle_{std::move(library_handle)}, tracer_handle_{std::move(tracer_handle)}
|
||||
{
|
||||
#if OPENTELEMETRY_ABI_VERSION_NO >= 2
|
||||
UpdateEnabled(true);
|
||||
#endif
|
||||
}
|
||||
|
||||
// trace::Tracer
|
||||
nostd::shared_ptr<trace::Span> StartSpan(
|
||||
nostd::string_view name,
|
||||
const common::KeyValueIterable &attributes,
|
||||
const trace::SpanContextKeyValueIterable &links,
|
||||
const trace::StartSpanOptions &options = {}) noexcept override
|
||||
{
|
||||
auto span = tracer_handle_->tracer().StartSpan(name, attributes, links, options);
|
||||
if (span == nullptr)
|
||||
{
|
||||
return nostd::shared_ptr<trace::Span>(nullptr);
|
||||
}
|
||||
return nostd::shared_ptr<trace::Span>{new (std::nothrow) Span{this->shared_from_this(), span}};
|
||||
}
|
||||
|
||||
#if OPENTELEMETRY_ABI_VERSION_NO == 1
|
||||
|
||||
void ForceFlushWithMicroseconds(uint64_t timeout) noexcept override
|
||||
{
|
||||
tracer_handle_->tracer().ForceFlushWithMicroseconds(timeout);
|
||||
}
|
||||
|
||||
void CloseWithMicroseconds(uint64_t timeout) noexcept override
|
||||
{
|
||||
tracer_handle_->tracer().CloseWithMicroseconds(timeout);
|
||||
}
|
||||
|
||||
#endif /* OPENTELEMETRY_ABI_VERSION_NO */
|
||||
|
||||
private:
|
||||
// Note: The order is important here.
|
||||
//
|
||||
// It's undefined behavior to close the library while a loaded tracer is still active.
|
||||
std::shared_ptr<DynamicLibraryHandle> library_handle_;
|
||||
std::unique_ptr<TracerHandle> tracer_handle_;
|
||||
};
|
||||
} // namespace plugin
|
||||
OPENTELEMETRY_END_NAMESPACE
|
||||
Loading…
Add table
Add a link
Reference in a new issue