117 		conn->current_result->m.free_result(conn->current_result, TRUE);  in MYSQLND_METHOD()
122 		conn->net->data->m.free_contents(conn->net);  in MYSQLND_METHOD()
188 	conn->m->free_contents(conn);  in MYSQLND_METHOD_PRIVATE()
189 	conn->m->free_options(conn);  in MYSQLND_METHOD_PRIVATE()
225 			MYSQLND_PACKET_OK * ok_response = conn->protocol->m.get_ok_packet(conn->protocol, FALSE);  in MYSQLND_METHOD()
271 			MYSQLND_PACKET_EOF * ok_response = conn->protocol->m.get_eof_packet(conn->protocol, FALSE);  in MYSQLND_METHOD()
341 	cmd_packet = conn->protocol->m.get_command_packet(conn->protocol, FALSE);  in MYSQLND_METHOD()
361 		conn->m->send_close(conn);  in MYSQLND_METHOD()
380 …ret = conn->m->simple_command_send_request(conn, command, arg, arg_len, silent, ignore_upsert_stat…  in MYSQLND_METHOD()
382 …ret = conn->m->simple_command_handle_response(conn, ok_packet, silent, command, ignore_upsert_stat…  in MYSQLND_METHOD()
399 	if (PASS == conn->m->local_tx_start(conn, this_func)) {  in MYSQLND_METHOD()
402 …ret = conn->m->simple_command(conn, COM_SET_OPTION, buffer, sizeof(buffer), PROT_EOF_PACKET, FALSE…  in MYSQLND_METHOD()
404 		conn->m->local_tx_end(conn, this_func, ret);  in MYSQLND_METHOD()
476 	auth_packet = conn->protocol->m.get_auth_packet(conn->protocol, FALSE);  in mysqlnd_switch_to_ssl_if_needed()
506 …conn->net->data->m.set_client_option(conn->net, MYSQL_OPT_SSL_VERIFY_SERVER_CERT, (const char *) &…  in mysqlnd_switch_to_ssl_if_needed()
508 			if (FAIL == conn->net->data->m.enable_ssl(conn->net)) {  in mysqlnd_switch_to_ssl_if_needed()
526 	conn->m->send_close(conn);  in mysqlnd_switch_to_ssl_if_needed()
596 …struct st_mysqlnd_authentication_plugin * auth_plugin = conn->m->fetch_auth_plugin_by_name(request…  in mysqlnd_run_authentication()
672 		conn->m->set_client_option(conn, MYSQLND_OPT_AUTH_PROTOCOL, requested_protocol);  in mysqlnd_run_authentication()
728 				if (PASS != conn->m->query(conn, command, strlen(command))) {  in MYSQLND_METHOD()
734 					MYSQLND_RES * result = conn->m->use_result(conn, 0);  in MYSQLND_METHOD()
736 						result->m.free_result(result, TRUE);  in MYSQLND_METHOD()
798 	greet_packet = conn->protocol->m.get_greet_packet(conn->protocol, FALSE);  in MYSQLND_METHOD()
804 	if (FAIL == net->data->m.connect_ex(conn->net, conn->scheme, conn->scheme_len, conn->persistent,  in MYSQLND_METHOD()
810 	DBG_INF_FMT("stream=%p", net->data->m.get_stream(net));  in MYSQLND_METHOD()
889 	if (PASS != conn->m->local_tx_start(conn, this_func)) {
907 			conn->m->send_close(conn);
910 		conn->m->free_contents(conn);
930 		conn->m->set_client_option(conn, MYSQLND_OPT_MAX_ALLOWED_PACKET, (char *)&max_allowed_size);
994 	mysql_flags = conn->m->get_updated_connect_flags(conn, mysql_flags);
996 …if (FAIL == conn->m->connect_handshake(conn, host, user, passwd, passwd_len, db, db_len, mysql_fla…
1080 		if (FAIL == conn->m->execute_init_commands(conn)) {
1094 		conn->m->local_tx_end(conn, this_func, PASS);
1106 	conn->m->free_contents(conn);
1109 		conn->m->local_tx_end(conn, this_func, FAIL);
1134 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1136 …ret = conn->m->connect(conn, host, user, passwd, passwd_len, db, db_len, port, socket_or_pipe, mys…
1138 		conn->m->local_tx_end(conn, this_func, FAIL);
1170 …ret = conn_handle->m->connect(conn_handle, host, user, passwd, passwd_len, db, db_len, port, socke…
1178 			conn_handle->m->dtor(conn_handle);
1200 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1201 …if (PASS == conn->m->send_query(conn, query, query_len, MYSQLND_SEND_QUERY_IMPLICIT, NULL, NULL) &&
1202 			PASS == conn->m->reap_query(conn, MYSQLND_REAP_RESULT_IMPLICIT))
1209 		conn->m->local_tx_end(conn, this_func, ret);
1227 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1228 		ret = conn->m->simple_command(conn, COM_QUERY, (zend_uchar *) query, query_len,
1234 		conn->m->local_tx_end(conn, this_func, ret);
1253 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1259 		ret = conn->m->query_read_result_set_header(conn, NULL);
1261 		conn->m->local_tx_end(conn, this_func, ret);
1320 		stream = (*p)->data->net->data->m.get_stream((*p)->data->net);
1350 		stream = (*fwd)->data->net->data->m.get_stream((*fwd)->data->net);
1375 #define php_select(m, r, w, e, t)	select(m, r, w, e, t)  argument
1478 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1495 			if (PASS != conn->m->simple_command(conn, COM_FIELD_LIST, buff, p - buff,
1498 				conn->m->local_tx_end(conn, 0, FAIL);
1506 			result = conn->m->result_init(5000, conn->persistent);
1511 			if (FAIL == result->m.read_result_metadata(result, conn)) {
1513 				result->m.free_result(result, TRUE);
1523 				result->m.free_result(result, TRUE);
1529 		conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS);
1549 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1564 		if (PASS == conn->m->query(conn, show_query, show_query_len)) {
1565 			result = conn->m->store_result(conn, MYSQLND_STORE_NO_COPY);
1570 		conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS);
1624 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1625 		ret = (PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_KEY, key) &&
1626 			PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_CERT, cert) &&
1627 			PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_CA, ca) &&
1628 			PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_CAPATH, capath) &&
1629 			PASS == net->data->m.set_client_option(net, MYSQLND_OPT_SSL_CIPHER, cipher)) ? PASS : FAIL;
1631 		conn->m->local_tx_end(conn, this_func, ret);
1647 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1654 		conn->m->local_tx_end(conn, this_func, PASS);
1669 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1670 		ret = conn->m->simple_command(conn, COM_DEBUG, NULL, 0, PROT_EOF_PACKET, FALSE, TRUE);
1672 		conn->m->local_tx_end(conn, this_func, ret);
1690 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1691 …ret = conn->m->simple_command(conn, COM_INIT_DB, (zend_uchar*) db, db_len, PROT_OK_PACKET, FALSE, …
1709 		conn->m->local_tx_end(conn, this_func, ret);
1726 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1727 		ret = conn->m->simple_command(conn, COM_PING, NULL, 0, PROT_OK_PACKET, TRUE, TRUE);
1734 		conn->m->local_tx_end(conn, this_func, ret);
1753 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1755 			ret = conn->m->simple_command(conn, COM_STATISTICS, NULL, 0, PROT_LAST, FALSE, TRUE);
1759 			stats_header = conn->protocol->m.get_stats_packet(conn->protocol, FALSE);
1773 		conn->m->local_tx_end(conn, this_func, ret);
1791 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1796 			ret = conn->m->simple_command(conn, COM_PROCESS_KILL, buff, 4, PROT_OK_PACKET, FALSE, TRUE);
1802 …} else if (PASS == (ret = conn->m->simple_command(conn, COM_PROCESS_KILL, buff, 4, PROT_LAST, FALS…
1804 			conn->m->send_close(conn);
1807 		conn->m->local_tx_end(conn, this_func, ret);
1831 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1835 		if (FAIL == (ret = conn->m->query(conn, query, query_len))) {
1844 		conn->m->local_tx_end(conn, this_func, ret);
1863 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1866 		ret = conn->m->simple_command(conn, COM_REFRESH, bits, 1, PROT_OK_PACKET, FALSE, TRUE);
1868 		conn->m->local_tx_end(conn, this_func, ret);
1885 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
1888 		ret = conn->m->simple_command(conn, COM_SHUTDOWN, bits, 1, PROT_OK_PACKET, FALSE, TRUE);
1890 		conn->m->local_tx_end(conn, this_func, ret);
1903 	php_stream * net_stream = net->data->m.get_stream(net);
1921 				ret = conn->m->simple_command(conn, COM_QUIT, NULL, 0, PROT_LAST, TRUE, TRUE);
1922 				net->data->m.close_stream(net, conn->stats, conn->error_info);
1952 			net->data->m.close_stream(net, conn->stats, conn->error_info);
1986 		ret = conn->m->send_close(conn);
1987 		conn->m->dtor(conn);
2173 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
2185 			if (FAIL == (ret = conn->m->query_read_result_set_header(conn, NULL))) {
2194 					conn->m->send_close(conn);
2204 		conn->m->local_tx_end(conn, this_func, ret);
2282 	if (PASS != conn->m->local_tx_start(conn, this_func)) {
2308 	conn->m->local_tx_end(conn, this_func, ret);
2328 	if (PASS != conn->m->local_tx_start(conn, this_func)) {
2347 			ret = conn->net->data->m.set_client_option(conn->net, option, value);
2475 	conn->m->local_tx_end(conn, this_func, ret);
2479 	conn->m->local_tx_end(conn, this_func, FAIL);
2499 	if (PASS != conn->m->local_tx_start(conn, this_func)) {
2522 	conn->m->local_tx_end(conn, this_func, ret);
2526 	conn->m->local_tx_end(conn, this_func, FAIL);
2543 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
2558 			conn->current_result->conn = conn->m->get_reference(conn);
2559 			result = conn->current_result->m.use_result(conn->current_result, FALSE);
2562 				conn->current_result->m.free_result(conn->current_result, TRUE);
2567 		conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS);
2585 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
2602 			if ((conn->m->get_client_api_capabilities(conn) & MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA)) {
2618 			result = conn->current_result->m.store_result(conn->current_result, conn, f);
2620 				conn->current_result->m.free_result(conn->current_result, TRUE);
2625 		conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS);
2652 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
2653 …ret = conn->m->query(conn, (mode) ? "SET AUTOCOMMIT=1":"SET AUTOCOMMIT=0", sizeof("SET AUTOCOMMIT=…
2654 		conn->m->local_tx_end(conn, this_func, ret);
2666 	return conn->m->tx_commit_or_rollback(conn, TRUE, TRANS_COR_NO_OPT, NULL);
2675 	return conn->m->tx_commit_or_rollback(conn, FALSE, TRANS_COR_NO_OPT, NULL);
2763 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
2766 			conn->m->tx_cor_options_to_string(conn, &tmp_str, flags);
2787 				ret = conn->m->query(conn, query, query_len);
2791 		conn->m->local_tx_end(conn, this_func, ret);
2807 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
2817 				zend_ulong server_version = conn->m->get_server_version(conn);
2849 				ret = conn->m->query(conn, query, query_len);
2853 		conn->m->local_tx_end(conn, this_func, ret);
2869 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
2882 			ret = conn->m->query(conn, query, query_len);
2885 		conn->m->local_tx_end(conn, this_func, ret);
2901 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
2914 			ret = conn->m->query(conn, query, query_len);
2917 		conn->m->local_tx_end(conn, this_func, ret);
3105 	conn->data->m->free_reference(conn->data);
3125 	if (PASS == conn->m->local_tx_start(conn, this_func)) {
3139 		ret = conn->m->send_close(conn);
3142 		conn->m->local_tx_end(conn, this_func, ret);
3144 		conn_handle->m->dtor(conn_handle);
3167 		ret->data->m->negotiate_client_api_capabilities(ret->data, flags);

Last Index update Mon Sep 30 18:07:01 UTC 2024

Dedicated to & Maintained by Room-11