/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/x/src/ |
H A D | sql_data_result.cc | 35 void xpl::Sql_data_result::disable_binlog() in disable_binlog() 43 void xpl::Sql_data_result::restore_binlog() in restore_binlog() 48 void xpl::Sql_data_result::query(const ngs::PFS_string &query) in query() 65 void xpl::Sql_data_result::get_next_field(long &value) in get_next_field() 73 void xpl::Sql_data_result::get_next_field(bool &value) in get_next_field() 81 void xpl::Sql_data_result::get_next_field(std::string &value) in get_next_field() 110 void xpl::Sql_data_result::get_next_field(char * &value) in get_next_field() 123 long xpl::Sql_data_result::statement_warn_count() in statement_warn_count() 129 xpl::Sql_data_result::Field_value *xpl::Sql_data_result::get_value() in get_value() 137 bool xpl::Sql_data_result::next_row() in next_row() [all …]
|
H A D | admin_cmd_handler.cc | 80 const xpl::Admin_command_handler::Command_handler xpl::Admin_command_handler::m_command_handler; 183 ngs::shared_ptr<xpl::Session> session(ngs::static_pointer_cast<xpl::Session>(client->session())); in get_client_data() 311 xpl::Query_string_builder qb; in create_collection_impl() 498 xpl::Query_string_builder qb; in remove_nonvirtual_column_names() 545 xpl::Query_string_builder qb; in index_on_virtual_column_supported() 586 xpl::Query_string_builder qb; in table_column_exists() 876 xpl::Query_string_builder qb; in get_index_virtual_column_names() 1117 xpl::Query_string_builder qb; in is_schema_selected_and_exists() 1129 xpl::Sql_data_result result(da); in get_system_variable() 1239 xpl::Query_string_builder qb; in is_collection() [all …]
|
H A D | xpl_session.cc | 51 xpl::Session::~Session() in ~Session() 61 bool xpl::Session::handle_ready_message(ngs::Request &command) in handle_ready_message() 96 ngs::Error_code xpl::Session::init() in init() 105 void xpl::Session::on_kill() in on_kill() 117 void xpl::Session::on_auth_success(const ngs::Authentication_handler::Response &response) in on_auth_success() 119 xpl::notices::send_client_id(proto(), m_client.client_id_num()); in on_auth_success() 129 void xpl::Session::on_auth_failure(const ngs::Authentication_handler::Response &response) in on_auth_failure() 143 void xpl::Session::mark_as_tls_session() in mark_as_tls_session() 149 bool xpl::Session::is_handled_by(const void *handler) const in is_handled_by() 159 bool xpl::Session::can_see_user(const std::string &user) const in can_see_user() [all …]
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/x/src/ |
H A D | sql_data_result.cc | 35 void xpl::Sql_data_result::disable_binlog() in disable_binlog() 43 void xpl::Sql_data_result::restore_binlog() in restore_binlog() 48 void xpl::Sql_data_result::query(const ngs::PFS_string &query) in query() 65 void xpl::Sql_data_result::get_next_field(long &value) in get_next_field() 73 void xpl::Sql_data_result::get_next_field(bool &value) in get_next_field() 81 void xpl::Sql_data_result::get_next_field(std::string &value) in get_next_field() 110 void xpl::Sql_data_result::get_next_field(char * &value) in get_next_field() 123 long xpl::Sql_data_result::statement_warn_count() in statement_warn_count() 129 xpl::Sql_data_result::Field_value *xpl::Sql_data_result::get_value() in get_value() 137 bool xpl::Sql_data_result::next_row() in next_row() [all …]
|
H A D | admin_cmd_handler.cc | 80 const xpl::Admin_command_handler::Command_handler xpl::Admin_command_handler::m_command_handler; 183 ngs::shared_ptr<xpl::Session> session(ngs::static_pointer_cast<xpl::Session>(client->session())); in get_client_data() 311 xpl::Query_string_builder qb; in create_collection_impl() 498 xpl::Query_string_builder qb; in remove_nonvirtual_column_names() 545 xpl::Query_string_builder qb; in index_on_virtual_column_supported() 586 xpl::Query_string_builder qb; in table_column_exists() 876 xpl::Query_string_builder qb; in get_index_virtual_column_names() 1117 xpl::Query_string_builder qb; in is_schema_selected_and_exists() 1129 xpl::Sql_data_result result(da); in get_system_variable() 1239 xpl::Query_string_builder qb; in is_collection() [all …]
|
H A D | xpl_session.cc | 51 xpl::Session::~Session() in ~Session() 61 bool xpl::Session::handle_ready_message(ngs::Request &command) in handle_ready_message() 96 ngs::Error_code xpl::Session::init() in init() 105 void xpl::Session::on_kill() in on_kill() 117 void xpl::Session::on_auth_success(const ngs::Authentication_handler::Response &response) in on_auth_success() 119 xpl::notices::send_client_id(proto(), m_client.client_id_num()); in on_auth_success() 129 void xpl::Session::on_auth_failure(const ngs::Authentication_handler::Response &response) in on_auth_failure() 143 void xpl::Session::mark_as_tls_session() in mark_as_tls_session() 149 bool xpl::Session::is_handled_by(const void *handler) const in is_handled_by() 159 bool xpl::Session::can_see_user(const std::string &user) const in can_see_user() [all …]
|
/dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/x/src/ |
H A D | sql_data_result.cc | 35 void xpl::Sql_data_result::disable_binlog() in disable_binlog() 43 void xpl::Sql_data_result::restore_binlog() in restore_binlog() 48 void xpl::Sql_data_result::query(const ngs::PFS_string &query) in query() 65 void xpl::Sql_data_result::get_next_field(long &value) in get_next_field() 73 void xpl::Sql_data_result::get_next_field(bool &value) in get_next_field() 81 void xpl::Sql_data_result::get_next_field(std::string &value) in get_next_field() 110 void xpl::Sql_data_result::get_next_field(char * &value) in get_next_field() 123 long xpl::Sql_data_result::statement_warn_count() in statement_warn_count() 129 xpl::Sql_data_result::Field_value *xpl::Sql_data_result::get_value() in get_value() 137 bool xpl::Sql_data_result::next_row() in next_row() [all …]
|
H A D | admin_cmd_handler.cc | 80 const xpl::Admin_command_handler::Command_handler xpl::Admin_command_handler::m_command_handler; 183 ngs::shared_ptr<xpl::Session> session(ngs::static_pointer_cast<xpl::Session>(client->session())); in get_client_data() 311 xpl::Query_string_builder qb; in create_collection_impl() 498 xpl::Query_string_builder qb; in remove_nonvirtual_column_names() 545 xpl::Query_string_builder qb; in index_on_virtual_column_supported() 586 xpl::Query_string_builder qb; in table_column_exists() 876 xpl::Query_string_builder qb; in get_index_virtual_column_names() 1117 xpl::Query_string_builder qb; in is_schema_selected_and_exists() 1129 xpl::Sql_data_result result(da); in get_system_variable() 1239 xpl::Query_string_builder qb; in is_collection() [all …]
|
H A D | xpl_session.cc | 51 xpl::Session::~Session() in ~Session() 61 bool xpl::Session::handle_ready_message(ngs::Request &command) in handle_ready_message() 96 ngs::Error_code xpl::Session::init() in init() 105 void xpl::Session::on_kill() in on_kill() 117 void xpl::Session::on_auth_success(const ngs::Authentication_handler::Response &response) in on_auth_success() 119 xpl::notices::send_client_id(proto(), m_client.client_id_num()); in on_auth_success() 129 void xpl::Session::on_auth_failure(const ngs::Authentication_handler::Response &response) in on_auth_failure() 143 void xpl::Session::mark_as_tls_session() in mark_as_tls_session() 149 bool xpl::Session::is_handled_by(const void *handler) const in is_handled_by() 159 bool xpl::Session::can_see_user(const std::string &user) const in can_see_user() [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/ngs/src/ |
H A D | client.cc | 80 xpl::iface::Protocol_monitor *pmon) in Client() 112 xpl::chrono::Time_point Client::get_accept_time() const { in get_accept_time() 144 std::vector<xpl::Capability_handler_ptr> handlers; in capabilities_configurator() 367 case xpl::Connection_tcpip: { in on_client_addr() 371 case xpl::Connection_namedpipe: in on_client_addr() 372 case xpl::Connection_unixsocket: // fall through in on_client_addr() 600 const xpl::Optional_value<int64_t> &level) { in configure_compression_opts() 608 std::shared_ptr<xpl::iface::Session> session( in create_session() 647 const xpl::Optional_value<int64_t> &level) const { in get_adjusted_compression_level() 648 using Variables = xpl::Plugin_system_variables; in get_adjusted_compression_level() [all …]
|
H A D | server_client_timeout.cc | 32 const xpl::chrono::Time_point &release_all_before_time) in Server_client_timeout() 36 std::shared_ptr<xpl::iface::Client> client) { in validate_client_state() 37 const xpl::chrono::Time_point client_accept_time = client->get_accept_time(); in validate_client_state() 38 const xpl::iface::Client::Client::State state = client->get_state(); in validate_client_state() 40 if (xpl::iface::Client::State::k_invalid == state || in validate_client_state() 41 xpl::iface::Client::State::k_accepted == state || in validate_client_state() 42 xpl::iface::Client::State::k_authenticating_first == state) { in validate_client_state() 50 if (!xpl::chrono::is_valid(m_oldest_client_accept_time) || in validate_client_state() 57 xpl::chrono::Time_point Server_client_timeout::get_oldest_client_accept_time() { in get_oldest_client_accept_time()
|
H A D | client_list.cc | 49 void Client_list::add(std::shared_ptr<xpl::iface::Client> client) { in add() 50 xpl::RWLock_writelock guard(&m_clients_lock); in add() 55 xpl::RWLock_writelock guard(&m_clients_lock); in remove() 61 std::shared_ptr<xpl::iface::Client> Client_list::find(uint64_t client_id) { in find() 62 xpl::RWLock_readlock guard(&m_clients_lock); in find() 65 std::list<std::shared_ptr<xpl::iface::Client>>::iterator i = in find() 68 if (m_clients.end() == i) return std::shared_ptr<xpl::iface::Client>(); in find() 74 xpl::RWLock_readlock guard(&m_clients_lock); in size() 80 std::vector<std::shared_ptr<xpl::iface::Client>> *result) { in get_all_clients() 81 xpl::RWLock_readlock guard(&m_clients_lock); in get_all_clients()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/mysql-test/suite/x/t/ |
H A D | system_variable_compression_algorithms.test | 6 --write_file $MYSQL_TMP_DIR/capabilities_compression_algorithm_get.xpl 17 --write_file $MYSQL_TMP_DIR/capabilities_compression_algorithm_set.xpl 61 --file=$MYSQL_TMP_DIR/capabilities_compression_algorithm_get.xpl 2>&1; 65 --file=$MYSQL_TMP_DIR/capabilities_compression_algorithm_set.xpl 2>&1 70 --file=$MYSQL_TMP_DIR/capabilities_compression_algorithm_set.xpl 2>&1 75 --file=$MYSQL_TMP_DIR/capabilities_compression_algorithm_set.xpl 2>&1 80 --file=$MYSQL_TMP_DIR/capabilities_compression_algorithm_set.xpl 2>&1 95 --file=$MYSQL_TMP_DIR/capabilities_compression_algorithm_set.xpl 2>&1 100 --file=$MYSQL_TMP_DIR/capabilities_compression_algorithm_set.xpl 2>&1 105 --file=$MYSQL_TMP_DIR/capabilities_compression_algorithm_set.xpl 2>&1 [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/src/server/ |
H A D | server_factory.cc | 32 namespace xpl { namespace 35 xpl::iface::Server *server, Vio_interface_ptr connection) { in create_client() 36 std::shared_ptr<xpl::iface::Client> result; in create_client() 38 result = ngs::allocate_shared<xpl::Client>( in create_client() 40 ngs::allocate_object<xpl::Protocol_monitor>()); in create_client() 45 xpl::Server_factory::Session_interface_ptr Server_factory::create_session( in create_session() 46 xpl::iface::Client *client, xpl::iface::Protocol_encoder *proto, in create_session() 47 const xpl::iface::Session::Session_id session_id) { in create_session() 49 ngs::allocate_shared<xpl::Session>(client, proto, session_id)); in create_session()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/ngs/include/ngs/ |
H A D | client_session.h | 40 class Session : public xpl::iface::Session { 44 Session(xpl::iface::Client *client, xpl::iface::Protocol_encoder *proto, 53 const xpl::iface::Authentication::Response &response) override; 55 const xpl::iface::Authentication::Response &response) override; 60 xpl::iface::Client &client() override { return *m_client; } in client() 61 const xpl::iface::Client &client() const override { return *m_client; } in client() 63 xpl::iface::Protocol_encoder &proto() override { return *m_encoder; } in proto() 64 void set_proto(xpl::iface::Protocol_encoder *encode) override; 82 xpl::iface::Client *m_client; 83 xpl::iface::Protocol_encoder *m_encoder; [all …]
|
H A D | client_list.h | 42 using Client_ptr = std::shared_ptr<xpl::iface::Client>; 45 xpl::Locked_container<Client_ptr_list, xpl::RWLock_writelock, 46 xpl::RWLock>; 53 void add(std::shared_ptr<xpl::iface::Client> client); 55 std::shared_ptr<xpl::iface::Client> find(const uint64_t client_id); 81 std::vector<std::shared_ptr<xpl::iface::Client>> *result); 87 xpl::RWLock m_clients_lock; 93 xpl::RWLock_readlock guard(&m_clients_lock); in enumerate() 101 xpl::RWLock_readlock guard(&m_clients_lock); in enumerate()
|
H A D | socket_acceptors_task.h | 40 class Socket_acceptors_task : public xpl::iface::Server_task { 42 using On_connection = xpl::iface::Listener::On_connection; 46 const xpl::iface::Listener_factory &listener_factory, 50 const std::shared_ptr<xpl::iface::Socket_events> &event); 61 using Listener_interfaces = std::vector<xpl::iface::Listener *>; 69 const xpl::iface::Listener_factory &m_listener_factory; 70 std::shared_ptr<xpl::iface::Socket_events> m_event; 75 std::vector<std::unique_ptr<xpl::iface::Listener>> m_tcp_socket; 76 std::unique_ptr<xpl::iface::Listener> m_unix_socket; 79 xpl::iface::Listener::Sync_variable_state m_time_and_event_state;
|
/dports/finance/aqbanking/aqbanking-6.2.10/src/libs/aqbanking/backendsupport/ |
H A D | bankinfoplugin.c | 179 AB_PLUGIN_BANKINFO *xpl; in AB_Plugin_BankInfo_new() local 194 AB_PLUGIN_BANKINFO *xpl; in AB_Plugin_BankInfo_FreeData() local 196 xpl=(AB_PLUGIN_BANKINFO *)p; in AB_Plugin_BankInfo_FreeData() 197 GWEN_FREE_OBJECT(xpl); in AB_Plugin_BankInfo_FreeData() 205 AB_PLUGIN_BANKINFO *xpl; in AB_Plugin_BankInfo_Factory() local 209 assert(xpl); in AB_Plugin_BankInfo_Factory() 211 assert(xpl->pluginFactoryFn); in AB_Plugin_BankInfo_Factory() 212 return xpl->pluginFactoryFn(pl, ab); in AB_Plugin_BankInfo_Factory() 220 AB_PLUGIN_BANKINFO *xpl; in AB_Plugin_BankInfo_SetFactoryFn() local 224 assert(xpl); in AB_Plugin_BankInfo_SetFactoryFn() [all …]
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/src/variables/ |
H A D | status_variables.cc | 42 namespace xpl { namespace 140 template <typename ReturnType, xpl::Global_status_variables::Variable 147 (xpl::Global_status_variables::instance().*variable).load(); in global_status_variable_server() 182 xpl::Global_status_variables::instance(); in common_status_variable() 371 xpl::Client::get_status_compression_algorithm), 378 xpl::Global_status_variables::m_closed_sessions_count), 386 xpl::Global_status_variables::m_accepted_sessions_count), 389 xpl::Global_status_variables::m_rejected_sessions_count), 392 xpl::Global_status_variables::m_killed_sessions_count), 395 xpl::Global_status_variables::m_closed_connections_count), [all …]
|
/dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/x/src/ |
H A D | admin_cmd_handler.cc | 80 const xpl::Admin_command_handler::Command_handler xpl::Admin_command_handler::m_command_handler; 183 ngs::shared_ptr<xpl::Session> session(ngs::static_pointer_cast<xpl::Session>(client->session())); in get_client_data() 311 xpl::Query_string_builder qb; in create_collection_impl() 498 xpl::Query_string_builder qb; in remove_nonvirtual_column_names() 545 xpl::Query_string_builder qb; in index_on_virtual_column_supported() 586 xpl::Query_string_builder qb; in table_column_exists() 876 xpl::Query_string_builder qb; in get_index_virtual_column_names() 1117 xpl::Query_string_builder qb; in is_schema_selected_and_exists() 1129 xpl::Sql_data_result result(da); in get_system_variable() 1239 xpl::Query_string_builder qb; in is_collection() [all …]
|
H A D | xpl_session.cc | 51 xpl::Session::~Session() in ~Session() 61 bool xpl::Session::handle_ready_message(ngs::Request &command) in handle_ready_message() 96 ngs::Error_code xpl::Session::init() in init() 105 void xpl::Session::on_kill() in on_kill() 117 void xpl::Session::on_auth_success(const ngs::Authentication_handler::Response &response) in on_auth_success() 119 xpl::notices::send_client_id(proto(), m_client.client_id_num()); in on_auth_success() 129 void xpl::Session::on_auth_failure(const ngs::Authentication_handler::Response &response) in on_auth_failure() 143 void xpl::Session::mark_as_tls_session() in mark_as_tls_session() 149 bool xpl::Session::is_handled_by(const void *handler) const in is_handled_by() 159 bool xpl::Session::can_see_user(const std::string &user) const in can_see_user() [all …]
|
/dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/x/src/ |
H A D | admin_cmd_handler.cc | 80 const xpl::Admin_command_handler::Command_handler xpl::Admin_command_handler::m_command_handler; 183 ngs::shared_ptr<xpl::Session> session(ngs::static_pointer_cast<xpl::Session>(client->session())); in get_client_data() 311 xpl::Query_string_builder qb; in create_collection_impl() 498 xpl::Query_string_builder qb; in remove_nonvirtual_column_names() 545 xpl::Query_string_builder qb; in index_on_virtual_column_supported() 586 xpl::Query_string_builder qb; in table_column_exists() 876 xpl::Query_string_builder qb; in get_index_virtual_column_names() 1117 xpl::Query_string_builder qb; in is_schema_selected_and_exists() 1129 xpl::Sql_data_result result(da); in get_system_variable() 1239 xpl::Query_string_builder qb; in is_collection() [all …]
|
H A D | xpl_session.cc | 51 xpl::Session::~Session() in ~Session() 61 bool xpl::Session::handle_ready_message(ngs::Request &command) in handle_ready_message() 96 ngs::Error_code xpl::Session::init() in init() 105 void xpl::Session::on_kill() in on_kill() 117 void xpl::Session::on_auth_success(const ngs::Authentication_handler::Response &response) in on_auth_success() 119 xpl::notices::send_client_id(proto(), m_client.client_id_num()); in on_auth_success() 129 void xpl::Session::on_auth_failure(const ngs::Authentication_handler::Response &response) in on_auth_failure() 143 void xpl::Session::mark_as_tls_session() in mark_as_tls_session() 149 bool xpl::Session::is_handled_by(const void *handler) const in is_handled_by() 159 bool xpl::Session::can_see_user(const std::string &user) const in can_see_user() [all …]
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/x/src/ |
H A D | admin_cmd_handler.cc | 80 const xpl::Admin_command_handler::Command_handler xpl::Admin_command_handler::m_command_handler; 183 ngs::shared_ptr<xpl::Session> session(ngs::static_pointer_cast<xpl::Session>(client->session())); in get_client_data() 311 xpl::Query_string_builder qb; in create_collection_impl() 498 xpl::Query_string_builder qb; in remove_nonvirtual_column_names() 545 xpl::Query_string_builder qb; in index_on_virtual_column_supported() 586 xpl::Query_string_builder qb; in table_column_exists() 876 xpl::Query_string_builder qb; in get_index_virtual_column_names() 1117 xpl::Query_string_builder qb; in is_schema_selected_and_exists() 1129 xpl::Sql_data_result result(da); in get_system_variable() 1239 xpl::Query_string_builder qb; in is_collection() [all …]
|
H A D | xpl_session.cc | 51 xpl::Session::~Session() in ~Session() 61 bool xpl::Session::handle_ready_message(ngs::Request &command) in handle_ready_message() 96 ngs::Error_code xpl::Session::init() in init() 105 void xpl::Session::on_kill() in on_kill() 117 void xpl::Session::on_auth_success(const ngs::Authentication_handler::Response &response) in on_auth_success() 119 xpl::notices::send_client_id(proto(), m_client.client_id_num()); in on_auth_success() 129 void xpl::Session::on_auth_failure(const ngs::Authentication_handler::Response &response) in on_auth_failure() 143 void xpl::Session::mark_as_tls_session() in mark_as_tls_session() 149 bool xpl::Session::is_handled_by(const void *handler) const in is_handled_by() 159 bool xpl::Session::can_see_user(const std::string &user) const in can_see_user() [all …]
|