aboutsummaryrefslogtreecommitdiff
path: root/src/common/Metric
diff options
context:
space:
mode:
authorShauren <shauren.trinity@gmail.com>2018-01-06 01:21:59 +0100
committerShauren <shauren.trinity@gmail.com>2018-01-06 01:21:59 +0100
commitdfd2660a85e4f0891c63009ee8425b2796586409 (patch)
tree26704dff3840402765ada5e6e4549a48b95ed82b /src/common/Metric
parent76577ddc3ca4edd5943777443d9cf5a4c5314e10 (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.cpp12
-rw-r--r--src/common/Metric/Metric.h8
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();