123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269 |
- //
- // Copyright (c) 2019-2023 Ruben Perez Hidalgo (rubenperez038 at gmail dot com)
- //
- // Distributed under the Boost Software License, Version 1.0. (See accompanying
- // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
- //
- #ifndef BHO_MYSQL_IMPL_NETWORK_ALGORITHMS_IPP
- #define BHO_MYSQL_IMPL_NETWORK_ALGORITHMS_IPP
- #pragma once
- #include <asio2/bho/mysql/detail/network_algorithms.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/close_connection.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/close_statement.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/connect.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/execute.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/handshake.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/ping.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/prepare_statement.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/quit_connection.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/read_resultset_head.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/read_some_rows.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/read_some_rows_dynamic.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/reset_connection.hpp>
- #include <asio2/bho/mysql/impl/internal/network_algorithms/start_execution.hpp>
- void bho::mysql::detail::connect_erased(
- channel& chan,
- const void* endpoint,
- const handshake_params& params,
- error_code& err,
- diagnostics& diag
- )
- {
- connect_impl(chan, endpoint, params, err, diag);
- }
- void bho::mysql::detail::async_connect_erased(
- channel& chan,
- const void* endpoint,
- const handshake_params& params,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_connect_impl(chan, endpoint, params, diag, std::move(handler));
- }
- void bho::mysql::detail::handshake_erased(
- channel& channel,
- const handshake_params& params,
- error_code& err,
- diagnostics& diag
- )
- {
- handshake_impl(channel, params, err, diag);
- }
- void bho::mysql::detail::async_handshake_erased(
- channel& chan,
- const handshake_params& params,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_handshake_impl(chan, params, diag, std::move(handler));
- }
- void bho::mysql::detail::execute_erased(
- channel& channel,
- const any_execution_request& req,
- execution_processor& output,
- error_code& err,
- diagnostics& diag
- )
- {
- execute_impl(channel, req, output, err, diag);
- }
- void bho::mysql::detail::async_execute_erased(
- channel& chan,
- const any_execution_request& req,
- execution_processor& output,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_execute_impl(chan, req, output, diag, std::move(handler));
- }
- void bho::mysql::detail::start_execution_erased(
- channel& channel,
- const any_execution_request& req,
- execution_processor& proc,
- error_code& err,
- diagnostics& diag
- )
- {
- start_execution_impl(channel, req, proc, err, diag);
- }
- void bho::mysql::detail::async_start_execution_erased(
- channel& channel,
- const any_execution_request& req,
- execution_processor& proc,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_start_execution_impl(channel, req, proc, diag, std::move(handler));
- }
- bho::mysql::statement bho::mysql::detail::prepare_statement_erased(
- channel& chan,
- string_view stmt,
- error_code& err,
- diagnostics& diag
- )
- {
- return prepare_statement_impl(chan, stmt, err, diag);
- }
- void bho::mysql::detail::async_prepare_statement_erased(
- channel& chan,
- string_view stmt,
- diagnostics& diag,
- any_handler<statement> handler
- )
- {
- async_prepare_statement_impl(chan, stmt, diag, std::move(handler));
- }
- void bho::mysql::detail::close_statement_erased(
- channel& chan,
- const statement& stmt,
- error_code& err,
- diagnostics& diag
- )
- {
- close_statement_impl(chan, stmt, err, diag);
- }
- void bho::mysql::detail::async_close_statement_erased(
- channel& chan,
- const statement& stmt,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_close_statement_impl(chan, stmt, diag, std::move(handler));
- }
- bho::mysql::rows_view bho::mysql::detail::read_some_rows_dynamic_erased(
- channel& chan,
- execution_state_impl& st,
- error_code& err,
- diagnostics& diag
- )
- {
- return read_some_rows_dynamic_impl(chan, st, err, diag);
- }
- void bho::mysql::detail::async_read_some_rows_dynamic_erased(
- channel& chan,
- execution_state_impl& st,
- diagnostics& diag,
- any_handler<rows_view> handler
- )
- {
- async_read_some_rows_dynamic_impl(chan, st, diag, std::move(handler));
- }
- std::size_t bho::mysql::detail::read_some_rows_static_erased(
- channel& chan,
- execution_processor& proc,
- const output_ref& output,
- error_code& err,
- diagnostics& diag
- )
- {
- return read_some_rows_impl(chan, proc, output, err, diag);
- }
- void bho::mysql::detail::async_read_some_rows_erased(
- channel& chan,
- execution_processor& proc,
- const output_ref& output,
- diagnostics& diag,
- any_handler<std::size_t> handler
- )
- {
- async_read_some_rows_impl(chan, proc, output, diag, std::move(handler));
- }
- void bho::mysql::detail::read_resultset_head_erased(
- channel& channel,
- execution_processor& proc,
- error_code& err,
- diagnostics& diag
- )
- {
- read_resultset_head_impl(channel, proc, err, diag);
- }
- void bho::mysql::detail::async_read_resultset_head_erased(
- channel& chan,
- execution_processor& proc,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_read_resultset_head_impl(chan, proc, diag, std::move(handler));
- }
- void bho::mysql::detail::ping_erased(channel& chan, error_code& code, diagnostics& diag)
- {
- ping_impl(chan, code, diag);
- }
- void bho::mysql::detail::async_ping_erased(channel& chan, diagnostics& diag, any_void_handler handler)
- {
- async_ping_impl(chan, diag, std::move(handler));
- }
- void bho::mysql::detail::reset_connection_erased(channel& chan, error_code& code, diagnostics& diag)
- {
- reset_connection_impl(chan, code, diag);
- }
- void bho::mysql::detail::async_reset_connection_erased(
- channel& chan,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_reset_connection_impl(chan, diag, std::move(handler));
- }
- void bho::mysql::detail::close_connection_erased(channel& chan, error_code& code, diagnostics& diag)
- {
- close_connection_impl(chan, code, diag);
- }
- void bho::mysql::detail::async_close_connection_erased(
- channel& chan,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_close_connection_impl(chan, diag, std::move(handler));
- }
- void bho::mysql::detail::quit_connection_erased(channel& chan, error_code& err, diagnostics& diag)
- {
- quit_connection_impl(chan, err, diag);
- }
- void bho::mysql::detail::async_quit_connection_erased(
- channel& chan,
- diagnostics& diag,
- any_void_handler handler
- )
- {
- async_quit_connection_impl(chan, diag, std::move(handler));
- }
- #endif
|