Home
last modified time | relevance | path

Searched refs:xpl (Results 76 – 100 of 1460) sorted by relevance

12345678910>>...59

/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/x/src/
H A Dsql_data_result.cc35 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 Dadmin_cmd_handler.cc80 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 Dxpl_session.cc51 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 Dsql_data_result.cc35 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 Dadmin_cmd_handler.cc80 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 Dxpl_session.cc51 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 Dsql_data_result.cc35 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 Dadmin_cmd_handler.cc80 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 Dxpl_session.cc51 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 Dclient.cc80 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 Dserver_client_timeout.cc32 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 Dclient_list.cc49 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 Dsystem_variable_compression_algorithms.test6 --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 Dserver_factory.cc32 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 Dclient_session.h40 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 Dclient_list.h42 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 Dsocket_acceptors_task.h40 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 Dbankinfoplugin.c179 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 Dstatus_variables.cc42 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 Dadmin_cmd_handler.cc80 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 Dxpl_session.cc51 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 Dadmin_cmd_handler.cc80 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 Dxpl_session.cc51 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 Dadmin_cmd_handler.cc80 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 Dxpl_session.cc51 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 …]

12345678910>>...59