diff options
author | Shauren <shauren.trinity@gmail.com> | 2024-06-12 21:41:29 +0200 |
---|---|---|
committer | Shauren <shauren.trinity@gmail.com> | 2024-06-12 21:41:29 +0200 |
commit | 7fcb126fcb7cff945936a7f5e051b07ce0de8a7f (patch) | |
tree | dff4c0a1fdf3ab28bdffd95dbe6694c119de0aa1 /src | |
parent | 00efee9ca12d6e625e9954a39768bbec029d0459 (diff) |
Core/Database: Remove future/promise typedefs from a public header (these are internal to database project)
Diffstat (limited to 'src')
-rw-r--r-- | src/server/database/Database/DatabaseEnvFwd.h | 10 | ||||
-rw-r--r-- | src/server/database/Database/DatabaseWorkerPool.cpp | 8 | ||||
-rw-r--r-- | src/server/database/Database/DatabaseWorkerPool.h | 1 | ||||
-rw-r--r-- | src/server/database/Database/MySQLConnection.h | 1 | ||||
-rw-r--r-- | src/server/database/Database/QueryCallback.cpp | 4 | ||||
-rw-r--r-- | src/server/database/Database/QueryCallback.h | 9 | ||||
-rw-r--r-- | src/server/database/Database/QueryHolder.h | 5 | ||||
-rw-r--r-- | src/server/database/Database/Transaction.h | 5 | ||||
-rw-r--r-- | src/server/database/Updater/UpdateFetcher.h | 1 | ||||
-rw-r--r-- | src/server/game/Accounts/AccountMgr.h | 1 | ||||
-rw-r--r-- | src/server/game/Globals/ObjectAccessor.cpp | 1 | ||||
-rw-r--r-- | src/server/game/Globals/ObjectMgr.h | 1 | ||||
-rw-r--r-- | src/server/game/Server/WorldSession.h | 1 |
13 files changed, 24 insertions, 24 deletions
diff --git a/src/server/database/Database/DatabaseEnvFwd.h b/src/server/database/Database/DatabaseEnvFwd.h index 4521409902b..18c4216a193 100644 --- a/src/server/database/Database/DatabaseEnvFwd.h +++ b/src/server/database/Database/DatabaseEnvFwd.h @@ -18,7 +18,6 @@ #ifndef DatabaseEnvFwd_h__ #define DatabaseEnvFwd_h__ -#include <future> #include <memory> struct QueryResultFieldMetadata; @@ -26,8 +25,6 @@ class Field; class ResultSet; using QueryResult = std::shared_ptr<ResultSet>; -using QueryResultFuture = std::future<QueryResult>; -using QueryResultPromise = std::promise<QueryResult>; class CharacterDatabaseConnection; class HotfixDatabaseConnection; @@ -46,8 +43,6 @@ using WorldDatabasePreparedStatement = PreparedStatement<WorldDatabaseConnection class PreparedResultSet; using PreparedQueryResult = std::shared_ptr<PreparedResultSet>; -using PreparedQueryResultFuture = std::future<PreparedQueryResult>; -using PreparedQueryResultPromise = std::promise<PreparedQueryResult>; class QueryCallback; @@ -58,9 +53,6 @@ using QueryCallbackProcessor = AsyncCallbackProcessor<QueryCallback>; class TransactionBase; -using TransactionFuture = std::future<bool>; -using TransactionPromise = std::promise<bool>; - template<typename T> class Transaction; @@ -75,8 +67,6 @@ using LoginDatabaseTransaction = SQLTransaction<LoginDatabaseConnection>; using WorldDatabaseTransaction = SQLTransaction<WorldDatabaseConnection>; class SQLQueryHolderBase; -using QueryResultHolderFuture = std::future<void>; -using QueryResultHolderPromise = std::promise<void>; template<typename T> class SQLQueryHolder; diff --git a/src/server/database/Database/DatabaseWorkerPool.cpp b/src/server/database/Database/DatabaseWorkerPool.cpp index 35a1ffb74f9..ad63678d367 100644 --- a/src/server/database/Database/DatabaseWorkerPool.cpp +++ b/src/server/database/Database/DatabaseWorkerPool.cpp @@ -260,7 +260,7 @@ PreparedQueryResult DatabaseWorkerPool<T>::Query(PreparedStatement<T>* stmt) template <class T> QueryCallback DatabaseWorkerPool<T>::AsyncQuery(char const* sql) { - QueryResultFuture result = boost::asio::post(_ioContext->get_executor(), boost::asio::use_future([this, sql = std::string(sql), tracker = QueueSizeTracker(this)] + std::future<QueryResult> result = boost::asio::post(_ioContext->get_executor(), boost::asio::use_future([this, sql = std::string(sql), tracker = QueueSizeTracker(this)] { T* conn = GetAsyncConnectionForCurrentThread(); return BasicStatementTask::Query(conn, sql.c_str()); @@ -271,7 +271,7 @@ QueryCallback DatabaseWorkerPool<T>::AsyncQuery(char const* sql) template <class T> QueryCallback DatabaseWorkerPool<T>::AsyncQuery(PreparedStatement<T>* stmt) { - PreparedQueryResultFuture result = boost::asio::post(_ioContext->get_executor(), boost::asio::use_future([this, stmt = std::unique_ptr<PreparedStatement<T>>(stmt), tracker = QueueSizeTracker(this)] + std::future<PreparedQueryResult> result = boost::asio::post(_ioContext->get_executor(), boost::asio::use_future([this, stmt = std::unique_ptr<PreparedStatement<T>>(stmt), tracker = QueueSizeTracker(this)] { T* conn = GetAsyncConnectionForCurrentThread(); return PreparedStatementTask::Query(conn, stmt.get()); @@ -282,7 +282,7 @@ QueryCallback DatabaseWorkerPool<T>::AsyncQuery(PreparedStatement<T>* stmt) template <class T> SQLQueryHolderCallback DatabaseWorkerPool<T>::DelayQueryHolder(std::shared_ptr<SQLQueryHolder<T>> holder) { - QueryResultHolderFuture result = boost::asio::post(_ioContext->get_executor(), boost::asio::use_future([this, holder, tracker = QueueSizeTracker(this)] + std::future<void> result = boost::asio::post(_ioContext->get_executor(), boost::asio::use_future([this, holder, tracker = QueueSizeTracker(this)] { T* conn = GetAsyncConnectionForCurrentThread(); SQLQueryHolderTask::Execute(conn, holder.get()); @@ -343,7 +343,7 @@ TransactionCallback DatabaseWorkerPool<T>::AsyncCommitTransaction(SQLTransaction } #endif // TRINITY_DEBUG - TransactionFuture result = boost::asio::post(_ioContext->get_executor(), boost::asio::use_future([this, transaction, tracker = QueueSizeTracker(this)] + std::future<bool> result = boost::asio::post(_ioContext->get_executor(), boost::asio::use_future([this, transaction, tracker = QueueSizeTracker(this)] { T* conn = GetAsyncConnectionForCurrentThread(); return TransactionTask::Execute(conn, transaction); diff --git a/src/server/database/Database/DatabaseWorkerPool.h b/src/server/database/Database/DatabaseWorkerPool.h index 70c7a022510..5bd3320f0ac 100644 --- a/src/server/database/Database/DatabaseWorkerPool.h +++ b/src/server/database/Database/DatabaseWorkerPool.h @@ -23,6 +23,7 @@ #include "DatabaseEnvFwd.h" #include "StringFormat.h" #include <array> +#include <atomic> #include <string> #include <vector> diff --git a/src/server/database/Database/MySQLConnection.h b/src/server/database/Database/MySQLConnection.h index df42cd3a342..db8ff40a2ab 100644 --- a/src/server/database/Database/MySQLConnection.h +++ b/src/server/database/Database/MySQLConnection.h @@ -24,6 +24,7 @@ #include <memory> #include <mutex> #include <string> +#include <thread> #include <vector> class MySQLPreparedStatement; diff --git a/src/server/database/Database/QueryCallback.cpp b/src/server/database/Database/QueryCallback.cpp index c8b3295fe39..f921eaa1e4d 100644 --- a/src/server/database/Database/QueryCallback.cpp +++ b/src/server/database/Database/QueryCallback.cpp @@ -200,7 +200,7 @@ bool QueryCallback::InvokeIfReady() { if (_string.valid() && _string.wait_for(std::chrono::seconds(0)) == std::future_status::ready) { - QueryResultFuture f(std::move(_string)); + std::future<QueryResult> f(std::move(_string)); std::function<void(QueryCallback&, QueryResult)> cb(std::move(callback._string)); cb(*this, f.get()); return checkStateAndReturnCompletion(); @@ -210,7 +210,7 @@ bool QueryCallback::InvokeIfReady() { if (_prepared.valid() && _prepared.wait_for(std::chrono::seconds(0)) == std::future_status::ready) { - PreparedQueryResultFuture f(std::move(_prepared)); + std::future<PreparedQueryResult> f(std::move(_prepared)); std::function<void(QueryCallback&, PreparedQueryResult)> cb(std::move(callback._prepared)); cb(*this, f.get()); return checkStateAndReturnCompletion(); diff --git a/src/server/database/Database/QueryCallback.h b/src/server/database/Database/QueryCallback.h index f788cc41baa..bb3cc64559d 100644 --- a/src/server/database/Database/QueryCallback.h +++ b/src/server/database/Database/QueryCallback.h @@ -21,14 +21,15 @@ #include "DatabaseEnvFwd.h" #include "Define.h" #include <functional> +#include <future> #include <list> #include <queue> class TC_DATABASE_API QueryCallback { public: - explicit QueryCallback(QueryResultFuture&& result); - explicit QueryCallback(PreparedQueryResultFuture&& result); + explicit QueryCallback(std::future<QueryResult>&& result); + explicit QueryCallback(std::future<PreparedQueryResult>&& result); QueryCallback(QueryCallback&& right) noexcept; QueryCallback& operator=(QueryCallback&& right) noexcept; ~QueryCallback(); @@ -55,8 +56,8 @@ private: union { - QueryResultFuture _string; - PreparedQueryResultFuture _prepared; + std::future<QueryResult> _string; + std::future<PreparedQueryResult> _prepared; }; bool _isPrepared; diff --git a/src/server/database/Database/QueryHolder.h b/src/server/database/Database/QueryHolder.h index e63fe4add66..a0a0b2b2d0f 100644 --- a/src/server/database/Database/QueryHolder.h +++ b/src/server/database/Database/QueryHolder.h @@ -20,6 +20,7 @@ #include "Define.h" #include "DatabaseEnvFwd.h" +#include <future> #include <vector> class MySQLConnection; @@ -59,7 +60,7 @@ public: class TC_DATABASE_API SQLQueryHolderCallback { public: - SQLQueryHolderCallback(std::shared_ptr<SQLQueryHolderBase>&& holder, QueryResultHolderFuture&& future) + SQLQueryHolderCallback(std::shared_ptr<SQLQueryHolderBase>&& holder, std::future<void>&& future) : m_holder(std::move(holder)), m_future(std::move(future)) { } SQLQueryHolderCallback(SQLQueryHolderCallback&&) = default; @@ -74,7 +75,7 @@ public: bool InvokeIfReady(); std::shared_ptr<SQLQueryHolderBase> m_holder; - QueryResultHolderFuture m_future; + std::future<void> m_future; std::function<void(SQLQueryHolderBase const&)> m_callback; }; diff --git a/src/server/database/Database/Transaction.h b/src/server/database/Database/Transaction.h index f4dcb9fae34..c60b74b58b8 100644 --- a/src/server/database/Database/Transaction.h +++ b/src/server/database/Database/Transaction.h @@ -22,6 +22,7 @@ #include "DatabaseEnvFwd.h" #include "StringFormat.h" #include <functional> +#include <future> #include <mutex> #include <variant> #include <vector> @@ -100,7 +101,7 @@ private: class TC_DATABASE_API TransactionCallback { public: - TransactionCallback(TransactionFuture&& future) : m_future(std::move(future)) { } + TransactionCallback(std::future<bool>&& future) : m_future(std::move(future)) { } TransactionCallback(TransactionCallback&&) = default; TransactionCallback& operator=(TransactionCallback&&) = default; @@ -112,7 +113,7 @@ public: bool InvokeIfReady(); - TransactionFuture m_future; + std::future<bool> m_future; std::function<void(bool)> m_callback; }; diff --git a/src/server/database/Updater/UpdateFetcher.h b/src/server/database/Updater/UpdateFetcher.h index 69f4d4cdca9..3accf8e3a92 100644 --- a/src/server/database/Updater/UpdateFetcher.h +++ b/src/server/database/Updater/UpdateFetcher.h @@ -20,6 +20,7 @@ #include "Define.h" #include "DatabaseEnvFwd.h" +#include <functional> #include <set> #include <string> #include <unordered_map> diff --git a/src/server/game/Accounts/AccountMgr.h b/src/server/game/Accounts/AccountMgr.h index ce881bd49a9..24c3379469f 100644 --- a/src/server/game/Accounts/AccountMgr.h +++ b/src/server/game/Accounts/AccountMgr.h @@ -19,6 +19,7 @@ #define _ACCMGR_H #include "RBAC.h" +#include <functional> enum class AccountOpResult : uint8 { diff --git a/src/server/game/Globals/ObjectAccessor.cpp b/src/server/game/Globals/ObjectAccessor.cpp index 35160618084..23d522cb1bc 100644 --- a/src/server/game/Globals/ObjectAccessor.cpp +++ b/src/server/game/Globals/ObjectAccessor.cpp @@ -27,6 +27,7 @@ #include "Pet.h" #include "Player.h" #include "Transport.h" +#include <mutex> template<class T> void HashMapHolder<T>::Insert(T* o) diff --git a/src/server/game/Globals/ObjectMgr.h b/src/server/game/Globals/ObjectMgr.h index f480829e880..adc1dde5dc8 100644 --- a/src/server/game/Globals/ObjectMgr.h +++ b/src/server/game/Globals/ObjectMgr.h @@ -37,6 +37,7 @@ #include "Trainer.h" #include "VehicleDefines.h" #include "UniqueTrackablePtr.h" +#include <atomic> #include <iterator> #include <map> #include <unordered_map> diff --git a/src/server/game/Server/WorldSession.h b/src/server/game/Server/WorldSession.h index 4c148b32055..bacbac65468 100644 --- a/src/server/game/Server/WorldSession.h +++ b/src/server/game/Server/WorldSession.h @@ -36,6 +36,7 @@ #include "SharedDefines.h" #include <boost/circular_buffer_fwd.hpp> #include <array> +#include <atomic> #include <map> #include <memory> #include <unordered_map> |