diff options
| author | Shauren <shauren.trinity@gmail.com> | 2018-01-06 01:21:59 +0100 |
|---|---|---|
| committer | Shauren <shauren.trinity@gmail.com> | 2018-01-06 01:21:59 +0100 |
| commit | dfd2660a85e4f0891c63009ee8425b2796586409 (patch) | |
| tree | 26704dff3840402765ada5e6e4549a48b95ed82b /src/common/Metric | |
| parent | 76577ddc3ca4edd5943777443d9cf5a4c5314e10 (diff) | |
Core/Misc: Added compatibility layer for boost 1.66 and future std:: networking stuff
* Based on work done by @dimiandre in PR #21173
Closes #21171
Closes #21173
Diffstat (limited to 'src/common/Metric')
| -rw-r--r-- | src/common/Metric/Metric.cpp | 12 | ||||
| -rw-r--r-- | src/common/Metric/Metric.h | 8 |
2 files changed, 10 insertions, 10 deletions
diff --git a/src/common/Metric/Metric.cpp b/src/common/Metric/Metric.cpp index dd564b695f7..cd30f2e4b08 100644 --- a/src/common/Metric/Metric.cpp +++ b/src/common/Metric/Metric.cpp @@ -16,21 +16,21 @@ */ #include "Metric.h" -#include "AsioHacksImpl.h" #include "Common.h" #include "Config.h" #include "Log.h" +#include "Strand.h" #include "Util.h" #include <boost/algorithm/string/replace.hpp> #include <boost/asio/deadline_timer.hpp> #include <boost/asio/ip/tcp.hpp> -void Metric::Initialize(std::string const& realmName, boost::asio::io_service& ioService, std::function<void()> overallStatusLogger) +void Metric::Initialize(std::string const& realmName, Trinity::Asio::IoContext& ioContext, std::function<void()> overallStatusLogger) { _dataStream = Trinity::make_unique<boost::asio::ip::tcp::iostream>(); _realmName = FormatInfluxDBTagValue(realmName); - _batchTimer = Trinity::make_unique<boost::asio::deadline_timer>(ioService); - _overallStatusTimer = Trinity::make_unique<boost::asio::deadline_timer>(ioService); + _batchTimer = Trinity::make_unique<boost::asio::deadline_timer>(ioContext); + _overallStatusTimer = Trinity::make_unique<boost::asio::deadline_timer>(ioContext); _overallStatusLogger = overallStatusLogger; LoadFromConfigs(); } @@ -215,8 +215,8 @@ void Metric::ScheduleSend() void Metric::ForceSend() { - // Send what's queued only if io_service is stopped (so only on shutdown) - if (_enabled && _batchTimer->get_io_service().stopped()) + // Send what's queued only if IoContext is stopped (so only on shutdown) + if (_enabled && Trinity::Asio::get_io_context(*_batchTimer).stopped()) SendBatch(); } diff --git a/src/common/Metric/Metric.h b/src/common/Metric/Metric.h index 1e1f8cf8e48..ae61b5f35d5 100644 --- a/src/common/Metric/Metric.h +++ b/src/common/Metric/Metric.h @@ -27,11 +27,11 @@ #include <memory> #include <string> -namespace boost +namespace Trinity { - namespace asio + namespace Asio { - class io_service; + class IoContext; } } @@ -95,7 +95,7 @@ public: ~Metric(); static Metric* instance(); - void Initialize(std::string const& realmName, boost::asio::io_service& ioService, std::function<void()> overallStatusLogger); + void Initialize(std::string const& realmName, Trinity::Asio::IoContext& ioContext, std::function<void()> overallStatusLogger); void LoadFromConfigs(); void Update(); |
