conn 41 ext/mysqli/mysqli_api.c static void mysqli_tx_cor_options_to_string(const MYSQL * const conn, smart_str * str, const uint32_t mode) conn 112 ext/mysqli/mysqli_api.c static int mysqli_commit_or_rollback_libmysql(MYSQL * conn, zend_bool commit, const uint32_t mode, const char * const name) conn 116 ext/mysqli/mysqli_api.c mysqli_tx_cor_options_to_string(conn, &tmp_str, mode); conn 132 ext/mysqli/mysqli_api.c ret = mysql_real_query(conn, query, query_len); conn 39 ext/mysqli/mysqli_mysqlnd.h #define mysqli_stmt_get_connection(s) (s)->data->conn conn 1027 ext/mysqli/mysqli_nonapi.c static int mysqli_begin_transaction_libmysql(MYSQL * conn, const unsigned int mode, const char * const name) conn 1039 ext/mysqli/mysqli_nonapi.c if (mysql_get_server_version(conn) < 50605L) { conn 1067 ext/mysqli/mysqli_nonapi.c ret = mysql_real_query(conn, query, query_len); conn 1117 ext/mysqli/mysqli_nonapi.c static int mysqli_savepoint_libmysql(MYSQL * conn, const char * const name, zend_bool release) conn 1122 ext/mysqli/mysqli_nonapi.c ret = mysql_real_query(conn, query, query_len); conn 70 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, free_options)(MYSQLND_CONN_DATA * conn) conn 72 ext/mysqlnd/mysqlnd.c zend_bool pers = conn->persistent; conn 74 ext/mysqlnd/mysqlnd.c if (conn->options->charset_name) { conn 75 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->charset_name, pers); conn 76 ext/mysqlnd/mysqlnd.c conn->options->charset_name = NULL; conn 78 ext/mysqlnd/mysqlnd.c if (conn->options->auth_protocol) { conn 79 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->auth_protocol, pers); conn 80 ext/mysqlnd/mysqlnd.c conn->options->auth_protocol = NULL; conn 82 ext/mysqlnd/mysqlnd.c if (conn->options->num_commands) { conn 84 ext/mysqlnd/mysqlnd.c for (i = 0; i < conn->options->num_commands; i++) { conn 86 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->init_commands[i], pers); conn 88 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->init_commands, pers); conn 89 ext/mysqlnd/mysqlnd.c conn->options->init_commands = NULL; conn 91 ext/mysqlnd/mysqlnd.c if (conn->options->cfg_file) { conn 92 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->cfg_file, pers); conn 93 ext/mysqlnd/mysqlnd.c conn->options->cfg_file = NULL; conn 95 ext/mysqlnd/mysqlnd.c if (conn->options->cfg_section) { conn 96 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->cfg_section, pers); conn 97 ext/mysqlnd/mysqlnd.c conn->options->cfg_section = NULL; conn 99 ext/mysqlnd/mysqlnd.c if (conn->options->connect_attr) { conn 100 ext/mysqlnd/mysqlnd.c zend_hash_destroy(conn->options->connect_attr); conn 101 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->connect_attr, pers); conn 102 ext/mysqlnd/mysqlnd.c conn->options->connect_attr = NULL; conn 110 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, free_contents)(MYSQLND_CONN_DATA * conn) conn 112 ext/mysqlnd/mysqlnd.c zend_bool pers = conn->persistent; conn 116 ext/mysqlnd/mysqlnd.c if (conn->current_result) { conn 117 ext/mysqlnd/mysqlnd.c conn->current_result->m.free_result(conn->current_result, TRUE); conn 118 ext/mysqlnd/mysqlnd.c conn->current_result = NULL; conn 121 ext/mysqlnd/mysqlnd.c if (conn->net) { conn 122 ext/mysqlnd/mysqlnd.c conn->net->data->m.free_contents(conn->net); conn 127 ext/mysqlnd/mysqlnd.c if (conn->host) { conn 128 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->host, pers); conn 129 ext/mysqlnd/mysqlnd.c conn->host = NULL; conn 131 ext/mysqlnd/mysqlnd.c if (conn->user) { conn 132 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->user, pers); conn 133 ext/mysqlnd/mysqlnd.c conn->user = NULL; conn 135 ext/mysqlnd/mysqlnd.c if (conn->passwd) { conn 136 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->passwd, pers); conn 137 ext/mysqlnd/mysqlnd.c conn->passwd = NULL; conn 139 ext/mysqlnd/mysqlnd.c if (conn->connect_or_select_db) { conn 140 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->connect_or_select_db, pers); conn 141 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db = NULL; conn 143 ext/mysqlnd/mysqlnd.c if (conn->unix_socket) { conn 144 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->unix_socket, pers); conn 145 ext/mysqlnd/mysqlnd.c conn->unix_socket = NULL; conn 147 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("scheme=%s", conn->scheme); conn 148 ext/mysqlnd/mysqlnd.c if (conn->scheme) { conn 149 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->scheme, pers); conn 150 ext/mysqlnd/mysqlnd.c conn->scheme = NULL; conn 152 ext/mysqlnd/mysqlnd.c if (conn->server_version) { conn 153 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->server_version, pers); conn 154 ext/mysqlnd/mysqlnd.c conn->server_version = NULL; conn 156 ext/mysqlnd/mysqlnd.c if (conn->host_info) { conn 157 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->host_info, pers); conn 158 ext/mysqlnd/mysqlnd.c conn->host_info = NULL; conn 160 ext/mysqlnd/mysqlnd.c if (conn->auth_plugin_data) { conn 161 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->auth_plugin_data, pers); conn 162 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data = NULL; conn 164 ext/mysqlnd/mysqlnd.c if (conn->last_message) { conn 165 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->last_message, pers); conn 166 ext/mysqlnd/mysqlnd.c conn->last_message = NULL; conn 168 ext/mysqlnd/mysqlnd.c if (conn->error_info->error_list) { conn 169 ext/mysqlnd/mysqlnd.c zend_llist_clean(conn->error_info->error_list); conn 170 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->error_info->error_list, pers); conn 171 ext/mysqlnd/mysqlnd.c conn->error_info->error_list = NULL; conn 173 ext/mysqlnd/mysqlnd.c conn->charset = NULL; conn 174 ext/mysqlnd/mysqlnd.c conn->greet_charset = NULL; conn 183 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, dtor)(MYSQLND_CONN_DATA * conn) conn 186 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 188 ext/mysqlnd/mysqlnd.c conn->m->free_contents(conn); conn 189 ext/mysqlnd/mysqlnd.c conn->m->free_options(conn); conn 191 ext/mysqlnd/mysqlnd.c if (conn->net) { conn 192 ext/mysqlnd/mysqlnd.c mysqlnd_net_free(conn->net, conn->stats, conn->error_info); conn 193 ext/mysqlnd/mysqlnd.c conn->net = NULL; conn 196 ext/mysqlnd/mysqlnd.c if (conn->protocol) { conn 197 ext/mysqlnd/mysqlnd.c mysqlnd_protocol_free(conn->protocol); conn 198 ext/mysqlnd/mysqlnd.c conn->protocol = NULL; conn 201 ext/mysqlnd/mysqlnd.c if (conn->stats) { conn 202 ext/mysqlnd/mysqlnd.c mysqlnd_stats_end(conn->stats, conn->persistent); conn 205 ext/mysqlnd/mysqlnd.c mnd_pefree(conn, conn->persistent); conn 214 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, simple_command_handle_response)(MYSQLND_CONN_DATA * conn, enum mysqlnd_packet_type ok_packet, conn 225 ext/mysqlnd/mysqlnd.c MYSQLND_PACKET_OK * ok_response = conn->protocol->m.get_ok_packet(conn->protocol, FALSE); conn 227 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 230 ext/mysqlnd/mysqlnd.c if (FAIL == (ret = PACKET_READ(ok_response, conn))) { conn 240 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, ok_response->error_no, ok_response->sqlstate, ok_response->error); conn 251 ext/mysqlnd/mysqlnd.c conn->upsert_status->server_status &= ~SERVER_MORE_RESULTS_EXISTS; conn 252 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 254 ext/mysqlnd/mysqlnd.c SET_NEW_MESSAGE(conn->last_message, conn->last_message_len, conn 256 ext/mysqlnd/mysqlnd.c conn->persistent); conn 259 ext/mysqlnd/mysqlnd.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 260 ext/mysqlnd/mysqlnd.c conn->upsert_status->warning_count = ok_response->warning_count; conn 261 ext/mysqlnd/mysqlnd.c conn->upsert_status->server_status = ok_response->server_status; conn 262 ext/mysqlnd/mysqlnd.c conn->upsert_status->affected_rows = ok_response->affected_rows; conn 263 ext/mysqlnd/mysqlnd.c conn->upsert_status->last_insert_id = ok_response->last_insert_id; conn 271 ext/mysqlnd/mysqlnd.c MYSQLND_PACKET_EOF * ok_response = conn->protocol->m.get_eof_packet(conn->protocol, FALSE); conn 273 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 276 ext/mysqlnd/mysqlnd.c if (FAIL == (ret = PACKET_READ(ok_response, conn))) { conn 277 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_MALFORMED_PACKET, UNKNOWN_SQLSTATE, conn 286 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, ok_response->error_no, ok_response->sqlstate, ok_response->error); conn 287 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 289 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_MALFORMED_PACKET, UNKNOWN_SQLSTATE, "Malformed packet"); conn 302 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_MALFORMED_PACKET, UNKNOWN_SQLSTATE, "Malformed packet"); conn 314 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, simple_command_send_request)(MYSQLND_CONN_DATA * conn, enum php_mysqlnd_server_command command, conn 322 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 325 ext/mysqlnd/mysqlnd.c switch (CONN_GET_STATE(conn)) { conn 329 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); conn 333 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 334 ext/mysqlnd/mysqlnd.c DBG_ERR_FMT("Command out of sync. State=%u", CONN_GET_STATE(conn)); conn 338 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 339 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 341 ext/mysqlnd/mysqlnd.c cmd_packet = conn->protocol->m.get_command_packet(conn->protocol, FALSE); conn 343 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 353 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_COM_QUIT + command - 1 /* because of COM_SLEEP */ ); conn 355 ext/mysqlnd/mysqlnd.c if (! PACKET_WRITE(cmd_packet, conn)) { conn 360 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 361 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn); conn 373 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, simple_command)(MYSQLND_CONN_DATA * conn, enum php_mysqlnd_server_command command, conn 380 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command_send_request(conn, command, arg, arg_len, silent, ignore_upsert_status); conn 382 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command_handle_response(conn, ok_packet, silent, command, ignore_upsert_status); conn 393 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_server_option)(MYSQLND_CONN_DATA * const conn, enum_mysqlnd_server_option option) conn 399 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 402 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_SET_OPTION, buffer, sizeof(buffer), PROT_EOF_PACKET, FALSE, TRUE); conn 404 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 413 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, restart_psession)(MYSQLND_CONN_DATA * conn) conn 416 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CONNECT_REUSED); conn 418 ext/mysqlnd/mysqlnd.c if (conn->last_message) { conn 419 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->last_message, conn->persistent); conn 420 ext/mysqlnd/mysqlnd.c conn->last_message = NULL; conn 429 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, end_psession)(MYSQLND_CONN_DATA * conn) conn 440 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn, conn 476 ext/mysqlnd/mysqlnd.c auth_packet = conn->protocol->m.get_auth_packet(conn->protocol, FALSE); conn 478 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 502 ext/mysqlnd/mysqlnd.c if (!PACKET_WRITE(auth_packet, conn)) { conn 506 ext/mysqlnd/mysqlnd.c conn->net->data->m.set_client_option(conn->net, MYSQL_OPT_SSL_VERIFY_SERVER_CERT, (const char *) &verify); conn 508 ext/mysqlnd/mysqlnd.c if (FAIL == conn->net->data->m.enable_ssl(conn->net)) { conn 515 ext/mysqlnd/mysqlnd.c if (!PACKET_WRITE(auth_packet, conn)) { conn 525 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 526 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn); conn 527 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); conn 555 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn, conn 596 ext/mysqlnd/mysqlnd.c struct st_mysqlnd_authentication_plugin * auth_plugin = conn->m->fetch_auth_plugin_by_name(requested_protocol); conn 600 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, "The server requested authentication method unknown to the client"); conn 614 ext/mysqlnd/mysqlnd.c if (conn->auth_plugin_data) { conn 615 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->auth_plugin_data, conn->persistent); conn 616 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data = NULL; conn 618 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data_len = plugin_data_len; conn 619 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data = mnd_pemalloc(conn->auth_plugin_data_len, conn->persistent); conn 620 ext/mysqlnd/mysqlnd.c if (!conn->auth_plugin_data) { conn 621 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 624 ext/mysqlnd/mysqlnd.c memcpy(conn->auth_plugin_data, plugin_data, plugin_data_len); conn 629 ext/mysqlnd/mysqlnd.c auth_plugin->methods.get_auth_data(NULL, &scrambled_data_len, conn, user, passwd, passwd_len, conn 630 ext/mysqlnd/mysqlnd.c plugin_data, plugin_data_len, options, &conn->net->data->options, mysql_flags); conn 631 ext/mysqlnd/mysqlnd.c if (conn->error_info->error_no) { conn 635 ext/mysqlnd/mysqlnd.c ret = mysqlnd_auth_handshake(conn, user, passwd, passwd_len, db, db_len, options, mysql_flags, conn 644 ext/mysqlnd/mysqlnd.c ret = mysqlnd_auth_change_user(conn, user, strlen(user), passwd, passwd_len, db, db_len, silent, conn 667 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->error_info->error_no = %d", conn->error_info->error_no); conn 668 ext/mysqlnd/mysqlnd.c } while (ret == FAIL && conn->error_info->error_no == 0 && switch_to_auth_protocol != NULL); conn 672 ext/mysqlnd/mysqlnd.c conn->m->set_client_option(conn, MYSQLND_OPT_AUTH_PROTOCOL, requested_protocol); conn 690 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn, conn 704 ext/mysqlnd/mysqlnd.c ret = mysqlnd_switch_to_ssl_if_needed(conn, greet_packet, options, mysql_flags); conn 706 ext/mysqlnd/mysqlnd.c ret = mysqlnd_run_authentication(conn, user, passwd, passwd_len, db, db_len, conn 717 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, execute_init_commands)(MYSQLND_CONN_DATA * conn) conn 722 ext/mysqlnd/mysqlnd.c if (conn->options->init_commands) { conn 724 ext/mysqlnd/mysqlnd.c for (; current_command < conn->options->num_commands; ++current_command) { conn 725 ext/mysqlnd/mysqlnd.c const char * const command = conn->options->init_commands[current_command]; conn 727 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_INIT_COMMAND_EXECUTED_COUNT); conn 728 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->query(conn, command, strlen(command))) { conn 729 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_INIT_COMMAND_FAILED_COUNT); conn 733 ext/mysqlnd/mysqlnd.c if (conn->last_query_type == QUERY_SELECT) { conn 734 ext/mysqlnd/mysqlnd.c MYSQLND_RES * result = conn->m->use_result(conn, 0); conn 749 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_updated_connect_flags)(MYSQLND_CONN_DATA * conn, unsigned int mysql_flags) conn 751 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 757 ext/mysqlnd/mysqlnd.c mysql_flags |= conn->options->flags; /* use the flags from set_client_option() */ conn 787 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, connect_handshake)(MYSQLND_CONN_DATA * conn, conn 794 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 798 ext/mysqlnd/mysqlnd.c greet_packet = conn->protocol->m.get_greet_packet(conn->protocol, FALSE); conn 800 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 804 ext/mysqlnd/mysqlnd.c if (FAIL == net->data->m.connect_ex(conn->net, conn->scheme, conn->scheme_len, conn->persistent, conn 805 ext/mysqlnd/mysqlnd.c conn->stats, conn->error_info)) conn 812 ext/mysqlnd/mysqlnd.c if (FAIL == PACKET_READ(greet_packet, conn)) { conn 818 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, greet_packet->error_no, greet_packet->sqlstate, greet_packet->error); conn 824 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, conn 829 ext/mysqlnd/mysqlnd.c conn->thread_id = greet_packet->thread_id; conn 830 ext/mysqlnd/mysqlnd.c conn->protocol_version = greet_packet->protocol_version; conn 831 ext/mysqlnd/mysqlnd.c conn->server_version = mnd_pestrdup(greet_packet->server_version, conn->persistent); conn 833 ext/mysqlnd/mysqlnd.c conn->greet_charset = mysqlnd_find_charset_nr(greet_packet->charset_no); conn 834 ext/mysqlnd/mysqlnd.c if (!conn->greet_charset) { conn 837 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, conn 842 ext/mysqlnd/mysqlnd.c conn->client_flag = mysql_flags; conn 843 ext/mysqlnd/mysqlnd.c conn->server_capabilities = greet_packet->server_capabilities; conn 845 ext/mysqlnd/mysqlnd.c if (FAIL == mysqlnd_connect_run_authentication(conn, user, passwd, db, db_len, (size_t) passwd_len, conn 846 ext/mysqlnd/mysqlnd.c greet_packet, conn->options, mysql_flags)) conn 850 ext/mysqlnd/mysqlnd.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 851 ext/mysqlnd/mysqlnd.c conn->upsert_status->warning_count = 0; conn 852 ext/mysqlnd/mysqlnd.c conn->upsert_status->server_status = greet_packet->server_status; conn 853 ext/mysqlnd/mysqlnd.c conn->upsert_status->affected_rows = 0; conn 858 ext/mysqlnd/mysqlnd.c conn->client_flag = 0; conn 859 ext/mysqlnd/mysqlnd.c conn->server_capabilities = 0; conn 868 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, connect)(MYSQLND_CONN_DATA * conn, conn 884 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 887 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%p", conn); conn 889 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->local_tx_start(conn, this_func)) { conn 894 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 895 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 899 ext/mysqlnd/mysqlnd.c conn? conn->persistent:0, conn? CONN_GET_STATE(conn):-1); conn 901 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) > CONN_ALLOCED && CONN_GET_STATE(conn) ) { conn 904 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) < CONN_QUIT_SENT) { conn 905 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CLOSE_IMPLICIT); conn 907 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn); conn 910 ext/mysqlnd/mysqlnd.c conn->m->free_contents(conn); conn 911 ext/mysqlnd/mysqlnd.c MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_CONNECTIONS); conn 912 ext/mysqlnd/mysqlnd.c if (conn->persistent) { conn 913 ext/mysqlnd/mysqlnd.c MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_PERSISTENT_CONNECTIONS); conn 930 ext/mysqlnd/mysqlnd.c conn->m->set_client_option(conn, MYSQLND_OPT_MAX_ALLOWED_PACKET, (char *)&max_allowed_size); conn 981 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 984 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("transport=%s conn->scheme=%s", transport, conn->scheme); conn 985 ext/mysqlnd/mysqlnd.c conn->scheme = mnd_pestrndup(transport, transport_len, conn->persistent); conn 986 ext/mysqlnd/mysqlnd.c conn->scheme_len = transport_len; conn 989 ext/mysqlnd/mysqlnd.c if (!conn->scheme) { conn 994 ext/mysqlnd/mysqlnd.c mysql_flags = conn->m->get_updated_connect_flags(conn, mysql_flags); conn 996 ext/mysqlnd/mysqlnd.c if (FAIL == conn->m->connect_handshake(conn, host, user, passwd, passwd_len, db, db_len, mysql_flags)) { conn 1001 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_READY); conn 1013 ext/mysqlnd/mysqlnd.c conn->user_len = strlen(user); conn 1014 ext/mysqlnd/mysqlnd.c conn->user = mnd_pestrndup(user, conn->user_len, conn->persistent); conn 1015 ext/mysqlnd/mysqlnd.c conn->passwd = mnd_pestrndup(passwd, passwd_len, conn->persistent); conn 1016 ext/mysqlnd/mysqlnd.c conn->passwd_len = passwd_len; conn 1017 ext/mysqlnd/mysqlnd.c conn->port = port; conn 1018 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db = mnd_pestrndup(db, db_len, conn->persistent); conn 1019 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db_len = db_len; conn 1021 ext/mysqlnd/mysqlnd.c if (!conn->user || !conn->passwd || !conn->connect_or_select_db) { conn 1022 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1027 ext/mysqlnd/mysqlnd.c conn->host = mnd_pestrndup(host, host_len, conn->persistent); conn 1028 ext/mysqlnd/mysqlnd.c if (!conn->host) { conn 1029 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1032 ext/mysqlnd/mysqlnd.c conn->host_len = host_len; conn 1035 ext/mysqlnd/mysqlnd.c mnd_sprintf(&p, 0, "%s via TCP/IP", conn->host); conn 1037 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1040 ext/mysqlnd/mysqlnd.c conn->host_info = mnd_pestrdup(p, conn->persistent); conn 1042 ext/mysqlnd/mysqlnd.c if (!conn->host_info) { conn 1043 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1048 ext/mysqlnd/mysqlnd.c conn->unix_socket = mnd_pestrdup(socket_or_pipe, conn->persistent); conn 1050 ext/mysqlnd/mysqlnd.c conn->host_info = mnd_pestrdup("Localhost via UNIX socket", conn->persistent); conn 1053 ext/mysqlnd/mysqlnd.c mnd_sprintf(&p, 0, "%s via named pipe", conn->unix_socket); conn 1055 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1058 ext/mysqlnd/mysqlnd.c conn->host_info = mnd_pestrdup(p, conn->persistent); conn 1060 ext/mysqlnd/mysqlnd.c if (!conn->host_info) { conn 1061 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1067 ext/mysqlnd/mysqlnd.c if (!conn->unix_socket || !conn->host_info) { conn 1068 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1071 ext/mysqlnd/mysqlnd.c conn->unix_socket_len = strlen(conn->unix_socket); conn 1073 ext/mysqlnd/mysqlnd.c conn->max_packet_size = MYSQLND_ASSEMBLED_PACKET_MAX_SIZE; conn 1076 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 1078 ext/mysqlnd/mysqlnd.c mysqlnd_local_infile_default(conn); conn 1080 ext/mysqlnd/mysqlnd.c if (FAIL == conn->m->execute_init_commands(conn)) { conn 1084 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, STAT_CONNECT_SUCCESS, 1, STAT_OPENED_CONNECTIONS, 1); conn 1088 ext/mysqlnd/mysqlnd.c if (conn->persistent) { conn 1089 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, STAT_PCONNECT_SUCCESS, 1, STAT_OPENED_PERSISTENT_CONNECTIONS, 1); conn 1092 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("connection_id=%llu", conn->thread_id); conn 1094 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, PASS); conn 1099 ext/mysqlnd/mysqlnd.c DBG_ERR_FMT("[%u] %.128s (trying to connect via %s)", conn->error_info->error_no, conn->error_info->error, conn->scheme); conn 1100 ext/mysqlnd/mysqlnd.c if (!conn->error_info->error_no) { conn 1101 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_CONNECTION_ERROR, UNKNOWN_SQLSTATE, conn->error_info->error? conn->error_info->error:"Unknown error"); conn 1103 ext/mysqlnd/mysqlnd.c conn->error_info->error_no, conn->error_info->error, conn->scheme); conn 1106 ext/mysqlnd/mysqlnd.c conn->m->free_contents(conn); conn 1107 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CONNECT_FAILURE); conn 1109 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, FAIL); conn 1130 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn = conn_handle->data; conn 1134 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1136 ext/mysqlnd/mysqlnd.c ret = conn->m->connect(conn, host, user, passwd, passwd_len, db, db_len, port, socket_or_pipe, mysql_flags); conn 1138 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, FAIL); conn 1193 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, query)(MYSQLND_CONN_DATA * conn, const char * query, unsigned int query_len) conn 1198 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%p conn=%llu query=%s", conn, conn->thread_id, query); conn 1200 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1201 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->send_query(conn, query, query_len, MYSQLND_SEND_QUERY_IMPLICIT, NULL, NULL) && conn 1202 ext/mysqlnd/mysqlnd.c PASS == conn->m->reap_query(conn, MYSQLND_REAP_RESULT_IMPLICIT)) conn 1205 ext/mysqlnd/mysqlnd.c if (conn->last_query_type == QUERY_UPSERT && conn->upsert_status->affected_rows) { conn 1206 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, STAT_ROWS_AFFECTED_NORMAL, conn->upsert_status->affected_rows); conn 1209 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1218 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, send_query)(MYSQLND_CONN_DATA * conn, const char * query, unsigned int query_len, conn 1224 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu query=%s", conn->thread_id, query); conn 1225 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1227 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1228 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_QUERY, (zend_uchar *) query, query_len, conn 1232 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUERY_SENT); conn 1234 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1236 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1244 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, reap_query)(MYSQLND_CONN_DATA * conn, enum_mysqlnd_reap_result_type type) conn 1247 ext/mysqlnd/mysqlnd.c enum_mysqlnd_connection_state state = CONN_GET_STATE(conn); conn 1250 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1252 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1253 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1259 ext/mysqlnd/mysqlnd.c ret = conn->m->query_read_result_set_header(conn, NULL); conn 1261 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1263 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1468 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, list_fields)(MYSQLND_CONN_DATA * conn, const char *table, const char *achtung_wild) conn 1476 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu table=%s wild=%s", conn->thread_id, table? table:"",achtung_wild? achtung_wild:""); conn 1478 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1495 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->simple_command(conn, COM_FIELD_LIST, buff, p - buff, conn 1498 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, 0, FAIL); conn 1506 ext/mysqlnd/mysqlnd.c result = conn->m->result_init(5000, conn->persistent); conn 1511 ext/mysqlnd/mysqlnd.c if (FAIL == result->m.read_result_metadata(result, conn)) { conn 1522 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1529 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS); conn 1539 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, list_method)(MYSQLND_CONN_DATA * conn, const char * query, const char *achtung_wild, char *par1) conn 1547 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu query=%s wild=%u", conn->thread_id, query, achtung_wild); conn 1549 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1564 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->query(conn, show_query, show_query_len)) { conn 1565 ext/mysqlnd/mysqlnd.c result = conn->m->store_result(conn, MYSQLND_STORE_NO_COPY); conn 1570 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS); conn 1579 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, errno)(const MYSQLND_CONN_DATA * const conn) conn 1581 ext/mysqlnd/mysqlnd.c return conn->error_info->error_no; conn 1588 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, error)(const MYSQLND_CONN_DATA * const conn) conn 1590 ext/mysqlnd/mysqlnd.c return conn->error_info->error; conn 1597 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, sqlstate)(const MYSQLND_CONN_DATA * const conn) conn 1599 ext/mysqlnd/mysqlnd.c return conn->error_info->sqlstate[0] ? conn->error_info->sqlstate:MYSQLND_SQLSTATE_NULL; conn 1616 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, ssl_set)(MYSQLND_CONN_DATA * const conn, const char * key, const char * const cert, conn 1621 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 1624 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1631 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1640 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, escape_string)(MYSQLND_CONN_DATA * const conn, char * newstr, const char * escapestr, size_t escapestr_len) conn 1645 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1647 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1648 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("server_status=%u", conn->upsert_status->server_status); conn 1649 ext/mysqlnd/mysqlnd.c if (conn->upsert_status->server_status & SERVER_STATUS_NO_BACKSLASH_ESCAPES) { conn 1650 ext/mysqlnd/mysqlnd.c ret = mysqlnd_cset_escape_quotes(conn->charset, newstr, escapestr, escapestr_len); conn 1652 ext/mysqlnd/mysqlnd.c ret = mysqlnd_cset_escape_slashes(conn->charset, newstr, escapestr, escapestr_len); conn 1654 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, PASS); conn 1663 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, dump_debug_info)(MYSQLND_CONN_DATA * const conn) conn 1668 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1669 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1670 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_DEBUG, NULL, 0, PROT_EOF_PACKET, FALSE, TRUE); conn 1672 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1682 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, select_db)(MYSQLND_CONN_DATA * const conn, const char * const db, unsigned int db_len) conn 1688 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu db=%s", conn->thread_id, db); conn 1690 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1691 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_INIT_DB, (zend_uchar*) db, db_len, PROT_OK_PACKET, FALSE, TRUE); conn 1696 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 1698 ext/mysqlnd/mysqlnd.c if (conn->connect_or_select_db) { conn 1699 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->connect_or_select_db, conn->persistent); conn 1701 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db = mnd_pestrndup(db, db_len, conn->persistent); conn 1702 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db_len = db_len; conn 1703 ext/mysqlnd/mysqlnd.c if (!conn->connect_or_select_db) { conn 1705 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1709 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1718 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, ping)(MYSQLND_CONN_DATA * const conn) conn 1724 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1726 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1727 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_PING, NULL, 0, PROT_OK_PACKET, TRUE, TRUE); conn 1732 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 1734 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1744 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, statistic)(MYSQLND_CONN_DATA * conn, zend_string **message) conn 1751 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1753 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1755 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_STATISTICS, NULL, 0, PROT_LAST, FALSE, TRUE); conn 1759 ext/mysqlnd/mysqlnd.c stats_header = conn->protocol->m.get_stats_packet(conn->protocol, FALSE); conn 1761 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1765 ext/mysqlnd/mysqlnd.c if (PASS == (ret = PACKET_READ(stats_header, conn))) { conn 1773 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1782 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, kill)(MYSQLND_CONN_DATA * conn, unsigned int pid) conn 1789 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu pid=%u", conn->thread_id, pid); conn 1791 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1795 ext/mysqlnd/mysqlnd.c if (pid != conn->thread_id) { conn 1796 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_PROCESS_KILL, buff, 4, PROT_OK_PACKET, FALSE, TRUE); conn 1801 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 1802 ext/mysqlnd/mysqlnd.c } else if (PASS == (ret = conn->m->simple_command(conn, COM_PROCESS_KILL, buff, 4, PROT_LAST, FALSE, TRUE))) { conn 1803 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 1804 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn); conn 1807 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1816 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_charset)(MYSQLND_CONN_DATA * const conn, const char * const csname) conn 1823 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu cs=%s", conn->thread_id, csname); conn 1826 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_CANT_FIND_CHARSET, UNKNOWN_SQLSTATE, conn 1831 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1835 ext/mysqlnd/mysqlnd.c if (FAIL == (ret = conn->m->query(conn, query, query_len))) { conn 1837 ext/mysqlnd/mysqlnd.c } else if (conn->error_info->error_no) { conn 1840 ext/mysqlnd/mysqlnd.c conn->charset = charset; conn 1844 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1855 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, refresh)(MYSQLND_CONN_DATA * const conn, uint8_t options) conn 1861 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu options=%lu", conn->thread_id, options); conn 1863 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1866 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_REFRESH, bits, 1, PROT_OK_PACKET, FALSE, TRUE); conn 1868 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1877 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, shutdown)(MYSQLND_CONN_DATA * const conn, uint8_t level) conn 1883 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu level=%lu", conn->thread_id, level); conn 1885 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 1888 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_SHUTDOWN, bits, 1, PROT_OK_PACKET, FALSE, TRUE); conn 1890 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 1899 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, send_close)(MYSQLND_CONN_DATA * const conn) conn 1902 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 1907 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu net->data->stream->abstract=%p", conn->thread_id, net_stream? net_stream->abstract:NULL); conn 1909 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) >= CONN_READY) { conn 1910 ext/mysqlnd/mysqlnd.c MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_CONNECTIONS); conn 1911 ext/mysqlnd/mysqlnd.c if (conn->persistent) { conn 1912 ext/mysqlnd/mysqlnd.c MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_PERSISTENT_CONNECTIONS); conn 1915 ext/mysqlnd/mysqlnd.c state = CONN_GET_STATE(conn); conn 1921 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_QUIT, NULL, 0, PROT_LAST, TRUE, TRUE); conn 1922 ext/mysqlnd/mysqlnd.c net->data->m.close_stream(net, conn->stats, conn->error_info); conn 1924 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 1935 ext/mysqlnd/mysqlnd.c DBG_ERR_FMT("Brutally closing connection [%p][%s]", conn, conn->scheme); conn 1948 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 1952 ext/mysqlnd/mysqlnd.c net->data->m.close_stream(net, conn->stats, conn->error_info); conn 1963 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, get_reference)(MYSQLND_CONN_DATA * const conn) conn 1966 ext/mysqlnd/mysqlnd.c ++conn->refcount; conn 1967 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu new_refcount=%u", conn->thread_id, conn->refcount); conn 1968 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn); conn 1975 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, free_reference)(MYSQLND_CONN_DATA * const conn) conn 1979 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu old_refcount=%u", conn->thread_id, conn->refcount); conn 1980 ext/mysqlnd/mysqlnd.c if (!(--conn->refcount)) { conn 1986 ext/mysqlnd/mysqlnd.c ret = conn->m->send_close(conn); conn 1987 ext/mysqlnd/mysqlnd.c conn->m->dtor(conn); conn 1996 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, get_state)(const MYSQLND_CONN_DATA * const conn) conn 1999 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn->state); conn 2006 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, set_state)(MYSQLND_CONN_DATA * const conn, enum mysqlnd_connection_state new_state) conn 2010 ext/mysqlnd/mysqlnd.c conn->state = new_state; conn 2018 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, field_count)(const MYSQLND_CONN_DATA * const conn) conn 2020 ext/mysqlnd/mysqlnd.c return conn->field_count; conn 2027 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, server_status)(const MYSQLND_CONN_DATA * const conn) conn 2029 ext/mysqlnd/mysqlnd.c return conn->upsert_status->server_status; conn 2036 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, insert_id)(const MYSQLND_CONN_DATA * const conn) conn 2038 ext/mysqlnd/mysqlnd.c return conn->upsert_status->last_insert_id; conn 2045 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, affected_rows)(const MYSQLND_CONN_DATA * const conn) conn 2047 ext/mysqlnd/mysqlnd.c return conn->upsert_status->affected_rows; conn 2054 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, warning_count)(const MYSQLND_CONN_DATA * const conn) conn 2056 ext/mysqlnd/mysqlnd.c return conn->upsert_status->warning_count; conn 2063 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, info)(const MYSQLND_CONN_DATA * const conn) conn 2065 ext/mysqlnd/mysqlnd.c return conn->last_message; conn 2087 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_server_info)(const MYSQLND_CONN_DATA * const conn) conn 2089 ext/mysqlnd/mysqlnd.c return conn->server_version; conn 2096 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_host_info)(const MYSQLND_CONN_DATA * const conn) conn 2098 ext/mysqlnd/mysqlnd.c return conn->host_info; conn 2105 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_proto_info)(const MYSQLND_CONN_DATA * const conn) conn 2107 ext/mysqlnd/mysqlnd.c return conn->protocol_version; conn 2114 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, charset_name)(const MYSQLND_CONN_DATA * const conn) conn 2116 ext/mysqlnd/mysqlnd.c return conn->charset->name; conn 2123 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, thread_id)(const MYSQLND_CONN_DATA * const conn) conn 2125 ext/mysqlnd/mysqlnd.c return conn->thread_id; conn 2132 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_server_version)(const MYSQLND_CONN_DATA * const conn) conn 2137 ext/mysqlnd/mysqlnd.c if (!(p = conn->server_version)) { conn 2154 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, more_results)(const MYSQLND_CONN_DATA * const conn) conn 2158 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS? TRUE:FALSE); conn 2165 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, next_result)(MYSQLND_CONN_DATA * const conn) conn 2171 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 2173 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 2175 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) != CONN_NEXT_RESULT_PENDING) { conn 2179 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 2180 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 2185 ext/mysqlnd/mysqlnd.c if (FAIL == (ret = conn->m->query_read_result_set_header(conn, NULL))) { conn 2190 ext/mysqlnd/mysqlnd.c if (!conn->error_info->error_no) { conn 2193 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 2194 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn); conn 2196 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("Error from the server : (%u) %s", conn->error_info->error_no, conn->error_info->error); conn 2200 ext/mysqlnd/mysqlnd.c if (conn->last_query_type == QUERY_UPSERT && conn->upsert_status->affected_rows) { conn 2201 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, STAT_ROWS_AFFECTED_NORMAL, conn->upsert_status->affected_rows); conn 2204 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2267 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, change_user)(MYSQLND_CONN_DATA * const conn, conn 2280 ext/mysqlnd/mysqlnd.c conn->thread_id, user?user:"", passwd?"***":"null", db?db:"", (silent == TRUE)?1:0 ); conn 2282 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->local_tx_start(conn, this_func)) { conn 2286 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 2287 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 2300 ext/mysqlnd/mysqlnd.c ret = mysqlnd_run_authentication(conn, user, passwd, passwd_len, db, strlen(db), conn 2301 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data, conn->auth_plugin_data_len, conn->options->auth_protocol, conn 2302 ext/mysqlnd/mysqlnd.c 0 /*charset not used*/, conn->options, conn->server_capabilities, silent, TRUE/*is_change*/); conn 2308 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2318 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_client_option)(MYSQLND_CONN_DATA * const conn, conn 2326 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu option=%u", conn->thread_id, option); conn 2328 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->local_tx_start(conn, this_func)) { conn 2347 ext/mysqlnd/mysqlnd.c ret = conn->net->data->m.set_client_option(conn->net, option, value); conn 2351 ext/mysqlnd/mysqlnd.c conn->options->int_and_float_native = *(unsigned int*) value; conn 2356 ext/mysqlnd/mysqlnd.c conn->options->flags |= CLIENT_LOCAL_FILES; conn 2358 ext/mysqlnd/mysqlnd.c conn->options->flags &= ~CLIENT_LOCAL_FILES; conn 2367 ext/mysqlnd/mysqlnd.c new_init_commands = mnd_perealloc(conn->options->init_commands, sizeof(char *) * (conn->options->num_commands + 1), conn->persistent); conn 2371 ext/mysqlnd/mysqlnd.c conn->options->init_commands = new_init_commands; conn 2372 ext/mysqlnd/mysqlnd.c new_command = mnd_pestrdup(value, conn->persistent); conn 2376 ext/mysqlnd/mysqlnd.c conn->options->init_commands[conn->options->num_commands] = new_command; conn 2377 ext/mysqlnd/mysqlnd.c ++conn->options->num_commands; conn 2392 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_CANT_FIND_CHARSET, UNKNOWN_SQLSTATE, "Unknown character set"); conn 2397 ext/mysqlnd/mysqlnd.c new_charset_name = mnd_pestrdup(value, conn->persistent); conn 2401 ext/mysqlnd/mysqlnd.c if (conn->options->charset_name) { conn 2402 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->charset_name, conn->persistent); conn 2404 ext/mysqlnd/mysqlnd.c conn->options->charset_name = new_charset_name; conn 2405 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("charset=%s", conn->options->charset_name); conn 2409 ext/mysqlnd/mysqlnd.c conn->options->protocol = MYSQL_PROTOCOL_PIPE; conn 2413 ext/mysqlnd/mysqlnd.c conn->options->protocol = *(unsigned int*) value; conn 2430 ext/mysqlnd/mysqlnd.c conn->options->max_allowed_packet = *(unsigned int*) value; conn 2435 ext/mysqlnd/mysqlnd.c char * new_auth_protocol = value? mnd_pestrdup(value, conn->persistent) : NULL; conn 2439 ext/mysqlnd/mysqlnd.c if (conn->options->auth_protocol) { conn 2440 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->auth_protocol, conn->persistent); conn 2442 ext/mysqlnd/mysqlnd.c conn->options->auth_protocol = new_auth_protocol; conn 2443 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("auth_protocol=%s", conn->options->auth_protocol); conn 2448 ext/mysqlnd/mysqlnd.c conn->options->flags |= CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS; conn 2450 ext/mysqlnd/mysqlnd.c conn->options->flags &= ~CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS; conn 2454 ext/mysqlnd/mysqlnd.c if (conn->options->connect_attr) { conn 2455 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("Before reset %d attribute(s)", zend_hash_num_elements(conn->options->connect_attr)); conn 2456 ext/mysqlnd/mysqlnd.c zend_hash_clean(conn->options->connect_attr); conn 2460 ext/mysqlnd/mysqlnd.c if (conn->options->connect_attr && value) { conn 2461 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("Before delete %d attribute(s)", zend_hash_num_elements(conn->options->connect_attr)); conn 2462 ext/mysqlnd/mysqlnd.c zend_hash_str_del(conn->options->connect_attr, value, strlen(value)); conn 2463 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("%d left", zend_hash_num_elements(conn->options->connect_attr)); conn 2475 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2478 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2479 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, FAIL); conn 2488 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_client_option_2d)(MYSQLND_CONN_DATA * const conn, conn 2497 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu option=%u", conn->thread_id, option); conn 2499 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->local_tx_start(conn, this_func)) { conn 2504 ext/mysqlnd/mysqlnd.c if (!conn->options->connect_attr) { conn 2506 ext/mysqlnd/mysqlnd.c conn->options->connect_attr = mnd_pemalloc(sizeof(HashTable), conn->persistent); conn 2507 ext/mysqlnd/mysqlnd.c if (!conn->options->connect_attr) { conn 2510 ext/mysqlnd/mysqlnd.c zend_hash_init(conn->options->connect_attr, 0, NULL, ZVAL_PTR_DTOR, conn->persistent); conn 2516 ext/mysqlnd/mysqlnd.c zend_hash_str_update(conn->options->connect_attr, key, strlen(key), &attrz); conn 2522 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2525 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2526 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, FAIL); conn 2535 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, use_result)(MYSQLND_CONN_DATA * const conn, const unsigned int flags) conn 2541 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 2543 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 2545 ext/mysqlnd/mysqlnd.c if (!conn->current_result) { conn 2550 ext/mysqlnd/mysqlnd.c if (conn->last_query_type != QUERY_SELECT || CONN_GET_STATE(conn) != CONN_FETCHING_DATA) { conn 2551 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 2556 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_UNBUFFERED_SETS); conn 2558 ext/mysqlnd/mysqlnd.c conn->current_result->conn = conn->m->get_reference(conn); conn 2559 ext/mysqlnd/mysqlnd.c result = conn->current_result->m.use_result(conn->current_result, FALSE); conn 2562 ext/mysqlnd/mysqlnd.c conn->current_result->m.free_result(conn->current_result, TRUE); conn 2564 ext/mysqlnd/mysqlnd.c conn->current_result = NULL; conn 2567 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS); conn 2577 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, store_result)(MYSQLND_CONN_DATA * const conn, const unsigned int flags) conn 2583 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu conn=%p", conn->thread_id, conn); conn 2585 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 2588 ext/mysqlnd/mysqlnd.c if (!conn->current_result) { conn 2593 ext/mysqlnd/mysqlnd.c if (conn->last_query_type != QUERY_SELECT || CONN_GET_STATE(conn) != CONN_FETCHING_DATA) { conn 2594 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 2599 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_BUFFERED_SETS); conn 2602 ext/mysqlnd/mysqlnd.c if ((conn->m->get_client_api_capabilities(conn) & MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA)) { conn 2614 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, "Unknown fetch mode"); conn 2618 ext/mysqlnd/mysqlnd.c result = conn->current_result->m.store_result(conn->current_result, conn, f); conn 2620 ext/mysqlnd/mysqlnd.c conn->current_result->m.free_result(conn->current_result, TRUE); conn 2622 ext/mysqlnd/mysqlnd.c conn->current_result = NULL; conn 2625 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS); conn 2634 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_connection_stats)(const MYSQLND_CONN_DATA * const conn, conn 2638 ext/mysqlnd/mysqlnd.c mysqlnd_fill_stats_hash(conn->stats, mysqlnd_stats_values_names, return_value ZEND_FILE_LINE_CC); conn 2646 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_autocommit)(MYSQLND_CONN_DATA * conn, unsigned int mode) conn 2652 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 2653 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, (mode) ? "SET AUTOCOMMIT=1":"SET AUTOCOMMIT=0", sizeof("SET AUTOCOMMIT=1") - 1); conn 2654 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2664 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_commit)(MYSQLND_CONN_DATA * conn) conn 2666 ext/mysqlnd/mysqlnd.c return conn->m->tx_commit_or_rollback(conn, TRUE, TRANS_COR_NO_OPT, NULL); conn 2673 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_rollback)(MYSQLND_CONN_DATA * conn) conn 2675 ext/mysqlnd/mysqlnd.c return conn->m->tx_commit_or_rollback(conn, FALSE, TRANS_COR_NO_OPT, NULL); conn 2682 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_cor_options_to_string)(const MYSQLND_CONN_DATA * const conn, smart_str * str, const unsigned int mode) conn 2757 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_commit_or_rollback)(MYSQLND_CONN_DATA * conn, const zend_bool commit, const unsigned int flags, const char * const name) conn 2763 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 2766 ext/mysqlnd/mysqlnd.c conn->m->tx_cor_options_to_string(conn, &tmp_str, flags); conn 2783 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2787 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, query, query_len); conn 2791 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2801 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_begin)(MYSQLND_CONN_DATA * conn, const unsigned int mode, const char * const name) conn 2807 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 2817 ext/mysqlnd/mysqlnd.c zend_ulong server_version = conn->m->get_server_version(conn); conn 2846 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2849 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, query, query_len); conn 2853 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2863 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_savepoint)(MYSQLND_CONN_DATA * conn, const char * const name) conn 2869 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 2874 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, "Savepoint name not provided"); conn 2879 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2882 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, query, query_len); conn 2885 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2895 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_savepoint_release)(MYSQLND_CONN_DATA * conn, const char * const name) conn 2901 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 2906 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, "Savepoint name not provided"); conn 2911 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2914 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, query, query_len); conn 2917 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 2927 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, negotiate_client_api_capabilities)(MYSQLND_CONN_DATA * const conn, const unsigned int flags) conn 2931 ext/mysqlnd/mysqlnd.c if (conn) { conn 2932 ext/mysqlnd/mysqlnd.c ret = conn->client_api_capabilities; conn 2933 ext/mysqlnd/mysqlnd.c conn->client_api_capabilities = flags; conn 2943 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_client_api_capabilities)(const MYSQLND_CONN_DATA * const conn) conn 2946 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn? conn->client_api_capabilities : 0); conn 2953 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, local_tx_start)(MYSQLND_CONN_DATA * conn, size_t this_func) conn 2964 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, local_tx_end)(MYSQLND_CONN_DATA * conn, size_t this_func, enum_func_status status) conn 2974 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, init)(MYSQLND_CONN_DATA * conn) conn 2977 ext/mysqlnd/mysqlnd.c mysqlnd_stats_init(&conn->stats, STAT_LAST, conn->persistent); conn 2978 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 2980 ext/mysqlnd/mysqlnd.c conn->net = mysqlnd_net_init(conn->persistent, conn->stats, conn->error_info); conn 2981 ext/mysqlnd/mysqlnd.c conn->protocol = mysqlnd_protocol_init(conn->persistent); conn 2983 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn->stats && conn->net && conn->protocol? PASS:FAIL); conn 2988 ext/mysqlnd/mysqlnd.c MYSQLND_STMT * _mysqlnd_stmt_init(MYSQLND_CONN_DATA * const conn); conn 3088 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn, clone_object)(MYSQLND * const conn) conn 3092 ext/mysqlnd/mysqlnd.c ret = MYSQLND_CLASS_METHOD_TABLE_NAME(mysqlnd_object_factory).clone_connection_object(conn); conn 3100 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn, dtor)(MYSQLND * conn) conn 3103 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->data->thread_id); conn 3105 ext/mysqlnd/mysqlnd.c conn->data->m->free_reference(conn->data); conn 3107 ext/mysqlnd/mysqlnd.c mnd_pefree(conn, conn->persistent); conn 3119 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn = conn_handle->data; conn 3123 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 3125 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func)) { conn 3126 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) >= CONN_READY) { conn 3132 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, close_type_to_stat_map[close_type]); conn 3139 ext/mysqlnd/mysqlnd.c ret = conn->m->send_close(conn); conn 3142 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret); conn 76 ext/mysqlnd/mysqlnd.h #define mysqlnd_restart_psession(conn) ((conn)->data)->m->restart_psession((conn)->data) conn 77 ext/mysqlnd/mysqlnd.h #define mysqlnd_end_psession(conn) ((conn)->data)->m->end_psession((conn)->data) conn 87 ext/mysqlnd/mysqlnd.h PHPAPI MYSQLND * mysqlnd_connect(MYSQLND * conn, conn 97 ext/mysqlnd/mysqlnd.h #define mysqlnd_change_user(conn, user, passwd, db, silent) ((conn)->data)->m->change_user((conn)->data, (user), (passwd), (db), (silent), strlen((passwd))) conn 98 ext/mysqlnd/mysqlnd.h #define mysqlnd_change_user_ex(conn, user, passwd, db, silent, passwd_len) ((conn)->data)->m->change_user((conn)->data, (user), (passwd), (db), (silent), (passwd_len)) conn 107 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_connection_stats(conn, values) ((conn)->data)->m->get_statistics((conn)->data, (values) ZEND_FILE_LINE_CC) conn 110 ext/mysqlnd/mysqlnd.h #define mysqlnd_close(conn,is_forced) (conn)->m->close((conn), (is_forced)) conn 111 ext/mysqlnd/mysqlnd.h #define mysqlnd_query(conn, query_str, query_len) ((conn)->data)->m->query((conn)->data, (query_str), (query_len)) conn 112 ext/mysqlnd/mysqlnd.h #define mysqlnd_async_query(conn, query_str, query_len) ((conn)->data)->m->send_query((conn)->data, (query_str), (query_len), MYSQLND_SEND_QUERY_EXPLICIT, NULL, NULL) conn 113 ext/mysqlnd/mysqlnd.h #define mysqlnd_reap_async_query(conn) ((conn)->data)->m->reap_query((conn)->data, MYSQLND_REAP_RESULT_EXPLICIT) conn 118 ext/mysqlnd/mysqlnd.h #define mysqlnd_use_result(conn) ((conn)->data)->m->use_result((conn)->data, 0) conn 119 ext/mysqlnd/mysqlnd.h #define mysqlnd_store_result(conn) ((conn)->data)->m->store_result((conn)->data, MYSQLND_STORE_NO_COPY) conn 120 ext/mysqlnd/mysqlnd.h #define mysqlnd_store_result_ofs(conn) ((conn)->data)->m->store_result((conn)->data, MYSQLND_STORE_COPY) conn 121 ext/mysqlnd/mysqlnd.h #define mysqlnd_next_result(conn) ((conn)->data)->m->next_result((conn)->data) conn 122 ext/mysqlnd/mysqlnd.h #define mysqlnd_more_results(conn) ((conn)->data)->m->more_results((conn)->data) conn 127 ext/mysqlnd/mysqlnd.h #define mysqlnd_errno(conn) ((conn)->data)->m->get_error_no((conn)->data) conn 128 ext/mysqlnd/mysqlnd.h #define mysqlnd_error(conn) ((conn)->data)->m->get_error_str((conn)->data) conn 129 ext/mysqlnd/mysqlnd.h #define mysqlnd_sqlstate(conn) ((conn)->data)->m->get_sqlstate((conn)->data) conn 132 ext/mysqlnd/mysqlnd.h #define mysqlnd_character_set_name(conn) ((conn)->data)->m->charset_name((conn)->data) conn 135 ext/mysqlnd/mysqlnd.h #define mysqlnd_field_count(conn) ((conn)->data)->m->get_field_count((conn)->data) conn 136 ext/mysqlnd/mysqlnd.h #define mysqlnd_insert_id(conn) ((conn)->data)->m->get_last_insert_id((conn)->data) conn 137 ext/mysqlnd/mysqlnd.h #define mysqlnd_affected_rows(conn) ((conn)->data)->m->get_affected_rows((conn)->data) conn 138 ext/mysqlnd/mysqlnd.h #define mysqlnd_warning_count(conn) ((conn)->data)->m->get_warning_count((conn)->data) conn 139 ext/mysqlnd/mysqlnd.h #define mysqlnd_info(conn) ((conn)->data)->m->get_last_message((conn)->data) conn 140 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_server_info(conn) ((conn)->data)->m->get_server_information((conn)->data) conn 141 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_server_version(conn) ((conn)->data)->m->get_server_version((conn)->data) conn 142 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_host_info(conn) ((conn)->data)->m->get_host_information((conn)->data) conn 143 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_proto_info(conn) ((conn)->data)->m->get_protocol_information((conn)->data) conn 144 ext/mysqlnd/mysqlnd.h #define mysqlnd_thread_id(conn) ((conn)->data)->m->get_thread_id((conn)->data) conn 145 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_server_status(conn) ((conn)->data)->m->get_server_status((conn)->data) conn 162 ext/mysqlnd/mysqlnd.h #define mysqlnd_ssl_set(conn, key, cert, ca, capath, cipher) ((conn)->data)->m->ssl_set((conn)->data, (key), (cert), (ca), (capath), (cipher)) conn 186 ext/mysqlnd/mysqlnd.h void mysqlnd_local_infile_default(MYSQLND_CONN_DATA * conn); conn 189 ext/mysqlnd/mysqlnd.h #define mysqlnd_autocommit(conn, mode) ((conn)->data)->m->set_autocommit((conn)->data, (mode)) conn 190 ext/mysqlnd/mysqlnd.h #define mysqlnd_begin_transaction(conn,flags,name) ((conn)->data)->m->tx_begin((conn)->data, (flags), (name)) conn 191 ext/mysqlnd/mysqlnd.h #define mysqlnd_commit(conn, flags, name) ((conn)->data)->m->tx_commit_or_rollback((conn)->data, TRUE, (flags), (name)) conn 192 ext/mysqlnd/mysqlnd.h #define mysqlnd_rollback(conn, flags, name) ((conn)->data)->m->tx_commit_or_rollback((conn)->data, FALSE, (flags), (name)) conn 193 ext/mysqlnd/mysqlnd.h #define mysqlnd_savepoint(conn, name) ((conn)->data)->m->tx_savepoint((conn)->data, (name)) conn 194 ext/mysqlnd/mysqlnd.h #define mysqlnd_release_savepoint(conn, name) ((conn)->data)->m->tx_savepoint_release((conn)->data, (name)) conn 195 ext/mysqlnd/mysqlnd.h #define mysqlnd_list_dbs(conn, wild) ((conn)->data)->m->list_method((conn)->data, wild? "SHOW DATABASES LIKE %s":"SHOW DATABASES", (wild), NULL) conn 196 ext/mysqlnd/mysqlnd.h #define mysqlnd_list_fields(conn, tab,wild) ((conn)->data)->m->list_fields((conn)->data, (tab), (wild)) conn 197 ext/mysqlnd/mysqlnd.h #define mysqlnd_list_processes(conn) ((conn)->data)->m->list_method((conn)->data, "SHOW PROCESSLIST", NULL, NULL) conn 198 ext/mysqlnd/mysqlnd.h #define mysqlnd_list_tables(conn, wild) ((conn)->data)->m->list_method((conn)->data, wild? "SHOW TABLES LIKE %s":"SHOW TABLES", (wild), NULL) conn 199 ext/mysqlnd/mysqlnd.h #define mysqlnd_dump_debug_info(conn) ((conn)->data)->m->server_dump_debug_information((conn)->data) conn 200 ext/mysqlnd/mysqlnd.h #define mysqlnd_select_db(conn, db, db_len) ((conn)->data)->m->select_db((conn)->data, (db), (db_len)) conn 201 ext/mysqlnd/mysqlnd.h #define mysqlnd_ping(conn) ((conn)->data)->m->ping((conn)->data) conn 202 ext/mysqlnd/mysqlnd.h #define mysqlnd_kill(conn, pid) ((conn)->data)->m->kill_connection((conn)->data, (pid)) conn 203 ext/mysqlnd/mysqlnd.h #define mysqlnd_refresh(conn, options) ((conn)->data)->m->refresh_server((conn)->data, (options)) conn 204 ext/mysqlnd/mysqlnd.h #define mysqlnd_shutdown(conn, level) ((conn)->data)->m->shutdown_server((conn)->data, (level)) conn 205 ext/mysqlnd/mysqlnd.h #define mysqlnd_set_character_set(conn, cs) ((conn)->data)->m->set_charset((conn)->data, (cs)) conn 206 ext/mysqlnd/mysqlnd.h #define mysqlnd_stat(conn, msg) ((conn)->data)->m->get_server_statistics(((conn)->data), (msg)) conn 207 ext/mysqlnd/mysqlnd.h #define mysqlnd_options(conn, opt, value) ((conn)->data)->m->set_client_option((conn)->data, (opt), (value)) conn 208 ext/mysqlnd/mysqlnd.h #define mysqlnd_options4(conn, opt, k, v) ((conn)->data)->m->set_client_option_2d((conn)->data, (opt), (k), (v)) conn 209 ext/mysqlnd/mysqlnd.h #define mysqlnd_set_server_option(conn, op) ((conn)->data)->m->set_server_option((conn)->data, (op)) conn 212 ext/mysqlnd/mysqlnd.h #define mysqlnd_real_escape_string(conn, newstr, escapestr, escapestr_len) \ conn 213 ext/mysqlnd/mysqlnd.h ((conn)->data)->m->escape_string((conn)->data, (newstr), (escapestr), (escapestr_len)) conn 221 ext/mysqlnd/mysqlnd.h #define mysqlnd_stmt_init(conn) ((conn)->data)->m->stmt_init(((conn)->data)) conn 33 ext/mysqlnd/mysqlnd_auth.c mysqlnd_auth_handshake(MYSQLND_CONN_DATA * conn, conn 60 ext/mysqlnd/mysqlnd_auth.c auth_resp_packet = conn->protocol->m.get_auth_response_packet(conn->protocol, FALSE); conn 63 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 68 ext/mysqlnd/mysqlnd_auth.c change_auth_resp_packet = conn->protocol->m.get_change_auth_response_packet(conn->protocol, FALSE); conn 70 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 77 ext/mysqlnd/mysqlnd_auth.c if (!PACKET_WRITE(change_auth_resp_packet, conn)) { conn 78 ext/mysqlnd/mysqlnd_auth.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 79 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); conn 83 ext/mysqlnd/mysqlnd_auth.c auth_packet = conn->protocol->m.get_auth_packet(conn->protocol, FALSE); conn 102 ext/mysqlnd/mysqlnd_auth.c if (conn->server_capabilities & CLIENT_CONNECT_ATTRS) { conn 103 ext/mysqlnd/mysqlnd_auth.c auth_packet->connect_attr = conn->options->connect_attr; conn 106 ext/mysqlnd/mysqlnd_auth.c if (!PACKET_WRITE(auth_packet, conn)) { conn 111 ext/mysqlnd/mysqlnd_auth.c conn->charset = mysqlnd_find_charset_nr(auth_packet->charset_no); conn 114 ext/mysqlnd/mysqlnd_auth.c if (FAIL == PACKET_READ(auth_resp_packet, conn) || auth_resp_packet->response_code >= 0xFE) { conn 119 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, mysqlnd_old_passwd); conn 134 ext/mysqlnd/mysqlnd_auth.c strlcpy(conn->error_info->sqlstate, auth_resp_packet->sqlstate, sizeof(conn->error_info->sqlstate)); conn 137 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, auth_resp_packet->error_no, UNKNOWN_SQLSTATE, auth_resp_packet->error); conn 142 ext/mysqlnd/mysqlnd_auth.c SET_NEW_MESSAGE(conn->last_message, conn->last_message_len, auth_resp_packet->message, auth_resp_packet->message_len, conn->persistent); conn 155 ext/mysqlnd/mysqlnd_auth.c mysqlnd_auth_change_user(MYSQLND_CONN_DATA * const conn, conn 174 ext/mysqlnd/mysqlnd_auth.c const MYSQLND_CHARSET * old_cs = conn->charset; conn 181 ext/mysqlnd/mysqlnd_auth.c chg_user_resp = conn->protocol->m.get_change_user_response_packet(conn->protocol, FALSE); conn 184 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 189 ext/mysqlnd/mysqlnd_auth.c change_auth_resp_packet = conn->protocol->m.get_change_auth_response_packet(conn->protocol, FALSE); conn 191 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 198 ext/mysqlnd/mysqlnd_auth.c if (!PACKET_WRITE(change_auth_resp_packet, conn)) { conn 199 ext/mysqlnd/mysqlnd_auth.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 200 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); conn 204 ext/mysqlnd/mysqlnd_auth.c auth_packet = conn->protocol->m.get_auth_packet(conn->protocol, FALSE); conn 207 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 222 ext/mysqlnd/mysqlnd_auth.c if (conn->m->get_server_version(conn) >= 50123) { conn 223 ext/mysqlnd/mysqlnd_auth.c auth_packet->charset_no = conn->charset->nr; conn 226 ext/mysqlnd/mysqlnd_auth.c if (!PACKET_WRITE(auth_packet, conn)) { conn 227 ext/mysqlnd/mysqlnd_auth.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 228 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); conn 233 ext/mysqlnd/mysqlnd_auth.c ret = PACKET_READ(chg_user_resp, conn); conn 234 ext/mysqlnd/mysqlnd_auth.c COPY_CLIENT_ERROR(*conn->error_info, chg_user_resp->error_info); conn 240 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, mysqlnd_old_passwd); conn 255 ext/mysqlnd/mysqlnd_auth.c if (conn->error_info->error_no) { conn 262 ext/mysqlnd/mysqlnd_auth.c if (conn->m->get_server_version(conn) > 50113L &&conn->m->get_server_version(conn) < 50118L) { conn 263 ext/mysqlnd/mysqlnd_auth.c MYSQLND_PACKET_OK * redundant_error_packet = conn->protocol->m.get_ok_packet(conn->protocol, FALSE); conn 265 ext/mysqlnd/mysqlnd_auth.c PACKET_READ(redundant_error_packet, conn); conn 267 ext/mysqlnd/mysqlnd_auth.c DBG_INF_FMT("Server is %u, buggy, sends two ERR messages", conn->m->get_server_version(conn)); conn 269 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 276 ext/mysqlnd/mysqlnd_auth.c tmp = mnd_pestrndup(user, user_len, conn->persistent); conn 277 ext/mysqlnd/mysqlnd_auth.c if (conn->user) { conn 278 ext/mysqlnd/mysqlnd_auth.c mnd_pefree(conn->user, conn->persistent); conn 280 ext/mysqlnd/mysqlnd_auth.c conn->user = tmp; conn 282 ext/mysqlnd/mysqlnd_auth.c tmp = mnd_pestrdup(passwd, conn->persistent); conn 283 ext/mysqlnd/mysqlnd_auth.c if (conn->passwd) { conn 284 ext/mysqlnd/mysqlnd_auth.c mnd_pefree(conn->passwd, conn->persistent); conn 286 ext/mysqlnd/mysqlnd_auth.c conn->passwd = tmp; conn 288 ext/mysqlnd/mysqlnd_auth.c if (conn->last_message) { conn 289 ext/mysqlnd/mysqlnd_auth.c mnd_pefree(conn->last_message, conn->persistent); conn 290 ext/mysqlnd/mysqlnd_auth.c conn->last_message = NULL; conn 292 ext/mysqlnd/mysqlnd_auth.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 294 ext/mysqlnd/mysqlnd_auth.c if (conn->m->get_server_version(conn) < 50123) { conn 295 ext/mysqlnd/mysqlnd_auth.c ret = conn->m->set_charset(conn, old_cs->name); conn 300 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, mysqlnd_old_passwd); conn 360 ext/mysqlnd/mysqlnd_auth.c MYSQLND_CONN_DATA * conn, const char * const user, const char * const passwd, conn 374 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_MALFORMED_PACKET, UNKNOWN_SQLSTATE, "The server sent wrong length for scramble"); conn 420 ext/mysqlnd/mysqlnd_auth.c MYSQLND_CONN_DATA * conn, const char * const user, const char * const passwd, conn 482 ext/mysqlnd/mysqlnd_auth.c mysqlnd_sha256_get_rsa_key(MYSQLND_CONN_DATA * conn, conn 502 ext/mysqlnd/mysqlnd_auth.c pk_req_packet = conn->protocol->m.get_sha256_pk_request_packet(conn->protocol, FALSE); conn 504 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 507 ext/mysqlnd/mysqlnd_auth.c pk_resp_packet = conn->protocol->m.get_sha256_pk_request_response_packet(conn->protocol, FALSE); conn 509 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 514 ext/mysqlnd/mysqlnd_auth.c if (! PACKET_WRITE(pk_req_packet, conn)) { conn 517 ext/mysqlnd/mysqlnd_auth.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 520 ext/mysqlnd/mysqlnd_auth.c if (FAIL == PACKET_READ(pk_resp_packet, conn) || NULL == pk_resp_packet->public_key) { conn 523 ext/mysqlnd/mysqlnd_auth.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 540 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, conn 570 ext/mysqlnd/mysqlnd_auth.c MYSQLND_CONN_DATA * conn, const char * const user, const char * const passwd, conn 583 ext/mysqlnd/mysqlnd_auth.c if (conn->net->data->ssl) { conn 591 ext/mysqlnd/mysqlnd_auth.c server_public_key = mysqlnd_sha256_get_rsa_key(conn, options, net_options); conn 608 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, "password is too long"); conn 194 ext/mysqlnd/mysqlnd_driver.c MYSQLND_METHOD(mysqlnd_object_factory, get_prepared_statement)(MYSQLND_CONN_DATA * const conn) conn 197 ext/mysqlnd/mysqlnd_driver.c MYSQLND_STMT * ret = mnd_pecalloc(1, alloc_size, conn->persistent); conn 206 ext/mysqlnd/mysqlnd_driver.c ret->persistent = conn->persistent; conn 208 ext/mysqlnd/mysqlnd_driver.c stmt = ret->data = mnd_pecalloc(1, sizeof(MYSQLND_STMT_DATA), conn->persistent); conn 213 ext/mysqlnd/mysqlnd_driver.c stmt->persistent = conn->persistent; conn 229 ext/mysqlnd/mysqlnd_driver.c stmt->conn = conn->m->get_reference(conn); conn 235 ext/mysqlnd/mysqlnd_driver.c zend_llist_init(stmt->error_info->error_list, sizeof(MYSQLND_ERROR_LIST_ELEMENT), (llist_dtor_func_t) mysqlnd_error_list_pdtor, conn->persistent); conn 240 ext/mysqlnd/mysqlnd_driver.c SET_OOM_ERROR(*conn->error_info); conn 34 ext/mysqlnd/mysqlnd_ext_plugin.c _mysqlnd_plugin_get_plugin_connection_data(const MYSQLND * conn, unsigned int plugin_id) conn 38 ext/mysqlnd/mysqlnd_ext_plugin.c if (!conn || plugin_id >= mysqlnd_plugin_count()) { conn 41 ext/mysqlnd/mysqlnd_ext_plugin.c DBG_RETURN((void *)((char *)conn + sizeof(MYSQLND) + plugin_id * sizeof(void *))); conn 48 ext/mysqlnd/mysqlnd_ext_plugin.c _mysqlnd_plugin_get_plugin_connection_data_data(const MYSQLND_CONN_DATA * conn, unsigned int plugin_id) conn 52 ext/mysqlnd/mysqlnd_ext_plugin.c if (!conn || plugin_id >= mysqlnd_plugin_count()) { conn 55 ext/mysqlnd/mysqlnd_ext_plugin.c DBG_RETURN((void *)((char *)conn + sizeof(MYSQLND_CONN_DATA) + plugin_id * sizeof(void *))); conn 25 ext/mysqlnd/mysqlnd_ext_plugin.h PHPAPI void ** _mysqlnd_plugin_get_plugin_connection_data(const MYSQLND * conn, unsigned int plugin_id); conn 28 ext/mysqlnd/mysqlnd_ext_plugin.h PHPAPI void ** _mysqlnd_plugin_get_plugin_connection_data_data(const MYSQLND_CONN_DATA * conn, unsigned int plugin_id); conn 76 ext/mysqlnd/mysqlnd_libmysql_compat.h #define mysql_refresh(conn, options) mysqlnd_refresh((conn), (options)) conn 129 ext/mysqlnd/mysqlnd_loaddata.c mysqlnd_local_infile_default(MYSQLND_CONN_DATA * conn) conn 131 ext/mysqlnd/mysqlnd_loaddata.c conn->infile.local_infile_init = mysqlnd_local_infile_init; conn 132 ext/mysqlnd/mysqlnd_loaddata.c conn->infile.local_infile_read = mysqlnd_local_infile_read; conn 133 ext/mysqlnd/mysqlnd_loaddata.c conn->infile.local_infile_error = mysqlnd_local_infile_error; conn 134 ext/mysqlnd/mysqlnd_loaddata.c conn->infile.local_infile_end = mysqlnd_local_infile_end; conn 144 ext/mysqlnd/mysqlnd_loaddata.c mysqlnd_handle_local_infile(MYSQLND_CONN_DATA * conn, const char * filename, zend_bool * is_warning) conn 154 ext/mysqlnd/mysqlnd_loaddata.c MYSQLND_NET * net = conn->net; conn 158 ext/mysqlnd/mysqlnd_loaddata.c if (!(conn->options->flags & CLIENT_LOCAL_FILES)) { conn 161 ext/mysqlnd/mysqlnd_loaddata.c ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info); conn 166 ext/mysqlnd/mysqlnd_loaddata.c infile = conn->infile; conn 174 ext/mysqlnd/mysqlnd_loaddata.c char tmp_buf[sizeof(conn->error_info->error)]; conn 179 ext/mysqlnd/mysqlnd_loaddata.c SET_CLIENT_ERROR(*conn->error_info, tmp_error_no, UNKNOWN_SQLSTATE, tmp_buf); conn 181 ext/mysqlnd/mysqlnd_loaddata.c ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info); conn 187 ext/mysqlnd/mysqlnd_loaddata.c if ((ret = net->data->m.send_ex(net, buf, bufsize, conn->stats, conn->error_info)) == 0) { conn 189 ext/mysqlnd/mysqlnd_loaddata.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn); conn 195 ext/mysqlnd/mysqlnd_loaddata.c if ((ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info)) == 0) { conn 196 ext/mysqlnd/mysqlnd_loaddata.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn); conn 202 ext/mysqlnd/mysqlnd_loaddata.c char tmp_buf[sizeof(conn->error_info->error)]; conn 207 ext/mysqlnd/mysqlnd_loaddata.c SET_CLIENT_ERROR(*conn->error_info, tmp_error_no, UNKNOWN_SQLSTATE, tmp_buf); conn 215 ext/mysqlnd/mysqlnd_loaddata.c if (FAIL == conn->m->simple_command_handle_response(conn, PROT_OK_PACKET, FALSE, COM_QUERY, FALSE)) { conn 219 ext/mysqlnd/mysqlnd_loaddata.c (*conn->infile.local_infile_end)(info); conn 171 ext/mysqlnd/mysqlnd_priv.h enum_func_status mysqlnd_handle_local_infile(MYSQLND_CONN_DATA * conn, const char * filename, zend_bool * is_warning); conn 191 ext/mysqlnd/mysqlnd_priv.h mysqlnd_auth_handshake(MYSQLND_CONN_DATA * conn, conn 211 ext/mysqlnd/mysqlnd_priv.h mysqlnd_auth_change_user(MYSQLND_CONN_DATA * const conn, conn 52 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 56 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->result) { conn 61 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 74 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) != CONN_FETCHING_DATA || conn 77 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, conn 85 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*conn->error_info); conn 86 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_PS_BUFFERED_SETS); conn 94 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 98 ext/mysqlnd/mysqlnd_ps.c ret = result->m.store_result_fetch_data(conn, result, result->meta, &result->stored_data->row_buffers, TRUE); conn 109 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 115 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 131 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*conn->error_info, result->stored_data->error_info); conn 148 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 152 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->result) { conn 157 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 170 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) != CONN_FETCHING_DATA || stmt->state != MYSQLND_STMT_WAITING_USE_OR_STORE) { conn 171 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, conn 177 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*conn->error_info); conn 178 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_BUFFERED_SETS); conn 181 ext/mysqlnd/mysqlnd_ps.c result = conn->m->result_init(stmt->result->field_count, stmt->persistent); conn 183 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 189 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 193 ext/mysqlnd/mysqlnd_ps.c if ((result = result->m.store_result(result, conn, MYSQLND_STORE_PS | MYSQLND_STORE_NO_COPY))) { conn 198 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 220 ext/mysqlnd/mysqlnd_ps.c DBG_RETURN((stmt && stmt->conn && (stmt->conn->m->get_server_status(stmt->conn) & SERVER_MORE_RESULTS_EXISTS))? conn 232 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 235 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->result) { conn 238 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 241 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) != CONN_NEXT_RESULT_PENDING || !(conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS)) { conn 268 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->conn->protocol) { conn 273 ext/mysqlnd/mysqlnd_ps.c field_packet = stmt->conn->protocol->m.get_result_field_packet(stmt->conn->protocol, FALSE); conn 276 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 281 ext/mysqlnd/mysqlnd_ps.c if (FAIL == PACKET_READ(field_packet, stmt->conn)) { conn 303 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->conn->protocol) { conn 308 ext/mysqlnd/mysqlnd_ps.c prepare_resp = stmt->conn->protocol->m.get_prepare_response_packet(stmt->conn->protocol, FALSE); conn 311 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 315 ext/mysqlnd/mysqlnd_ps.c if (FAIL == PACKET_READ(prepare_resp, stmt->conn)) { conn 321 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->conn->error_info, prepare_resp->error_info); conn 326 ext/mysqlnd/mysqlnd_ps.c stmt->warning_count = stmt->conn->upsert_status->warning_count = prepare_resp->warning_count; conn 327 ext/mysqlnd/mysqlnd_ps.c stmt->field_count = stmt->conn->field_count = prepare_resp->field_count; conn 347 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->conn->protocol) { conn 352 ext/mysqlnd/mysqlnd_ps.c fields_eof = stmt->conn->protocol->m.get_eof_packet(stmt->conn->protocol, FALSE); conn 355 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 357 ext/mysqlnd/mysqlnd_ps.c if (FAIL == (ret = PACKET_READ(fields_eof, stmt->conn))) { conn 386 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 393 ext/mysqlnd/mysqlnd_ps.c SET_ERROR_AFF_ROWS(stmt->conn); conn 396 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 413 ext/mysqlnd/mysqlnd_ps.c s_to_prepare = stmt->conn->m->stmt_init(stmt->conn); conn 420 ext/mysqlnd/mysqlnd_ps.c if (FAIL == stmt_to_prepare->conn->m->simple_command(stmt_to_prepare->conn, COM_STMT_PREPARE, (const zend_uchar *) query, query_len, PROT_LAST, FALSE, TRUE) || conn 440 ext/mysqlnd/mysqlnd_ps.c MYSQLND_RES * result = stmt->conn->m->result_init(stmt_to_prepare->field_count, stmt_to_prepare->persistent); conn 442 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 448 ext/mysqlnd/mysqlnd_ps.c result->conn = stmt_to_prepare->conn->m->get_reference(stmt_to_prepare->conn); conn 452 ext/mysqlnd/mysqlnd_ps.c if (FAIL == result->m.read_result_metadata(result, stmt_to_prepare->conn) || conn 496 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 499 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 502 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 503 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(conn, CONN_QUERY_SENT); conn 505 ext/mysqlnd/mysqlnd_ps.c ret = mysqlnd_query_read_result_set_header(stmt->conn, s); conn 507 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 509 ext/mysqlnd/mysqlnd_ps.c stmt->upsert_status->affected_rows = conn->upsert_status->affected_rows; conn 510 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) == CONN_QUIT_SENT) { conn 524 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 525 ext/mysqlnd/mysqlnd_ps.c *stmt->upsert_status = *conn->upsert_status; /* copy status */ conn 527 ext/mysqlnd/mysqlnd_ps.c if (conn->last_query_type == QUERY_UPSERT || conn->last_query_type == QUERY_LOAD_LOCAL) { conn 533 ext/mysqlnd/mysqlnd_ps.c if (!stmt->result->conn) { conn 538 ext/mysqlnd/mysqlnd_ps.c stmt->result->conn = stmt->conn->m->get_reference(stmt->conn); conn 542 ext/mysqlnd/mysqlnd_ps.c stmt->field_count = stmt->result->field_count = conn->field_count; conn 561 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(conn, CONN_READY); conn 599 ext/mysqlnd/mysqlnd_ps.c if (ret == PASS && conn->last_query_type == QUERY_UPSERT && stmt->upsert_status->affected_rows) { conn 600 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, STAT_ROWS_AFFECTED_PS, stmt->upsert_status->affected_rows); conn 630 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 636 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 639 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 643 ext/mysqlnd/mysqlnd_ps.c SET_ERROR_AFF_ROWS(stmt->conn); conn 691 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, conn 726 ext/mysqlnd/mysqlnd_ps.c ret = stmt->conn->m->simple_command(stmt->conn, COM_STMT_EXECUTE, request, request_len, conn 738 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 779 ext/mysqlnd/mysqlnd_ps.c result->conn->options->int_and_float_native, conn 780 ext/mysqlnd/mysqlnd_ps.c result->conn->stats); conn 869 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { conn 870 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, conn 886 ext/mysqlnd/mysqlnd_ps.c if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { conn 890 ext/mysqlnd/mysqlnd_ps.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); conn 901 ext/mysqlnd/mysqlnd_ps.c result->conn->options->int_and_float_native, conn 902 ext/mysqlnd/mysqlnd_ps.c result->conn->stats)) conn 933 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(stmt->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_PS_UNBUF); conn 950 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->conn->error_info, row_packet->error_info); conn 953 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(result->conn, CONN_READY); conn 959 ext/mysqlnd/mysqlnd_ps.c memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); conn 960 ext/mysqlnd/mysqlnd_ps.c result->conn->upsert_status->warning_count = row_packet->warning_count; conn 961 ext/mysqlnd/mysqlnd_ps.c result->conn->upsert_status->server_status = row_packet->server_status; conn 966 ext/mysqlnd/mysqlnd_ps.c if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 967 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); conn 969 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(result->conn, CONN_READY); conn 985 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 988 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->result) { conn 993 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 996 ext/mysqlnd/mysqlnd_ps.c (!stmt->cursor_exists && CONN_GET_STATE(conn) != CONN_FETCHING_DATA) || conn 997 ext/mysqlnd/mysqlnd_ps.c (stmt->cursor_exists && CONN_GET_STATE(conn) != CONN_READY) || conn 1000 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, conn 1008 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(stmt->conn->stats, STAT_PS_UNBUFFERED_SETS); conn 1036 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !result || !result->conn || !result->unbuf) { conn 1045 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*stmt->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, conn 1055 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1060 ext/mysqlnd/mysqlnd_ps.c if (FAIL == stmt->conn->m->simple_command(stmt->conn, COM_STMT_FETCH, buf, sizeof(buf), conn 1063 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *stmt->conn->error_info); conn 1070 ext/mysqlnd/mysqlnd_ps.c if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { conn 1075 ext/mysqlnd/mysqlnd_ps.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); conn 1086 ext/mysqlnd/mysqlnd_ps.c result->conn->options->int_and_float_native, conn 1087 ext/mysqlnd/mysqlnd_ps.c result->conn->stats)) conn 1135 ext/mysqlnd/mysqlnd_ps.c ret = PACKET_READ(row_packet, result->conn); conn 1140 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(stmt->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_PS_CURSOR); conn 1148 ext/mysqlnd/mysqlnd_ps.c stmt->conn->upsert_status->warning_count = conn 1152 ext/mysqlnd/mysqlnd_ps.c stmt->conn->upsert_status->server_status = conn 1158 ext/mysqlnd/mysqlnd_ps.c stmt->conn->upsert_status->warning_count = conn 1161 ext/mysqlnd/mysqlnd_ps.c stmt->conn->upsert_status->server_status = conn 1180 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1199 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1238 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1244 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1247 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn = stmt->conn; conn 1268 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) == CONN_READY && conn 1269 ext/mysqlnd/mysqlnd_ps.c FAIL == (ret = conn->m->simple_command(conn, COM_STMT_RESET, cmd_buf, conn 1272 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 1274 ext/mysqlnd/mysqlnd_ps.c *stmt->upsert_status = *conn->upsert_status; conn 1290 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1327 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 1332 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1337 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 1340 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1373 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) == CONN_READY) { conn 1384 ext/mysqlnd/mysqlnd_ps.c ret = conn->m->simple_command(conn, cmd, cmd_buf, packet_len, PROT_LAST , FALSE, TRUE); conn 1387 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 1392 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 1414 ext/mysqlnd/mysqlnd_ps.c if ((packet_len = conn->net->m.consume_uneaten_data(conn->net, cmd))) { conn 1438 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1453 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1507 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1524 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1561 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1573 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1590 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1605 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1646 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1664 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1827 ext/mysqlnd/mysqlnd_ps.c if (!stmt->field_count || !stmt->conn || !stmt->result || !stmt->result->meta) { conn 1834 ext/mysqlnd/mysqlnd_ps.c stmt->result->stored_data->m.initialize_result_set_rest(stmt->result->stored_data, stmt->result->meta, stmt->conn->stats, conn 1835 ext/mysqlnd/mysqlnd_ps.c stmt->conn->options->int_and_float_native); conn 1847 ext/mysqlnd/mysqlnd_ps.c result = stmt->conn->m->result_init(stmt->field_count, stmt->persistent); conn 1866 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 1969 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 2010 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(stmt->conn, CONN_READY); conn 2161 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 2166 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 2171 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 2174 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 2203 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) == CONN_READY && conn 2204 ext/mysqlnd/mysqlnd_ps.c FAIL == conn->m->simple_command(conn, COM_STMT_CLOSE, cmd_buf, sizeof(cmd_buf), conn 2207 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 2222 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(conn->stats, statistic); conn 2232 ext/mysqlnd/mysqlnd_ps.c if (stmt->conn) { conn 2233 ext/mysqlnd/mysqlnd_ps.c stmt->conn->m->free_reference(stmt->conn); conn 2234 ext/mysqlnd/mysqlnd_ps.c stmt->conn = NULL; conn 2377 ext/mysqlnd/mysqlnd_ps.c _mysqlnd_stmt_init(MYSQLND_CONN_DATA * const conn) conn 2381 ext/mysqlnd/mysqlnd_ps.c ret = MYSQLND_CLASS_METHOD_TABLE_NAME(mysqlnd_object_factory).get_prepared_statement(conn); conn 303 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_result(result->unbuf, result->conn? result->conn->stats : NULL); conn 343 ext/mysqlnd/mysqlnd_result.c if (result->conn) { conn 344 ext/mysqlnd/mysqlnd_result.c result->conn->m->free_reference(result->conn); conn 345 ext/mysqlnd/mysqlnd_result.c result->conn = NULL; conn 357 ext/mysqlnd/mysqlnd_result.c MYSQLND_METHOD(mysqlnd_res, read_result_metadata)(MYSQLND_RES * result, MYSQLND_CONN_DATA * conn) conn 374 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 381 ext/mysqlnd/mysqlnd_result.c if (FAIL == result->meta->m->read_metadata(result->meta, conn)) { conn 402 ext/mysqlnd/mysqlnd_result.c mysqlnd_query_read_result_set_header(MYSQLND_CONN_DATA * conn, MYSQLND_STMT * s) conn 414 ext/mysqlnd/mysqlnd_result.c rset_header = conn->protocol->m.get_rset_header_packet(conn->protocol, FALSE); conn 416 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 421 ext/mysqlnd/mysqlnd_result.c SET_ERROR_AFF_ROWS(conn); conn 423 ext/mysqlnd/mysqlnd_result.c if (FAIL == (ret = PACKET_READ(rset_header, conn))) { conn 438 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->server_status &= ~SERVER_MORE_RESULTS_EXISTS; conn 443 ext/mysqlnd/mysqlnd_result.c COPY_CLIENT_ERROR(*conn->error_info, rset_header->error_info); conn 447 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_READY); conn 450 ext/mysqlnd/mysqlnd_result.c conn->error_info->error_no = 0; conn 456 ext/mysqlnd/mysqlnd_result.c conn->last_query_type = QUERY_LOAD_LOCAL; conn 457 ext/mysqlnd/mysqlnd_result.c conn->field_count = 0; /* overwrite previous value, or the last value could be used and lead to bug#53503 */ conn 458 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_SENDING_LOAD_DATA); conn 459 ext/mysqlnd/mysqlnd_result.c ret = mysqlnd_handle_local_infile(conn, rset_header->info_or_local_file, &is_warning); conn 460 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, (ret == PASS || is_warning == TRUE)? CONN_READY:CONN_QUIT_SENT); conn 461 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_NON_RSET_QUERY); conn 466 ext/mysqlnd/mysqlnd_result.c conn->last_query_type = QUERY_UPSERT; conn 467 ext/mysqlnd/mysqlnd_result.c conn->field_count = rset_header->field_count; conn 468 ext/mysqlnd/mysqlnd_result.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 469 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->warning_count = rset_header->warning_count; conn 470 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->server_status = rset_header->server_status; conn 471 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->affected_rows = rset_header->affected_rows; conn 472 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->last_insert_id = rset_header->last_insert_id; conn 473 ext/mysqlnd/mysqlnd_result.c SET_NEW_MESSAGE(conn->last_message, conn->last_message_len, conn 475 ext/mysqlnd/mysqlnd_result.c conn->persistent); conn 477 ext/mysqlnd/mysqlnd_result.c if (conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 478 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_NEXT_RESULT_PENDING); conn 480 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_READY); conn 483 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_NON_RSET_QUERY); conn 490 ext/mysqlnd/mysqlnd_result.c SET_EMPTY_MESSAGE(conn->last_message, conn->last_message_len, conn->persistent); conn 492 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_RSET_QUERY); conn 493 ext/mysqlnd/mysqlnd_result.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 495 ext/mysqlnd/mysqlnd_result.c SET_ERROR_AFF_ROWS(conn); conn 497 ext/mysqlnd/mysqlnd_result.c conn->last_query_type = QUERY_SELECT; conn 498 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_FETCHING_DATA); conn 500 ext/mysqlnd/mysqlnd_result.c conn->field_count = rset_header->field_count; conn 502 ext/mysqlnd/mysqlnd_result.c result = conn->current_result = conn->m->result_init(rset_header->field_count, conn->persistent); conn 511 ext/mysqlnd/mysqlnd_result.c result = stmt->result = conn->m->result_init(rset_header->field_count, stmt->persistent); conn 529 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 534 ext/mysqlnd/mysqlnd_result.c if (FAIL == (ret = result->m.read_result_metadata(result, conn))) { conn 536 ext/mysqlnd/mysqlnd_result.c if (!stmt && conn->current_result) { conn 537 ext/mysqlnd/mysqlnd_result.c mnd_efree(conn->current_result); conn 538 ext/mysqlnd/mysqlnd_result.c conn->current_result = NULL; conn 545 ext/mysqlnd/mysqlnd_result.c fields_eof = conn->protocol->m.get_eof_packet(conn->protocol, FALSE); conn 547 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 551 ext/mysqlnd/mysqlnd_result.c if (FAIL == (ret = PACKET_READ(fields_eof, conn))) { conn 556 ext/mysqlnd/mysqlnd_result.c conn->current_result = NULL; conn 564 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->warning_count = fields_eof->warning_count; conn 572 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->server_status = fields_eof->server_status; conn 580 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(conn->stats, statistic); conn 693 ext/mysqlnd/mysqlnd_result.c if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { conn 694 ext/mysqlnd/mysqlnd_result.c SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 708 ext/mysqlnd/mysqlnd_result.c if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { conn 709 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); conn 716 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(result->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_NORMAL_UNBUF); conn 725 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 726 ext/mysqlnd/mysqlnd_result.c result->conn->stats); conn 758 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*result->conn->error_info); conn 766 ext/mysqlnd/mysqlnd_result.c COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); conn 769 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_READY); conn 775 ext/mysqlnd/mysqlnd_result.c memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); conn 776 ext/mysqlnd/mysqlnd_result.c result->conn->upsert_status->warning_count = row_packet->warning_count; conn 777 ext/mysqlnd/mysqlnd_result.c result->conn->upsert_status->server_status = row_packet->server_status; conn 782 ext/mysqlnd/mysqlnd_result.c if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 783 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); conn 785 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_READY); conn 787 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); conn 812 ext/mysqlnd/mysqlnd_result.c if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { conn 813 ext/mysqlnd/mysqlnd_result.c SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 827 ext/mysqlnd/mysqlnd_result.c if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { conn 828 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); conn 835 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(result->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_NORMAL_UNBUF); conn 844 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 845 ext/mysqlnd/mysqlnd_result.c result->conn->stats); conn 892 ext/mysqlnd/mysqlnd_result.c COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); conn 895 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_READY); conn 901 ext/mysqlnd/mysqlnd_result.c memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); conn 902 ext/mysqlnd/mysqlnd_result.c result->conn->upsert_status->warning_count = row_packet->warning_count; conn 903 ext/mysqlnd/mysqlnd_result.c result->conn->upsert_status->server_status = row_packet->server_status; conn 908 ext/mysqlnd/mysqlnd_result.c if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 909 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); conn 911 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_READY); conn 913 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); conn 928 ext/mysqlnd/mysqlnd_result.c SET_EMPTY_ERROR(*result->conn->error_info); conn 947 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet = result->conn->protocol->m.get_row_packet(result->conn->protocol, FALSE); conn 960 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*result->conn->error_info); conn 992 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 993 ext/mysqlnd/mysqlnd_result.c result->conn->stats); conn 1032 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*result->conn->error_info); conn 1083 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 1084 ext/mysqlnd/mysqlnd_result.c result->conn->stats); conn 1166 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*result->conn->error_info); conn 1174 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 1175 ext/mysqlnd/mysqlnd_result.c result->conn->stats); conn 1269 ext/mysqlnd/mysqlnd_result.c MYSQLND_METHOD(mysqlnd_res, store_result_fetch_data)(MYSQLND_CONN_DATA * const conn, MYSQLND_RES * result, conn 1290 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1298 ext/mysqlnd/mysqlnd_result.c row_packet = conn->protocol->m.get_row_packet(conn->protocol, FALSE); conn 1300 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1313 ext/mysqlnd/mysqlnd_result.c while (FAIL != (ret = PACKET_READ(row_packet, conn)) && !row_packet->eof) { conn 1321 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1327 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1350 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, conn 1357 ext/mysqlnd/mysqlnd_result.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 1358 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->warning_count = row_packet->warning_count; conn 1359 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->server_status = row_packet->server_status; conn 1365 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1372 ext/mysqlnd/mysqlnd_result.c if (conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 1373 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_NEXT_RESULT_PENDING); conn 1375 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_READY); conn 1382 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->affected_rows = set->row_count; conn 1385 ext/mysqlnd/mysqlnd_result.c ret == PASS? "PASS":"FAIL", (uint) set->row_count, conn->upsert_status->warning_count, conn->upsert_status->server_status); conn 1397 ext/mysqlnd/mysqlnd_result.c MYSQLND_CONN_DATA * const conn, conn 1407 ext/mysqlnd/mysqlnd_result.c result->conn = conn->m->get_reference(conn); conn 1410 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_FETCHING_DATA); conn 1415 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1422 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1427 ext/mysqlnd/mysqlnd_result.c ret = result->m.store_result_fetch_data(conn, result, result->meta, row_buffers, flags & MYSQLND_STORE_PS); conn 1431 ext/mysqlnd/mysqlnd_result.c COPY_CLIENT_ERROR(*conn->error_info, result->stored_data->error_info); conn 1433 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1444 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1450 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1465 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->affected_rows = result->stored_data->row_count; conn 1487 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(result->conn->stats, conn 1506 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(result->conn? result->conn->stats : NULL, conn 1623 ext/mysqlnd/mysqlnd_result.c if (PASS != result->stored_data->m.initialize_result_set_rest(result->stored_data, result->meta, result->conn->stats, conn 1624 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native)) conn 1657 ext/mysqlnd/mysqlnd_result.c if (PASS != result->stored_data->m.initialize_result_set_rest(result->stored_data, result->meta, result->conn->stats, conn 1658 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native)) conn 1681 ext/mysqlnd/mysqlnd_result.c if (PASS != result->stored_data->m.initialize_result_set_rest(result->stored_data, result->meta, result->conn->stats, conn 1682 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native)) conn 1786 ext/mysqlnd/mysqlnd_result.c if (result->conn) { conn 1787 ext/mysqlnd/mysqlnd_result.c SET_CLIENT_ERROR(*result->conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, "fetch_all can be used only with buffered sets"); conn 31 ext/mysqlnd/mysqlnd_result.h enum_func_status mysqlnd_query_read_result_set_header(MYSQLND_CONN_DATA * conn, MYSQLND_STMT * stmt); conn 53 ext/mysqlnd/mysqlnd_result_meta.c MYSQLND_METHOD(mysqlnd_res_meta, read_metadata)(MYSQLND_RES_METADATA * const meta, MYSQLND_CONN_DATA * conn) conn 60 ext/mysqlnd/mysqlnd_result_meta.c field_packet = conn->protocol->m.get_result_field_packet(conn->protocol, FALSE); conn 62 ext/mysqlnd/mysqlnd_result_meta.c SET_OOM_ERROR(*conn->error_info); conn 76 ext/mysqlnd/mysqlnd_result_meta.c if (FAIL == PACKET_READ(field_packet, conn)) { conn 81 ext/mysqlnd/mysqlnd_result_meta.c COPY_CLIENT_ERROR(*conn->error_info, field_packet->error_info); conn 406 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND * (*func_mysqlnd_object_factory__clone_connection_object)(MYSQLND * conn); conn 407 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_STMT * (*func_mysqlnd_object_factory__get_prepared_statement)(MYSQLND_CONN_DATA * conn); conn 422 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__init)(MYSQLND_CONN_DATA * conn); conn 423 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__connect)(MYSQLND_CONN_DATA * conn, const char * host, const char * user, const char * passwd, unsigned int passwd_len, const char * db, unsigned int db_len, unsigned int port, const char * socket_or_pipe, unsigned int mysql_flags); conn 424 ext/mysqlnd/mysqlnd_structs.h typedef zend_ulong (*func_mysqlnd_conn_data__escape_string)(MYSQLND_CONN_DATA * const conn, char *newstr, const char *escapestr, size_t escapestr_len); conn 425 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__set_charset)(MYSQLND_CONN_DATA * const conn, const char * const charset); conn 426 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__query)(MYSQLND_CONN_DATA * conn, const char * query, unsigned int query_len); conn 427 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__send_query)(MYSQLND_CONN_DATA * conn, const char *query, unsigned int query_len, enum_mysqlnd_send_query_type type, zval *read_cb, zval *err_cb); conn 428 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__reap_query)(MYSQLND_CONN_DATA * conn, enum_mysqlnd_reap_result_type type); conn 429 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_RES * (*func_mysqlnd_conn_data__use_result)(MYSQLND_CONN_DATA * const conn, const unsigned int flags); conn 430 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_RES * (*func_mysqlnd_conn_data__store_result)(MYSQLND_CONN_DATA * const conn, const unsigned int flags); conn 431 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__next_result)(MYSQLND_CONN_DATA * const conn); conn 432 ext/mysqlnd/mysqlnd_structs.h typedef zend_bool (*func_mysqlnd_conn_data__more_results)(const MYSQLND_CONN_DATA * const conn); conn 434 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_STMT * (*func_mysqlnd_conn_data__stmt_init)(MYSQLND_CONN_DATA * const conn); conn 436 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__shutdown_server)(MYSQLND_CONN_DATA * const conn, uint8_t level); conn 437 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__refresh_server)(MYSQLND_CONN_DATA * const conn, uint8_t options); conn 439 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__ping)(MYSQLND_CONN_DATA * const conn); conn 440 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__kill_connection)(MYSQLND_CONN_DATA * conn, unsigned int pid); conn 441 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__select_db)(MYSQLND_CONN_DATA * const conn, const char * const db, unsigned int db_len); conn 442 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__server_dump_debug_information)(MYSQLND_CONN_DATA * const conn); conn 443 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__change_user)(MYSQLND_CONN_DATA * const conn, const char * user, const char * passwd, const char * db, zend_bool silent, size_t passwd_len); conn 445 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_error_no)(const MYSQLND_CONN_DATA * const conn); conn 446 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_error_str)(const MYSQLND_CONN_DATA * const conn); conn 447 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_sqlstate)(const MYSQLND_CONN_DATA * const conn); conn 448 ext/mysqlnd/mysqlnd_structs.h typedef uint64_t (*func_mysqlnd_conn_data__get_thread_id)(const MYSQLND_CONN_DATA * const conn); conn 449 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn_data__get_statistics)(const MYSQLND_CONN_DATA * const conn, zval *return_value ZEND_FILE_LINE_DC); conn 451 ext/mysqlnd/mysqlnd_structs.h typedef zend_ulong (*func_mysqlnd_conn_data__get_server_version)(const MYSQLND_CONN_DATA * const conn); conn 452 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_server_information)(const MYSQLND_CONN_DATA * const conn); conn 453 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__get_server_statistics)(MYSQLND_CONN_DATA * conn, zend_string **message); conn 454 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_host_information)(const MYSQLND_CONN_DATA * const conn); conn 455 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_protocol_information)(const MYSQLND_CONN_DATA * const conn); conn 456 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_last_message)(const MYSQLND_CONN_DATA * const conn); conn 457 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__charset_name)(const MYSQLND_CONN_DATA * const conn); conn 458 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_RES * (*func_mysqlnd_conn_data__list_fields)(MYSQLND_CONN_DATA * conn, const char * table, const char * achtung_wild); conn 459 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_RES * (*func_mysqlnd_conn_data__list_method)(MYSQLND_CONN_DATA * conn, const char * query, const char * achtung_wild, char *par1); conn 461 ext/mysqlnd/mysqlnd_structs.h typedef uint64_t (*func_mysqlnd_conn_data__get_last_insert_id)(const MYSQLND_CONN_DATA * const conn); conn 462 ext/mysqlnd/mysqlnd_structs.h typedef uint64_t (*func_mysqlnd_conn_data__get_affected_rows)(const MYSQLND_CONN_DATA * const conn); conn 463 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_warning_count)(const MYSQLND_CONN_DATA * const conn); conn 465 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_field_count)(const MYSQLND_CONN_DATA * const conn); conn 467 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_server_status)(const MYSQLND_CONN_DATA * const conn); conn 468 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__set_server_option)(MYSQLND_CONN_DATA * const conn, enum_mysqlnd_server_option option); conn 469 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__set_client_option)(MYSQLND_CONN_DATA * const conn, enum_mysqlnd_option option, const char * const value); conn 470 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn_data__free_contents)(MYSQLND_CONN_DATA * conn);/* private */ conn 471 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn_data__free_options)(MYSQLND_CONN_DATA * conn); /* private */ conn 472 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn_data__dtor)(MYSQLND_CONN_DATA * conn); /* private */ conn 474 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__query_read_result_set_header)(MYSQLND_CONN_DATA * conn, MYSQLND_STMT * stmt); conn 476 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_CONN_DATA * (*func_mysqlnd_conn_data__get_reference)(MYSQLND_CONN_DATA * const conn); conn 477 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__free_reference)(MYSQLND_CONN_DATA * const conn); conn 35 ext/mysqlnd/mysqlnd_wireprotocol.c #define PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_size, packet_type_as_text, packet_type) \ conn 38 ext/mysqlnd/mysqlnd_wireprotocol.c if (FAIL == mysqlnd_read_header((conn)->net, &((packet)->header), (conn)->stats, ((conn)->error_info))) {\ conn 39 ext/mysqlnd/mysqlnd_wireprotocol.c CONN_SET_STATE(conn, CONN_QUIT_SENT); \ conn 40 ext/mysqlnd/mysqlnd_wireprotocol.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone);\ conn 50 ext/mysqlnd/mysqlnd_wireprotocol.c if (FAIL == conn->net->data->m.receive_ex((conn)->net, (buf), (packet)->header.size, (conn)->stats, ((conn)->error_info))) { \ conn 51 ext/mysqlnd/mysqlnd_wireprotocol.c CONN_SET_STATE(conn, CONN_QUIT_SENT); \ conn 52 ext/mysqlnd/mysqlnd_wireprotocol.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone);\ conn 57 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, packet_type_to_statistic_byte_count[packet_type], \ conn 321 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_greet_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 331 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "greeting", PROT_GREET_PACKET); conn 483 ext/mysqlnd/mysqlnd_wireprotocol.c size_t php_mysqlnd_auth_write(void * _packet, MYSQLND_CONN_DATA * conn) conn 519 ext/mysqlnd/mysqlnd_wireprotocol.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, msg); conn 579 ext/mysqlnd/mysqlnd_wireprotocol.c zend_hash_move_forward_ex(conn->options->connect_attr, &pos_value); conn 618 ext/mysqlnd/mysqlnd_wireprotocol.c zend_hash_move_forward_ex(conn->options->connect_attr, &pos_value); conn 646 ext/mysqlnd/mysqlnd_wireprotocol.c if (PASS != conn->m->simple_command(conn, COM_CHANGE_USER, buffer + MYSQLND_HEADER_SIZE, p - buffer - MYSQLND_HEADER_SIZE, conn 653 ext/mysqlnd/mysqlnd_wireprotocol.c size_t sent = conn->net->data->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info); conn 655 ext/mysqlnd/mysqlnd_wireprotocol.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 679 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_auth_response_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 682 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.buffer? conn->net->cmd_buffer.length: AUTH_RESP_BUFFER_SIZE; conn 683 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = conn->net->cmd_buffer.buffer? (zend_uchar *) conn->net->cmd_buffer.buffer : local_buf; conn 693 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); conn 799 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_change_auth_response_write(void * _packet, MYSQLND_CONN_DATA * conn) conn 802 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar * buffer = conn->net->cmd_buffer.length >= packet->auth_data_len? conn->net->cmd_buffer.buffer : mnd_emalloc(packet->auth_data_len); conn 813 ext/mysqlnd/mysqlnd_wireprotocol.c size_t sent = conn->net->data->m.send_ex(conn->net, buffer, p - buffer - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info); conn 814 ext/mysqlnd/mysqlnd_wireprotocol.c if (buffer != conn->net->cmd_buffer.buffer) { conn 818 ext/mysqlnd/mysqlnd_wireprotocol.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 842 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_ok_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 845 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.buffer? conn->net->cmd_buffer.length : OK_BUFFER_SIZE; conn 846 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = conn->net->cmd_buffer.buffer? (zend_uchar *) conn->net->cmd_buffer.buffer : local_buf; conn 854 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); conn 867 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 928 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_eof_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 937 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 938 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 944 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "EOF", PROT_EOF_PACKET); conn 1005 ext/mysqlnd/mysqlnd_wireprotocol.c size_t php_mysqlnd_cmd_write(void * _packet, MYSQLND_CONN_DATA * conn) conn 1009 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_NET * net = conn->net; conn 1025 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_PACKETS_SENT_CMD); conn 1035 ext/mysqlnd/mysqlnd_wireprotocol.c sent = net->data->m.send_ex(net, buffer, 1, conn->stats, conn->error_info); conn 1050 ext/mysqlnd/mysqlnd_wireprotocol.c sent = net->data->m.send_ex(net, tmp, tmp_len - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info); conn 1052 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CMD_BUFFER_TOO_SMALL); conn 1062 ext/mysqlnd/mysqlnd_wireprotocol.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 1083 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_rset_header_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 1086 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 1087 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 1095 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "resultset header", PROT_RSET_HEADER_PACKET); conn 1110 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1134 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1161 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1222 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_rset_field_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 1226 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length, total_len = 0; conn 1227 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 1237 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "field", PROT_RSET_FLD_PACKET); conn 1339 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1350 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1436 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_row_ex(MYSQLND_CONN_DATA * conn, MYSQLND_MEMORY_POOL * result_set_memory_pool, conn 1458 ext/mysqlnd/mysqlnd_wireprotocol.c if (FAIL == mysqlnd_read_header(conn->net, &header, conn->stats, conn->error_info)) { conn 1483 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1491 ext/mysqlnd/mysqlnd_wireprotocol.c if (PASS != (ret = conn->net->data->m.receive_ex(conn->net, p, header.size, conn->stats, conn->error_info))) { conn 1788 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_rowp_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 1803 ext/mysqlnd/mysqlnd_wireprotocol.c ret = php_mysqlnd_read_row_ex(conn, packet->result_set_memory_pool, &packet->row_buffer, &data_size, conn 1809 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, packet_type_to_statistic_byte_count[PROT_ROW_PACKET], conn 1842 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC(conn->stats, conn 1866 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC(conn->stats, conn 1908 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_stats_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 1911 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 1912 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 1916 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "statistics", PROT_STATS_PACKET); conn 1950 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_prepare_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 1953 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 1954 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 1962 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "prepare", PROT_PREPARE_RESP_PACKET); conn 2038 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_chg_user_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 2041 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 2042 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 2049 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "change user response", PROT_CHG_USER_RESP_PACKET); conn 2126 ext/mysqlnd/mysqlnd_wireprotocol.c size_t php_mysqlnd_sha256_pk_request_write(void * _packet, MYSQLND_CONN_DATA * conn) conn 2134 ext/mysqlnd/mysqlnd_wireprotocol.c sent = conn->net->data->m.send_ex(conn->net, buffer, 1, conn->stats, conn->error_info); conn 2157 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_sha256_pk_request_response_read(void * _packet, MYSQLND_CONN_DATA * conn) conn 2167 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "SHA256_PK_REQUEST_RESPONSE", PROT_SHA256_PK_REQUEST_RESPONSE_PACKET); conn 39 ext/mysqlnd/mysqlnd_wireprotocol.h #define PACKET_WRITE(packet, conn) ((packet)->header.m->write_to_net((packet), (conn))) conn 40 ext/mysqlnd/mysqlnd_wireprotocol.h #define PACKET_READ(packet, conn) ((packet)->header.m->read_from_net((packet), (conn))) conn 54 ext/mysqlnd/mysqlnd_wireprotocol.h enum_func_status (*read_from_net)(void * packet, MYSQLND_CONN_DATA * conn); conn 55 ext/mysqlnd/mysqlnd_wireprotocol.h size_t (*write_to_net)(void * packet, MYSQLND_CONN_DATA * conn); conn 163 ext/odbc/birdstep.c #define PHP_BIRDSTEP_CHK_LNK(id) if (!(conn = birdstep_find_conn(list, id))) { php_error_docref(NULL, E_WARNING, "Birdstep: Not connection index (%ld)", id); RETURN_FALSE; } conn 168 ext/odbc/birdstep.c VConn *conn = (VConn *)rsrc->ptr; conn 170 ext/odbc/birdstep.c if ( conn ) { conn 171 ext/odbc/birdstep.c efree(conn); conn 227 ext/odbc/birdstep.c static int birdstep_add_conn(HashTable *list,VConn *conn,HDBC hdbc) conn 231 ext/odbc/birdstep.c ind = zend_list_insert(conn,php_birdstep_module.le_link); conn 232 ext/odbc/birdstep.c conn->hdbc = hdbc; conn 233 ext/odbc/birdstep.c conn->index = ind; conn 240 ext/odbc/birdstep.c VConn *conn; conn 243 ext/odbc/birdstep.c conn = zend_list_find(ind,&type); conn 244 ext/odbc/birdstep.c if ( !conn || type != php_birdstep_module.le_link ) { conn 247 ext/odbc/birdstep.c return(conn); conn 255 ext/odbc/birdstep.c static int birdstep_add_result(HashTable *list,Vresult *res,VConn *conn) conn 260 ext/odbc/birdstep.c res->conn = conn; conn 328 ext/odbc/birdstep.c VConn *conn; conn 336 ext/odbc/birdstep.c SQLDisconnect(conn->hdbc); conn 337 ext/odbc/birdstep.c SQLFreeConnect(conn->hdbc); conn 351 ext/odbc/birdstep.c VConn *conn; conn 364 ext/odbc/birdstep.c stat = SQLAllocStmt(conn->hdbc,&res->hstmt); conn 420 ext/odbc/birdstep.c indx = birdstep_add_result(list,res,conn); conn 577 ext/odbc/birdstep.c VConn *conn; conn 585 ext/odbc/birdstep.c stat = SQLSetConnectOption(conn->hdbc,SQL_AUTOCOMMIT,SQL_AUTOCOMMIT_ON); conn 600 ext/odbc/birdstep.c VConn *conn; conn 608 ext/odbc/birdstep.c stat = SQLSetConnectOption(conn->hdbc,SQL_AUTOCOMMIT,SQL_AUTOCOMMIT_OFF); conn 623 ext/odbc/birdstep.c VConn *conn; conn 631 ext/odbc/birdstep.c stat = SQLTransact(NULL,conn->hdbc,SQL_COMMIT); conn 646 ext/odbc/birdstep.c VConn *conn; conn 654 ext/odbc/birdstep.c stat = SQLTransact(NULL,conn->hdbc,SQL_ROLLBACK); conn 46 ext/odbc/php_birdstep.h VConn *conn; conn 479 ext/odbc/php_odbc.c odbc_connection *conn = (odbc_connection *)rsrc->ptr; conn 484 ext/odbc/php_odbc.c if (res->conn_ptr == conn) { conn 490 ext/odbc/php_odbc.c safe_odbc_disconnect(conn->hdbc); conn 491 ext/odbc/php_odbc.c SQLFreeConnect(conn->hdbc); conn 492 ext/odbc/php_odbc.c SQLFreeEnv(conn->henv); conn 493 ext/odbc/php_odbc.c efree(conn); conn 504 ext/odbc/php_odbc.c odbc_connection *conn = (odbc_connection *)rsrc->ptr; conn 509 ext/odbc/php_odbc.c if (res->conn_ptr == conn) { conn 515 ext/odbc/php_odbc.c safe_odbc_disconnect(conn->hdbc); conn 516 ext/odbc/php_odbc.c SQLFreeConnect(conn->hdbc); conn 517 ext/odbc/php_odbc.c SQLFreeEnv(conn->henv); conn 518 ext/odbc/php_odbc.c free(conn); conn 878 ext/odbc/php_odbc.c ODBC_SQL_CONN_T conn; conn 882 ext/odbc/php_odbc.c conn = conn_resource->hdbc; conn 885 ext/odbc/php_odbc.c conn = SQL_NULL_HDBC; conn 893 ext/odbc/php_odbc.c rc = SQLError(henv, conn, stmt, state, &error, errormsg, sizeof(errormsg)-1, &errormsgsize); conn 1049 ext/odbc/php_odbc.c odbc_connection *conn; conn 1057 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 1061 ext/odbc/php_odbc.c rc = SQLTransact(conn->henv, conn->hdbc, (SQLUSMALLINT)((type)?SQL_COMMIT:SQL_ROLLBACK)); conn 1063 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLTransact"); conn 1188 ext/odbc/php_odbc.c odbc_connection *conn; conn 1199 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 1208 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 1216 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 1224 ext/odbc/php_odbc.c rc = SQLGetInfo(conn->hdbc, SQL_FETCH_DIRECTION, (void *) &scrollopts, sizeof(scrollopts), NULL); conn 1242 ext/odbc/php_odbc.c odbc_sql_error(conn, result->stmt, "SQLPrepare"); conn 1245 ext/odbc/php_odbc.c odbc_sql_error(conn, result->stmt, "SQLPrepare"); conn 1261 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 1567 ext/odbc/php_odbc.c odbc_connection *conn; conn 1582 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(zv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 1587 ext/odbc/php_odbc.c rc = SQLDataSources(conn->henv, conn 1598 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLDataSources"); conn 1627 ext/odbc/php_odbc.c odbc_connection *conn; conn 1639 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 1645 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 1653 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 1661 ext/odbc/php_odbc.c rc = SQLGetInfo(conn->hdbc, SQL_FETCH_DIRECTION, (void *) &scrollopts, sizeof(scrollopts), NULL); conn 1679 ext/odbc/php_odbc.c odbc_sql_error(conn, result->stmt, "SQLExecDirect"); conn 1697 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 2433 ext/odbc/php_odbc.c int odbc_sqlconnect(odbc_connection **conn, char *db, char *uid, char *pwd, int cur_opt, int persistent) conn 2437 ext/odbc/php_odbc.c *conn = (odbc_connection *)pemalloc(sizeof(odbc_connection), persistent); conn 2438 ext/odbc/php_odbc.c (*conn)->persistent = persistent; conn 2439 ext/odbc/php_odbc.c SQLAllocEnv(&((*conn)->henv)); conn 2440 ext/odbc/php_odbc.c SQLAllocConnect((*conn)->henv, &((*conn)->hdbc)); conn 2443 ext/odbc/php_odbc.c SQLSetConnectOption((*conn)->hdbc, SQL_TRANSLATE_OPTION, conn 2480 ext/odbc/php_odbc.c rc = SQLDriverConnect((*conn)->hdbc, NULL, lpszConnStr, SQL_NTS, lpszConnStr, CONNSTRSIZE, &cbszConnStr, SQL_DRIVER_NOPROMPT); conn 2490 ext/odbc/php_odbc.c rc = SQLDriverConnect((*conn)->hdbc, NULL, db, SQL_NTS, dsnbuf, sizeof(dsnbuf) - 1, &dsnbuflen, SQL_DRIVER_NOPROMPT); conn 2494 ext/odbc/php_odbc.c rc = SQLSetConnectOption((*conn)->hdbc, SQL_ODBC_CURSORS, cur_opt); conn 2496 ext/odbc/php_odbc.c odbc_sql_error(*conn, SQL_NULL_HSTMT, "SQLSetConnectOption"); conn 2497 ext/odbc/php_odbc.c SQLFreeConnect((*conn)->hdbc); conn 2498 ext/odbc/php_odbc.c pefree(*conn, persistent); conn 2526 ext/odbc/php_odbc.c rc = SQLDriverConnect((*conn)->hdbc, NULL, ldb, strlen(ldb), dsnbuf, sizeof(dsnbuf) - 1, &dsnbuflen, SQL_DRIVER_NOPROMPT); conn 2528 ext/odbc/php_odbc.c rc = SQLConnect((*conn)->hdbc, db, SQL_NTS, uid, SQL_NTS, pwd, SQL_NTS); conn 2536 ext/odbc/php_odbc.c rc = SQLConnect((*conn)->hdbc, db, SQL_NTS, uid, SQL_NTS, pwd, SQL_NTS); conn 2541 ext/odbc/php_odbc.c odbc_sql_error(*conn, SQL_NULL_HSTMT, "SQLConnect"); conn 2542 ext/odbc/php_odbc.c SQLFreeConnect((*conn)->hdbc); conn 2543 ext/odbc/php_odbc.c pefree((*conn), persistent); conn 2736 ext/odbc/php_odbc.c odbc_connection *conn; conn 2744 ext/odbc/php_odbc.c conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn); conn 2752 ext/odbc/php_odbc.c if (res->conn_ptr == conn) { conn 2989 ext/odbc/php_odbc.c odbc_connection *conn; conn 2998 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3003 ext/odbc/php_odbc.c rc = SQLSetConnectOption(conn->hdbc, SQL_AUTOCOMMIT, (pv_onoff) ? SQL_AUTOCOMMIT_ON : SQL_AUTOCOMMIT_OFF); conn 3005 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "Set autocommit"); conn 3012 ext/odbc/php_odbc.c rc = SQLGetConnectOption(conn->hdbc, SQL_AUTOCOMMIT, (PTR)&status); conn 3014 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "Get commit status"); conn 3041 ext/odbc/php_odbc.c odbc_connection *conn; conn 3057 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_handle), "ODBC-Link", le_conn, le_pconn))) { conn 3062 ext/odbc/php_odbc.c strlcpy(ZSTR_VAL(ptr), conn->laststate, len+1); conn 3064 ext/odbc/php_odbc.c strlcpy(ZSTR_VAL(ptr), conn->lasterrormsg, len+1); conn 3104 ext/odbc/php_odbc.c odbc_connection *conn; conn 3116 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_handle), "ODBC-Link", le_conn, le_pconn))) { conn 3120 ext/odbc/php_odbc.c if (conn->persistent) { conn 3124 ext/odbc/php_odbc.c rc = SQLSetConnectOption(conn->hdbc, (unsigned short) pv_opt, pv_val); conn 3126 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SetConnectOption"); conn 3162 ext/odbc/php_odbc.c odbc_connection *conn; conn 3172 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3178 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3186 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3203 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLTables"); conn 3219 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3231 ext/odbc/php_odbc.c odbc_connection *conn; conn 3241 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3247 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3255 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3274 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLColumns"); conn 3290 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3303 ext/odbc/php_odbc.c odbc_connection *conn; conn 3313 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3319 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3327 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3339 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLColumnPrivileges"); conn 3355 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3369 ext/odbc/php_odbc.c odbc_connection *conn; conn 3391 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3397 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3405 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3419 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLForeignKeys"); conn 3435 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3449 ext/odbc/php_odbc.c odbc_connection *conn; conn 3459 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3465 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3473 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3481 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLGetTypeInfo"); conn 3497 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3509 ext/odbc/php_odbc.c odbc_connection *conn; conn 3518 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3524 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3532 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3543 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLPrimaryKeys"); conn 3559 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3572 ext/odbc/php_odbc.c odbc_connection *conn; conn 3586 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3592 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3600 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3612 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLProcedureColumns"); conn 3628 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3642 ext/odbc/php_odbc.c odbc_connection *conn; conn 3655 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3661 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3669 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3680 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLProcedures"); conn 3696 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3710 ext/odbc/php_odbc.c odbc_connection *conn; conn 3725 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3731 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3739 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3753 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLSpecialColumns"); conn 3769 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3782 ext/odbc/php_odbc.c odbc_connection *conn; conn 3796 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3802 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3810 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3823 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLStatistics"); conn 3839 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3852 ext/odbc/php_odbc.c odbc_connection *conn; conn 3861 ext/odbc/php_odbc.c if (!(conn = (odbc_connection *)zend_fetch_resource2(Z_RES_P(pv_conn), "ODBC-Link", le_conn, le_pconn))) { conn 3867 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3875 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3886 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLTablePrivileges"); conn 3902 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 281 ext/odbc/php_odbc_includes.h int odbc_add_conn(HashTable *list, HDBC conn); conn 140 ext/pdo_pgsql/pgsql_driver.c return lo_write(self->conn, self->lfd, (char*)buf, count); conn 146 ext/pdo_pgsql/pgsql_driver.c return lo_read(self->conn, self->lfd, buf, count); conn 154 ext/pdo_pgsql/pgsql_driver.c lo_close(self->conn, self->lfd); conn 171 ext/pdo_pgsql/pgsql_driver.c zend_off_t pos = lo_lseek64(self->conn, self->lfd, offset, whence); conn 173 ext/pdo_pgsql/pgsql_driver.c zend_off_t pos = lo_lseek(self->conn, self->lfd, offset, whence); conn 200 ext/pdo_pgsql/pgsql_driver.c self->conn = H->server; conn 98 ext/pdo_pgsql/php_pdo_pgsql_int.h PGconn *conn; conn 790 ext/pgsql/pgsql.c #define PQescapeStringConn(conn, to, from, len, error) PQescapeString(to, from, len) conn 794 ext/pgsql/pgsql.c #define PGSQLescapeLiteral(conn, str, len) PQescapeLiteral(conn, str, len) conn 795 ext/pgsql/pgsql.c #define PGSQLescapeIdentifier(conn, str, len) PQescapeIdentifier(conn, str, len) conn 798 ext/pgsql/pgsql.c #define PGSQLescapeLiteral(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 1, 0) conn 799 ext/pgsql/pgsql.c #define PGSQLescapeLiteral2(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 1, 1) conn 800 ext/pgsql/pgsql.c #define PGSQLescapeIdentifier(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 0, 0) conn 804 ext/pgsql/pgsql.c static char *php_pgsql_PQescapeInternal(PGconn *conn, const char *str, size_t len, int escape_literal, int safe) /* {{{ */ conn 809 ext/pgsql/pgsql.c if (!conn) { conn 824 ext/pgsql/pgsql.c new_len = PQescapeStringConn(conn, tmp, str, len, NULL); conn 833 ext/pgsql/pgsql.c encoding = (char *) pg_encoding_to_char(PQclientEncoding(conn)); conn 1887 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 2022 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 2106 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 2226 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 2456 ext/pgsql/pgsql.c if ((tmp_res = PQexec(pg_result->conn, ZSTR_VAL(querystr.s))) == NULL || PQresultStatus(tmp_res) != PGRES_TUPLES_OK) { conn 2525 ext/pgsql/pgsql.c char *name = get_field_name(pg_result->conn, PQftype(pgsql_result, (int)field), &EG(regular_list)); conn 3437 ext/pgsql/pgsql.c pgsql_lofp->conn = pgsql; conn 3448 ext/pgsql/pgsql.c pgsql_lofp->conn = pgsql; conn 3470 ext/pgsql/pgsql.c if (lo_close((PGconn *)pgsql->conn, pgsql->lofd) < 0) { conn 3508 ext/pgsql/pgsql.c if ((nbytes = lo_read((PGconn *)pgsql->conn, pgsql->lofd, ZSTR_VAL(buf), ZSTR_LEN(buf)))<0) { conn 3554 ext/pgsql/pgsql.c if ((nbytes = lo_write((PGconn *)pgsql->conn, pgsql->lofd, str, len)) == -1) { conn 3581 ext/pgsql/pgsql.c while ((nbytes = lo_read((PGconn *)pgsql->conn, pgsql->lofd, buf, PGSQL_LO_READ_BUF_SIZE))>0) { conn 3793 ext/pgsql/pgsql.c if (PQserverVersion((PGconn *)pgsql->conn) >= 90300) { conn 3794 ext/pgsql/pgsql.c result = lo_lseek64((PGconn *)pgsql->conn, pgsql->lofd, offset, (int)whence); conn 3796 ext/pgsql/pgsql.c result = lo_lseek((PGconn *)pgsql->conn, pgsql->lofd, (int)offset, (int)whence); conn 3799 ext/pgsql/pgsql.c result = lo_lseek((PGconn *)pgsql->conn, pgsql->lofd, offset, whence); conn 3827 ext/pgsql/pgsql.c if (PQserverVersion((PGconn *)pgsql->conn) >= 90300) { conn 3828 ext/pgsql/pgsql.c offset = lo_tell64((PGconn *)pgsql->conn, pgsql->lofd); conn 3830 ext/pgsql/pgsql.c offset = lo_tell((PGconn *)pgsql->conn, pgsql->lofd); conn 3833 ext/pgsql/pgsql.c offset = lo_tell((PGconn *)pgsql->conn, pgsql->lofd); conn 3859 ext/pgsql/pgsql.c if (PQserverVersion((PGconn *)pgsql->conn) >= 90300) { conn 3860 ext/pgsql/pgsql.c result = lo_truncate64((PGconn *)pgsql->conn, pgsql->lofd, size); conn 3862 ext/pgsql/pgsql.c result = lo_truncate((PGconn *)pgsql->conn, pgsql->lofd, size); conn 3865 ext/pgsql/pgsql.c result = lo_truncate((PGconn *)pgsql->conn, pgsql->lofd, size); conn 5220 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 6722 ext/pgsql/pgsql.c pgsql_handle->conn = pg_link; conn 287 ext/pgsql/php_pgsql.h PGconn *conn; conn 292 ext/pgsql/php_pgsql.h PGconn *conn; conn 44 netware/start.c int (*readRoutineP)( int conn, void *fileHandle, size_t offset,