conn 123 ext/mysql/php_mysql.c MYSQL *conn; conn 131 ext/mysql/php_mysql.c mysql_set_server_option(mysql->conn, MYSQL_OPTION_MULTI_STATEMENTS_OFF); \ conn 440 ext/mysql/php_mysql.c if (mysql_select_db(mysql->conn, db) != 0) { conn 456 ext/mysql/php_mysql.c mysql_close(link->conn); conn 471 ext/mysql/php_mysql.c mysql_close(link->conn); conn 549 ext/mysql/php_mysql.c return mysql->conn; conn 645 ext/mysql/php_mysql.c mysqlnd_end_psession(((php_mysql_conn *) le->ptr)->conn); conn 880 ext/mysql/php_mysql.c mysql->conn = mysql_init(NULL); conn 882 ext/mysql/php_mysql.c mysql->conn = mysqlnd_init(MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA, persistent); conn 886 ext/mysql/php_mysql.c mysql_options(mysql->conn, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&connect_timeout); conn 889 ext/mysql/php_mysql.c if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL) conn 891 ext/mysql/php_mysql.c if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags, MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA TSRMLS_CC) == NULL) conn 898 ext/mysql/php_mysql.c MySG(connect_error) = estrdup(mysql_error(mysql->conn)); conn 901 ext/mysql/php_mysql.c MySG(connect_errno) = mysql_errno(mysql->conn); conn 907 ext/mysql/php_mysql.c mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile)); conn 932 ext/mysql/php_mysql.c mysqlnd_end_psession(mysql->conn); conn 934 ext/mysql/php_mysql.c if (mysql_ping(mysql->conn)) { conn 935 ext/mysql/php_mysql.c if (mysql_errno(mysql->conn) == 2006) { conn 937 ext/mysql/php_mysql.c if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL) conn 939 ext/mysql/php_mysql.c if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags, MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA TSRMLS_CC) == NULL) conn 947 ext/mysql/php_mysql.c mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile)); conn 951 ext/mysql/php_mysql.c mysqlnd_restart_psession(mysql->conn); conn 999 ext/mysql/php_mysql.c mysql->conn = mysql_init(NULL); conn 1001 ext/mysql/php_mysql.c mysql->conn = mysqlnd_init(MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA, persistent); conn 1003 ext/mysql/php_mysql.c if (!mysql->conn) { conn 1012 ext/mysql/php_mysql.c mysql_options(mysql->conn, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&connect_timeout); conn 1016 ext/mysql/php_mysql.c if (mysql_real_connect(mysql->conn, host, user, passwd, NULL, port, socket, client_flags)==NULL) conn 1018 ext/mysql/php_mysql.c if (mysqlnd_connect(mysql->conn, host, user, passwd, passwd_len, NULL, 0, port, socket, client_flags, MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA TSRMLS_CC) == NULL) conn 1025 ext/mysql/php_mysql.c MySG(connect_error) = estrdup(mysql_error(mysql->conn)); conn 1028 ext/mysql/php_mysql.c MySG(connect_errno) = mysql_errno(mysql->conn); conn 1032 ext/mysql/php_mysql.c mysqlnd_close(mysql->conn, MYSQLND_CLOSE_DISCONNECTED); conn 1038 ext/mysql/php_mysql.c mysql_options(mysql->conn, MYSQL_OPT_LOCAL_INFILE, (char *)&MySG(allow_local_infile)); conn 1111 ext/mysql/php_mysql.c mysqlnd_end_psession(mysql->conn); conn 1192 ext/mysql/php_mysql.c RETURN_STRING((char *)mysql_get_host_info(mysql->conn),1); conn 1215 ext/mysql/php_mysql.c RETURN_LONG(mysql_get_proto_info(mysql->conn)); conn 1238 ext/mysql/php_mysql.c RETURN_STRING((char *)mysql_get_server_info(mysql->conn),1); conn 1262 ext/mysql/php_mysql.c if ((str = (char *)mysql_info(mysql->conn))) { conn 1288 ext/mysql/php_mysql.c RETURN_LONG((long) mysql_thread_id(mysql->conn)); conn 1316 ext/mysql/php_mysql.c if ((stat = (char *)mysql_stat(mysql->conn))) { conn 1319 ext/mysql/php_mysql.c if (mysqlnd_stat(mysql->conn, &stat, &stat_len) == PASS) { conn 1346 ext/mysql/php_mysql.c RETURN_STRING((char *)mysql_character_set_name(mysql->conn), 1); conn 1372 ext/mysql/php_mysql.c if (!mysql_set_character_set(mysql->conn, csname)) { conn 1406 ext/mysql/php_mysql.c if (mysql_create_db(mysql->conn, db)==0) { conn 1435 ext/mysql/php_mysql.c if (mysql_drop_db(mysql->conn, db)==0) { conn 1472 ext/mysql/php_mysql.c mysql_real_query(mysql->conn, newquery, newql); conn 1474 ext/mysql/php_mysql.c if (mysql_errno(mysql->conn)) { conn 1475 ext/mysql/php_mysql.c php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn)); conn 1479 ext/mysql/php_mysql.c mysql_result = mysql_use_result(mysql->conn); conn 1495 ext/mysql/php_mysql.c if (mysql_real_query(mysql->conn, query, query_len)!=0) { conn 1498 ext/mysql/php_mysql.c if (mysql_errno(mysql->conn)){ conn 1499 ext/mysql/php_mysql.c php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn)); conn 1505 ext/mysql/php_mysql.c if (mysql_query(mysql->conn, query)!=0) { conn 1508 ext/mysql/php_mysql.c if (mysql_errno(mysql->conn)){ conn 1509 ext/mysql/php_mysql.c php_error_docref("http://www.mysql.com/doc" TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql->conn)); conn 1516 ext/mysql/php_mysql.c mysql_result=mysql_use_result(mysql->conn); conn 1518 ext/mysql/php_mysql.c mysql_result=mysql_store_result(mysql->conn); conn 1521 ext/mysql/php_mysql.c if (PHP_MYSQL_VALID_RESULT(mysql->conn)) { /* query should have returned rows */ conn 1625 ext/mysql/php_mysql.c if ((mysql_result=mysql_list_dbs(mysql->conn, NULL))==NULL) { conn 1663 ext/mysql/php_mysql.c if ((mysql_result=mysql_list_tables(mysql->conn, NULL))==NULL) { conn 1701 ext/mysql/php_mysql.c if ((mysql_result=mysql_list_fields(mysql->conn, table, NULL))==NULL) { conn 1732 ext/mysql/php_mysql.c mysql_result = mysql_list_processes(mysql->conn); conn 1769 ext/mysql/php_mysql.c RETURN_STRING((char *)mysql_error(mysql->conn), 1); conn 1800 ext/mysql/php_mysql.c RETURN_LONG(mysql_errno(mysql->conn)); conn 1826 ext/mysql/php_mysql.c Z_LVAL_P(return_value) = (long) mysql_affected_rows(mysql->conn); conn 1879 ext/mysql/php_mysql.c new_str_len = mysql_real_escape_string(mysql->conn, new_str, str, str_len); conn 1906 ext/mysql/php_mysql.c Z_LVAL_P(return_value) = (long) mysql_insert_id(mysql->conn); conn 2673 ext/mysql/php_mysql.c RETURN_BOOL(! mysql_ping(mysql->conn)); conn 41 ext/mysqli/mysqli_api.c static void mysqli_tx_cor_options_to_string(const MYSQL * const conn, smart_str * str, const unsigned int mode) conn 114 ext/mysqli/mysqli_api.c static int mysqli_commit_or_rollback_libmysql(MYSQL * conn, zend_bool commit, const unsigned int mode, const char * const name TSRMLS_DC) conn 118 ext/mysqli/mysqli_api.c mysqli_tx_cor_options_to_string(conn, &tmp_str, mode); conn 134 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 1068 ext/mysqli/mysqli_nonapi.c static int mysqli_begin_transaction_libmysql(MYSQL * conn, const unsigned int mode, const char * const name TSRMLS_DC) conn 1080 ext/mysqli/mysqli_nonapi.c if (mysql_get_server_version(conn) < 50605L) { conn 1108 ext/mysqli/mysqli_nonapi.c ret = mysql_real_query(conn, query, query_len); conn 1159 ext/mysqli/mysqli_nonapi.c static int mysqli_savepoint_libmysql(MYSQL * conn, const char * const name, zend_bool release) conn 1164 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 TSRMLS_DC) 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 TSRMLS_DC) conn 112 ext/mysqlnd/mysqlnd.c zend_bool pers = conn->persistent; conn 116 ext/mysqlnd/mysqlnd.c mysqlnd_local_infile_default(conn); conn 117 ext/mysqlnd/mysqlnd.c if (conn->current_result) { conn 118 ext/mysqlnd/mysqlnd.c conn->current_result->m.free_result(conn->current_result, TRUE TSRMLS_CC); conn 119 ext/mysqlnd/mysqlnd.c conn->current_result = NULL; conn 122 ext/mysqlnd/mysqlnd.c if (conn->net) { conn 123 ext/mysqlnd/mysqlnd.c conn->net->data->m.free_contents(conn->net TSRMLS_CC); conn 128 ext/mysqlnd/mysqlnd.c if (conn->host) { conn 129 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->host, pers); conn 130 ext/mysqlnd/mysqlnd.c conn->host = NULL; conn 132 ext/mysqlnd/mysqlnd.c if (conn->user) { conn 133 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->user, pers); conn 134 ext/mysqlnd/mysqlnd.c conn->user = NULL; conn 136 ext/mysqlnd/mysqlnd.c if (conn->passwd) { conn 137 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->passwd, pers); conn 138 ext/mysqlnd/mysqlnd.c conn->passwd = NULL; conn 140 ext/mysqlnd/mysqlnd.c if (conn->connect_or_select_db) { conn 141 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->connect_or_select_db, pers); conn 142 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db = NULL; conn 144 ext/mysqlnd/mysqlnd.c if (conn->unix_socket) { conn 145 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->unix_socket, pers); conn 146 ext/mysqlnd/mysqlnd.c conn->unix_socket = NULL; conn 148 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("scheme=%s", conn->scheme); conn 149 ext/mysqlnd/mysqlnd.c if (conn->scheme) { conn 150 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->scheme, pers); conn 151 ext/mysqlnd/mysqlnd.c conn->scheme = NULL; conn 153 ext/mysqlnd/mysqlnd.c if (conn->server_version) { conn 154 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->server_version, pers); conn 155 ext/mysqlnd/mysqlnd.c conn->server_version = NULL; conn 157 ext/mysqlnd/mysqlnd.c if (conn->host_info) { conn 158 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->host_info, pers); conn 159 ext/mysqlnd/mysqlnd.c conn->host_info = NULL; conn 161 ext/mysqlnd/mysqlnd.c if (conn->auth_plugin_data) { conn 162 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->auth_plugin_data, pers); conn 163 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data = NULL; conn 165 ext/mysqlnd/mysqlnd.c if (conn->last_message) { conn 166 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->last_message, pers); conn 167 ext/mysqlnd/mysqlnd.c conn->last_message = NULL; conn 169 ext/mysqlnd/mysqlnd.c if (conn->error_info->error_list) { conn 170 ext/mysqlnd/mysqlnd.c zend_llist_clean(conn->error_info->error_list); conn 171 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->error_info->error_list, pers); conn 172 ext/mysqlnd/mysqlnd.c conn->error_info->error_list = NULL; conn 174 ext/mysqlnd/mysqlnd.c conn->charset = NULL; conn 175 ext/mysqlnd/mysqlnd.c conn->greet_charset = NULL; conn 184 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, dtor)(MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 187 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 189 ext/mysqlnd/mysqlnd.c conn->m->free_contents(conn TSRMLS_CC); conn 190 ext/mysqlnd/mysqlnd.c conn->m->free_options(conn TSRMLS_CC); conn 192 ext/mysqlnd/mysqlnd.c if (conn->net) { conn 193 ext/mysqlnd/mysqlnd.c mysqlnd_net_free(conn->net, conn->stats, conn->error_info TSRMLS_CC); conn 194 ext/mysqlnd/mysqlnd.c conn->net = NULL; conn 197 ext/mysqlnd/mysqlnd.c if (conn->protocol) { conn 198 ext/mysqlnd/mysqlnd.c mysqlnd_protocol_free(conn->protocol TSRMLS_CC); conn 199 ext/mysqlnd/mysqlnd.c conn->protocol = NULL; conn 202 ext/mysqlnd/mysqlnd.c if (conn->stats) { conn 203 ext/mysqlnd/mysqlnd.c mysqlnd_stats_end(conn->stats); conn 206 ext/mysqlnd/mysqlnd.c mnd_pefree(conn, conn->persistent); conn 215 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, simple_command_handle_response)(MYSQLND_CONN_DATA * conn, enum mysqlnd_packet_type ok_packet, conn 226 ext/mysqlnd/mysqlnd.c MYSQLND_PACKET_OK * ok_response = conn->protocol->m.get_ok_packet(conn->protocol, FALSE TSRMLS_CC); conn 228 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 231 ext/mysqlnd/mysqlnd.c if (FAIL == (ret = PACKET_READ(ok_response, conn))) { conn 241 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, ok_response->error_no, ok_response->sqlstate, ok_response->error); conn 252 ext/mysqlnd/mysqlnd.c conn->upsert_status->server_status &= ~SERVER_MORE_RESULTS_EXISTS; conn 253 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 255 ext/mysqlnd/mysqlnd.c SET_NEW_MESSAGE(conn->last_message, conn->last_message_len, conn 257 ext/mysqlnd/mysqlnd.c conn->persistent); conn 260 ext/mysqlnd/mysqlnd.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 261 ext/mysqlnd/mysqlnd.c conn->upsert_status->warning_count = ok_response->warning_count; conn 262 ext/mysqlnd/mysqlnd.c conn->upsert_status->server_status = ok_response->server_status; conn 263 ext/mysqlnd/mysqlnd.c conn->upsert_status->affected_rows = ok_response->affected_rows; conn 264 ext/mysqlnd/mysqlnd.c conn->upsert_status->last_insert_id = ok_response->last_insert_id; conn 272 ext/mysqlnd/mysqlnd.c MYSQLND_PACKET_EOF * ok_response = conn->protocol->m.get_eof_packet(conn->protocol, FALSE TSRMLS_CC); conn 274 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 277 ext/mysqlnd/mysqlnd.c if (FAIL == (ret = PACKET_READ(ok_response, conn))) { conn 278 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_MALFORMED_PACKET, UNKNOWN_SQLSTATE, conn 287 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, ok_response->error_no, ok_response->sqlstate, ok_response->error); conn 288 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 290 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_MALFORMED_PACKET, UNKNOWN_SQLSTATE, "Malformed packet"); conn 303 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_MALFORMED_PACKET, UNKNOWN_SQLSTATE, "Malformed packet"); conn 315 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, simple_command_send_request)(MYSQLND_CONN_DATA * conn, enum php_mysqlnd_server_command command, conn 323 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 326 ext/mysqlnd/mysqlnd.c switch (CONN_GET_STATE(conn)) { conn 330 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); conn 334 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 335 ext/mysqlnd/mysqlnd.c DBG_ERR_FMT("Command out of sync. State=%u", CONN_GET_STATE(conn)); conn 339 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 340 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 342 ext/mysqlnd/mysqlnd.c cmd_packet = conn->protocol->m.get_command_packet(conn->protocol, FALSE TSRMLS_CC); conn 344 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 354 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_COM_QUIT + command - 1 /* because of COM_SLEEP */ ); conn 356 ext/mysqlnd/mysqlnd.c if (! PACKET_WRITE(cmd_packet, conn)) { conn 361 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 362 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn TSRMLS_CC); conn 374 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, simple_command)(MYSQLND_CONN_DATA * conn, enum php_mysqlnd_server_command command, conn 381 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command_send_request(conn, command, arg, arg_len, silent, ignore_upsert_status TSRMLS_CC); conn 383 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command_handle_response(conn, ok_packet, silent, command, ignore_upsert_status TSRMLS_CC); conn 394 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_server_option)(MYSQLND_CONN_DATA * const conn, enum_mysqlnd_server_option option TSRMLS_DC) conn 400 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 403 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_SET_OPTION, buffer, sizeof(buffer), PROT_EOF_PACKET, FALSE, TRUE TSRMLS_CC); conn 405 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 414 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, restart_psession)(MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 417 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CONNECT_REUSED); conn 419 ext/mysqlnd/mysqlnd.c if (conn->last_message) { conn 420 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->last_message, conn->persistent); conn 421 ext/mysqlnd/mysqlnd.c conn->last_message = NULL; conn 430 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, end_psession)(MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 441 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn, conn 479 ext/mysqlnd/mysqlnd.c auth_packet = conn->protocol->m.get_auth_packet(conn->protocol, FALSE TSRMLS_CC); conn 481 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 505 ext/mysqlnd/mysqlnd.c if (!PACKET_WRITE(auth_packet, conn)) { conn 509 ext/mysqlnd/mysqlnd.c conn->net->data->m.set_client_option(conn->net, MYSQL_OPT_SSL_VERIFY_SERVER_CERT, (const char *) &verify TSRMLS_CC); conn 511 ext/mysqlnd/mysqlnd.c if (FAIL == conn->net->data->m.enable_ssl(conn->net TSRMLS_CC)) { conn 518 ext/mysqlnd/mysqlnd.c if (!PACKET_WRITE(auth_packet, conn)) { conn 528 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 529 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn TSRMLS_CC); conn 530 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_GONE_ERROR, UNKNOWN_SQLSTATE, mysqlnd_server_gone); conn 558 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn, conn 599 ext/mysqlnd/mysqlnd.c struct st_mysqlnd_authentication_plugin * auth_plugin = conn->m->fetch_auth_plugin_by_name(requested_protocol TSRMLS_CC); conn 603 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 617 ext/mysqlnd/mysqlnd.c if (conn->auth_plugin_data) { conn 618 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->auth_plugin_data, conn->persistent); conn 619 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data = NULL; conn 621 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data_len = plugin_data_len; conn 622 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data = mnd_pemalloc(conn->auth_plugin_data_len, conn->persistent); conn 623 ext/mysqlnd/mysqlnd.c if (!conn->auth_plugin_data) { conn 624 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 627 ext/mysqlnd/mysqlnd.c memcpy(conn->auth_plugin_data, plugin_data, plugin_data_len); conn 632 ext/mysqlnd/mysqlnd.c auth_plugin->methods.get_auth_data(NULL, &scrambled_data_len, conn, user, passwd, passwd_len, conn 633 ext/mysqlnd/mysqlnd.c plugin_data, plugin_data_len, options, &conn->net->data->options, mysql_flags TSRMLS_CC); conn 634 ext/mysqlnd/mysqlnd.c if (conn->error_info->error_no) { conn 638 ext/mysqlnd/mysqlnd.c ret = mysqlnd_auth_handshake(conn, user, passwd, passwd_len, db, db_len, options, mysql_flags, conn 647 ext/mysqlnd/mysqlnd.c ret = mysqlnd_auth_change_user(conn, user, strlen(user), passwd, passwd_len, db, db_len, silent, conn 670 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->error_info->error_no = %d", conn->error_info->error_no); conn 671 ext/mysqlnd/mysqlnd.c } while (ret == FAIL && conn->error_info->error_no == 0 && switch_to_auth_protocol != NULL); conn 675 ext/mysqlnd/mysqlnd.c conn->m->set_client_option(conn, MYSQLND_OPT_AUTH_PROTOCOL, requested_protocol TSRMLS_CC); conn 693 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn, conn 707 ext/mysqlnd/mysqlnd.c ret = mysqlnd_switch_to_ssl_if_needed(conn, greet_packet, options, mysql_flags TSRMLS_CC); conn 709 ext/mysqlnd/mysqlnd.c ret = mysqlnd_run_authentication(conn, user, passwd, passwd_len, db, db_len, conn 720 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, execute_init_commands)(MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 725 ext/mysqlnd/mysqlnd.c if (conn->options->init_commands) { conn 727 ext/mysqlnd/mysqlnd.c for (; current_command < conn->options->num_commands; ++current_command) { conn 728 ext/mysqlnd/mysqlnd.c const char * const command = conn->options->init_commands[current_command]; conn 730 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_INIT_COMMAND_EXECUTED_COUNT); conn 731 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->query(conn, command, strlen(command) TSRMLS_CC)) { conn 732 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_INIT_COMMAND_FAILED_COUNT); conn 736 ext/mysqlnd/mysqlnd.c if (conn->last_query_type == QUERY_SELECT) { conn 737 ext/mysqlnd/mysqlnd.c MYSQLND_RES * result = conn->m->use_result(conn, 0 TSRMLS_CC); conn 752 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_updated_connect_flags)(MYSQLND_CONN_DATA * conn, unsigned int mysql_flags TSRMLS_DC) conn 754 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 760 ext/mysqlnd/mysqlnd.c mysql_flags |= conn->options->flags; /* use the flags from set_client_option() */ conn 790 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, connect_handshake)(MYSQLND_CONN_DATA * conn, conn 797 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 801 ext/mysqlnd/mysqlnd.c greet_packet = conn->protocol->m.get_greet_packet(conn->protocol, FALSE TSRMLS_CC); conn 803 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 807 ext/mysqlnd/mysqlnd.c if (FAIL == net->data->m.connect_ex(conn->net, conn->scheme, conn->scheme_len, conn->persistent, conn 808 ext/mysqlnd/mysqlnd.c conn->stats, conn->error_info TSRMLS_CC)) conn 815 ext/mysqlnd/mysqlnd.c if (FAIL == PACKET_READ(greet_packet, conn)) { conn 821 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, greet_packet->error_no, greet_packet->sqlstate, greet_packet->error); conn 827 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, conn 832 ext/mysqlnd/mysqlnd.c conn->thread_id = greet_packet->thread_id; conn 833 ext/mysqlnd/mysqlnd.c conn->protocol_version = greet_packet->protocol_version; conn 834 ext/mysqlnd/mysqlnd.c conn->server_version = mnd_pestrdup(greet_packet->server_version, conn->persistent); conn 836 ext/mysqlnd/mysqlnd.c conn->greet_charset = mysqlnd_find_charset_nr(greet_packet->charset_no); conn 837 ext/mysqlnd/mysqlnd.c if (!conn->greet_charset) { conn 840 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_NOT_IMPLEMENTED, UNKNOWN_SQLSTATE, conn 845 ext/mysqlnd/mysqlnd.c conn->client_flag = mysql_flags; conn 846 ext/mysqlnd/mysqlnd.c conn->server_capabilities = greet_packet->server_capabilities; conn 848 ext/mysqlnd/mysqlnd.c if (FAIL == mysqlnd_connect_run_authentication(conn, user, passwd, db, db_len, (size_t) passwd_len, conn 849 ext/mysqlnd/mysqlnd.c greet_packet, conn->options, mysql_flags TSRMLS_CC)) conn 853 ext/mysqlnd/mysqlnd.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 854 ext/mysqlnd/mysqlnd.c conn->upsert_status->warning_count = 0; conn 855 ext/mysqlnd/mysqlnd.c conn->upsert_status->server_status = greet_packet->server_status; conn 856 ext/mysqlnd/mysqlnd.c conn->upsert_status->affected_rows = 0; conn 861 ext/mysqlnd/mysqlnd.c conn->client_flag = 0; conn 862 ext/mysqlnd/mysqlnd.c conn->server_capabilities = 0; conn 871 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, connect)(MYSQLND_CONN_DATA * conn, conn 887 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 890 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%p", conn); conn 892 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 897 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 898 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 902 ext/mysqlnd/mysqlnd.c conn? conn->persistent:0, conn? CONN_GET_STATE(conn):-1); conn 904 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) > CONN_ALLOCED && CONN_GET_STATE(conn) ) { conn 907 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) < CONN_QUIT_SENT) { conn 908 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CLOSE_IMPLICIT); conn 910 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn TSRMLS_CC); conn 913 ext/mysqlnd/mysqlnd.c conn->m->free_contents(conn TSRMLS_CC); conn 914 ext/mysqlnd/mysqlnd.c MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_CONNECTIONS); conn 915 ext/mysqlnd/mysqlnd.c if (conn->persistent) { conn 916 ext/mysqlnd/mysqlnd.c MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_PERSISTENT_CONNECTIONS); conn 933 ext/mysqlnd/mysqlnd.c conn->m->set_client_option(conn, MYSQLND_OPT_MAX_ALLOWED_PACKET, (char *)&max_allowed_size TSRMLS_CC); conn 984 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 987 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("transport=%s conn->scheme=%s", transport, conn->scheme); conn 988 ext/mysqlnd/mysqlnd.c conn->scheme = mnd_pestrndup(transport, transport_len, conn->persistent); conn 989 ext/mysqlnd/mysqlnd.c conn->scheme_len = transport_len; conn 992 ext/mysqlnd/mysqlnd.c if (!conn->scheme) { conn 997 ext/mysqlnd/mysqlnd.c mysql_flags = conn->m->get_updated_connect_flags(conn, mysql_flags TSRMLS_CC); conn 999 ext/mysqlnd/mysqlnd.c if (FAIL == conn->m->connect_handshake(conn, host, user, passwd, passwd_len, db, db_len, mysql_flags TSRMLS_CC)) { conn 1004 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_READY); conn 1016 ext/mysqlnd/mysqlnd.c conn->user = mnd_pestrdup(user, conn->persistent); conn 1017 ext/mysqlnd/mysqlnd.c conn->user_len = strlen(conn->user); conn 1018 ext/mysqlnd/mysqlnd.c conn->passwd = mnd_pestrndup(passwd, passwd_len, conn->persistent); conn 1019 ext/mysqlnd/mysqlnd.c conn->passwd_len = passwd_len; conn 1020 ext/mysqlnd/mysqlnd.c conn->port = port; conn 1021 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db = mnd_pestrndup(db, db_len, conn->persistent); conn 1022 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db_len = db_len; conn 1024 ext/mysqlnd/mysqlnd.c if (!conn->user || !conn->passwd || !conn->connect_or_select_db) { conn 1025 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1030 ext/mysqlnd/mysqlnd.c conn->host = mnd_pestrdup(host, conn->persistent); conn 1031 ext/mysqlnd/mysqlnd.c if (!conn->host) { conn 1032 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1035 ext/mysqlnd/mysqlnd.c conn->host_len = strlen(conn->host); conn 1038 ext/mysqlnd/mysqlnd.c mnd_sprintf(&p, 0, "%s via TCP/IP", conn->host); conn 1040 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1043 ext/mysqlnd/mysqlnd.c conn->host_info = mnd_pestrdup(p, conn->persistent); conn 1045 ext/mysqlnd/mysqlnd.c if (!conn->host_info) { conn 1046 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1051 ext/mysqlnd/mysqlnd.c conn->unix_socket = mnd_pestrdup(socket_or_pipe, conn->persistent); conn 1053 ext/mysqlnd/mysqlnd.c conn->host_info = mnd_pestrdup("Localhost via UNIX socket", conn->persistent); conn 1056 ext/mysqlnd/mysqlnd.c mnd_sprintf(&p, 0, "%s via named pipe", conn->unix_socket); conn 1058 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1061 ext/mysqlnd/mysqlnd.c conn->host_info = mnd_pestrdup(p, conn->persistent); conn 1063 ext/mysqlnd/mysqlnd.c if (!conn->host_info) { conn 1064 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1070 ext/mysqlnd/mysqlnd.c if (!conn->unix_socket || !conn->host_info) { conn 1071 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1074 ext/mysqlnd/mysqlnd.c conn->unix_socket_len = strlen(conn->unix_socket); conn 1076 ext/mysqlnd/mysqlnd.c conn->max_packet_size = MYSQLND_ASSEMBLED_PACKET_MAX_SIZE; conn 1079 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 1081 ext/mysqlnd/mysqlnd.c mysqlnd_local_infile_default(conn); conn 1083 ext/mysqlnd/mysqlnd.c if (FAIL == conn->m->execute_init_commands(conn TSRMLS_CC)) { conn 1087 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, STAT_CONNECT_SUCCESS, 1, STAT_OPENED_CONNECTIONS, 1); conn 1091 ext/mysqlnd/mysqlnd.c if (conn->persistent) { conn 1092 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, STAT_PCONNECT_SUCCESS, 1, STAT_OPENED_PERSISTENT_CONNECTIONS, 1); conn 1095 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("connection_id=%llu", conn->thread_id); conn 1097 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, PASS TSRMLS_CC); conn 1102 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 1103 ext/mysqlnd/mysqlnd.c if (!conn->error_info->error_no) { conn 1104 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 1106 ext/mysqlnd/mysqlnd.c conn->error_info->error_no, conn->error_info->error, conn->scheme); conn 1109 ext/mysqlnd/mysqlnd.c conn->m->free_contents(conn TSRMLS_CC); conn 1110 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CONNECT_FAILURE); conn 1112 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, FAIL TSRMLS_CC); conn 1133 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn = conn_handle->data; conn 1137 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1139 ext/mysqlnd/mysqlnd.c ret = conn->m->connect(conn, host, user, passwd, passwd_len, db, db_len, port, socket_or_pipe, mysql_flags TSRMLS_CC); conn 1141 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, FAIL TSRMLS_CC); conn 1196 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, query)(MYSQLND_CONN_DATA * conn, const char * query, unsigned int query_len TSRMLS_DC) conn 1201 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%p conn=%llu query=%s", conn, conn->thread_id, query); conn 1203 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1204 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->send_query(conn, query, query_len TSRMLS_CC) && conn 1205 ext/mysqlnd/mysqlnd.c PASS == conn->m->reap_query(conn TSRMLS_CC)) conn 1208 ext/mysqlnd/mysqlnd.c if (conn->last_query_type == QUERY_UPSERT && conn->upsert_status->affected_rows) { conn 1209 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, STAT_ROWS_AFFECTED_NORMAL, conn->upsert_status->affected_rows); conn 1212 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1221 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, send_query)(MYSQLND_CONN_DATA * conn, const char * query, unsigned int query_len TSRMLS_DC) conn 1226 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu query=%s", conn->thread_id, query); conn 1227 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1229 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1230 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_QUERY, (zend_uchar *) query, query_len, conn 1234 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUERY_SENT); conn 1236 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1238 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1246 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, reap_query)(MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 1249 ext/mysqlnd/mysqlnd.c enum_mysqlnd_connection_state state = CONN_GET_STATE(conn); conn 1252 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1254 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1255 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1261 ext/mysqlnd/mysqlnd.c ret = conn->m->query_read_result_set_header(conn, NULL TSRMLS_CC); conn 1263 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1265 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1470 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, list_fields)(MYSQLND_CONN_DATA * conn, const char *table, const char *achtung_wild TSRMLS_DC) conn 1478 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu table=%s wild=%s", conn->thread_id, table? table:"",achtung_wild? achtung_wild:""); conn 1480 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1497 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->simple_command(conn, COM_FIELD_LIST, buff, p - buff, conn 1500 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, 0, FAIL TSRMLS_CC); conn 1508 ext/mysqlnd/mysqlnd.c result = conn->m->result_init(5000, conn->persistent TSRMLS_CC); conn 1513 ext/mysqlnd/mysqlnd.c if (FAIL == result->m.read_result_metadata(result, conn TSRMLS_CC)) { conn 1524 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1531 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS TSRMLS_CC); conn 1541 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, list_method)(MYSQLND_CONN_DATA * conn, const char * query, const char *achtung_wild, char *par1 TSRMLS_DC) conn 1549 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu query=%s wild=%u", conn->thread_id, query, achtung_wild); conn 1551 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1566 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->query(conn, show_query, show_query_len TSRMLS_CC)) { conn 1567 ext/mysqlnd/mysqlnd.c result = conn->m->store_result(conn, MYSQLND_STORE_NO_COPY TSRMLS_CC); conn 1572 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS TSRMLS_CC); conn 1581 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, errno)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 1583 ext/mysqlnd/mysqlnd.c return conn->error_info->error_no; conn 1590 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, error)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 1592 ext/mysqlnd/mysqlnd.c return conn->error_info->error; conn 1599 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, sqlstate)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 1601 ext/mysqlnd/mysqlnd.c return conn->error_info->sqlstate[0] ? conn->error_info->sqlstate:MYSQLND_SQLSTATE_NULL; conn 1618 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, ssl_set)(MYSQLND_CONN_DATA * const conn, const char * key, const char * const cert, conn 1623 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 1626 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1633 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1642 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 TSRMLS_DC) conn 1647 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1649 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1650 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("server_status=%u", conn->upsert_status->server_status); conn 1651 ext/mysqlnd/mysqlnd.c if (conn->upsert_status->server_status & SERVER_STATUS_NO_BACKSLASH_ESCAPES) { conn 1652 ext/mysqlnd/mysqlnd.c ret = mysqlnd_cset_escape_quotes(conn->charset, newstr, escapestr, escapestr_len TSRMLS_CC); conn 1654 ext/mysqlnd/mysqlnd.c ret = mysqlnd_cset_escape_slashes(conn->charset, newstr, escapestr, escapestr_len TSRMLS_CC); conn 1656 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, PASS TSRMLS_CC); conn 1665 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, dump_debug_info)(MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 1670 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1671 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1672 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_DEBUG, NULL, 0, PROT_EOF_PACKET, FALSE, TRUE TSRMLS_CC); conn 1674 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1684 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, select_db)(MYSQLND_CONN_DATA * const conn, const char * const db, unsigned int db_len TSRMLS_DC) conn 1690 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu db=%s", conn->thread_id, db); conn 1692 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1693 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_INIT_DB, (zend_uchar*) db, db_len, PROT_OK_PACKET, FALSE, TRUE TSRMLS_CC); conn 1698 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 1700 ext/mysqlnd/mysqlnd.c if (conn->connect_or_select_db) { conn 1701 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->connect_or_select_db, conn->persistent); conn 1703 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db = mnd_pestrndup(db, db_len, conn->persistent); conn 1704 ext/mysqlnd/mysqlnd.c conn->connect_or_select_db_len = db_len; conn 1705 ext/mysqlnd/mysqlnd.c if (!conn->connect_or_select_db) { conn 1707 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1711 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1720 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, ping)(MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 1726 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1728 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1729 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_PING, NULL, 0, PROT_OK_PACKET, TRUE, TRUE TSRMLS_CC); conn 1734 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 1736 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1746 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, statistic)(MYSQLND_CONN_DATA * conn, char **message, unsigned int * message_len TSRMLS_DC) conn 1753 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 1755 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1757 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_STATISTICS, NULL, 0, PROT_LAST, FALSE, TRUE TSRMLS_CC); conn 1761 ext/mysqlnd/mysqlnd.c stats_header = conn->protocol->m.get_stats_packet(conn->protocol, FALSE TSRMLS_CC); conn 1763 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 1767 ext/mysqlnd/mysqlnd.c if (PASS == (ret = PACKET_READ(stats_header, conn))) { conn 1776 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1785 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, kill)(MYSQLND_CONN_DATA * conn, unsigned int pid TSRMLS_DC) conn 1792 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu pid=%u", conn->thread_id, pid); conn 1794 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1798 ext/mysqlnd/mysqlnd.c if (pid != conn->thread_id) { conn 1799 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_PROCESS_KILL, buff, 4, PROT_OK_PACKET, FALSE, TRUE TSRMLS_CC); conn 1804 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 1805 ext/mysqlnd/mysqlnd.c } else if (PASS == (ret = conn->m->simple_command(conn, COM_PROCESS_KILL, buff, 4, PROT_LAST, FALSE, TRUE TSRMLS_CC))) { conn 1806 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 1807 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn TSRMLS_CC); conn 1810 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1819 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_charset)(MYSQLND_CONN_DATA * const conn, const char * const csname TSRMLS_DC) conn 1826 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu cs=%s", conn->thread_id, csname); conn 1829 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_CANT_FIND_CHARSET, UNKNOWN_SQLSTATE, conn 1834 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1838 ext/mysqlnd/mysqlnd.c if (FAIL == (ret = conn->m->query(conn, query, query_len TSRMLS_CC))) { conn 1840 ext/mysqlnd/mysqlnd.c } else if (conn->error_info->error_no) { conn 1843 ext/mysqlnd/mysqlnd.c conn->charset = charset; conn 1847 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1858 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, refresh)(MYSQLND_CONN_DATA * const conn, uint8_t options TSRMLS_DC) conn 1864 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu options=%lu", conn->thread_id, options); conn 1866 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1869 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_REFRESH, bits, 1, PROT_OK_PACKET, FALSE, TRUE TSRMLS_CC); conn 1871 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1880 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, shutdown)(MYSQLND_CONN_DATA * const conn, uint8_t level TSRMLS_DC) conn 1886 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu level=%lu", conn->thread_id, level); conn 1888 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 1891 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_SHUTDOWN, bits, 1, PROT_OK_PACKET, FALSE, TRUE TSRMLS_CC); conn 1893 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 1902 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, send_close)(MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 1905 ext/mysqlnd/mysqlnd.c MYSQLND_NET * net = conn->net; conn 1910 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu net->data->stream->abstract=%p", conn->thread_id, net_stream? net_stream->abstract:NULL); conn 1912 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) >= CONN_READY) { conn 1913 ext/mysqlnd/mysqlnd.c MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_CONNECTIONS); conn 1914 ext/mysqlnd/mysqlnd.c if (conn->persistent) { conn 1915 ext/mysqlnd/mysqlnd.c MYSQLND_DEC_CONN_STATISTIC(conn->stats, STAT_OPENED_PERSISTENT_CONNECTIONS); conn 1918 ext/mysqlnd/mysqlnd.c state = CONN_GET_STATE(conn); conn 1924 ext/mysqlnd/mysqlnd.c ret = conn->m->simple_command(conn, COM_QUIT, NULL, 0, PROT_LAST, TRUE, TRUE TSRMLS_CC); conn 1925 ext/mysqlnd/mysqlnd.c net->data->m.close_stream(net, conn->stats, conn->error_info TSRMLS_CC); conn 1927 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 1938 ext/mysqlnd/mysqlnd.c DBG_ERR_FMT("Brutally closing connection [%p][%s]", conn, conn->scheme); conn 1951 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 1955 ext/mysqlnd/mysqlnd.c net->data->m.close_stream(net, conn->stats, conn->error_info TSRMLS_CC); conn 1966 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, get_reference)(MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 1969 ext/mysqlnd/mysqlnd.c ++conn->refcount; conn 1970 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu new_refcount=%u", conn->thread_id, conn->refcount); conn 1971 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn); conn 1978 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, free_reference)(MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 1982 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu old_refcount=%u", conn->thread_id, conn->refcount); conn 1983 ext/mysqlnd/mysqlnd.c if (!(--conn->refcount)) { conn 1989 ext/mysqlnd/mysqlnd.c ret = conn->m->send_close(conn TSRMLS_CC); conn 1990 ext/mysqlnd/mysqlnd.c conn->m->dtor(conn TSRMLS_CC); conn 1999 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, get_state)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2002 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn->state); conn 2009 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn_data, set_state)(MYSQLND_CONN_DATA * const conn, enum mysqlnd_connection_state new_state TSRMLS_DC) conn 2013 ext/mysqlnd/mysqlnd.c conn->state = new_state; conn 2021 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, field_count)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2023 ext/mysqlnd/mysqlnd.c return conn->field_count; conn 2030 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, server_status)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2032 ext/mysqlnd/mysqlnd.c return conn->upsert_status->server_status; conn 2039 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, insert_id)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2041 ext/mysqlnd/mysqlnd.c return conn->upsert_status->last_insert_id; conn 2048 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, affected_rows)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2050 ext/mysqlnd/mysqlnd.c return conn->upsert_status->affected_rows; conn 2057 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, warning_count)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2059 ext/mysqlnd/mysqlnd.c return conn->upsert_status->warning_count; conn 2066 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, info)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2068 ext/mysqlnd/mysqlnd.c return conn->last_message; conn 2090 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_server_info)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2092 ext/mysqlnd/mysqlnd.c return conn->server_version; conn 2099 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_host_info)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2101 ext/mysqlnd/mysqlnd.c return conn->host_info; conn 2108 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_proto_info)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2110 ext/mysqlnd/mysqlnd.c return conn->protocol_version; conn 2117 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, charset_name)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2119 ext/mysqlnd/mysqlnd.c return conn->charset->name; conn 2126 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, thread_id)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2128 ext/mysqlnd/mysqlnd.c return conn->thread_id; conn 2135 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_server_version)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2140 ext/mysqlnd/mysqlnd.c if (!(p = conn->server_version)) { conn 2157 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, more_results)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2161 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS? TRUE:FALSE); conn 2168 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, next_result)(MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2174 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 2176 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2178 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) != CONN_NEXT_RESULT_PENDING) { conn 2182 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 2183 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 2188 ext/mysqlnd/mysqlnd.c if (FAIL == (ret = conn->m->query_read_result_set_header(conn, NULL TSRMLS_CC))) { conn 2193 ext/mysqlnd/mysqlnd.c if (!conn->error_info->error_no) { conn 2196 ext/mysqlnd/mysqlnd.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 2197 ext/mysqlnd/mysqlnd.c conn->m->send_close(conn TSRMLS_CC); conn 2199 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("Error from the server : (%u) %s", conn->error_info->error_no, conn->error_info->error); conn 2203 ext/mysqlnd/mysqlnd.c if (conn->last_query_type == QUERY_UPSERT && conn->upsert_status->affected_rows) { conn 2204 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, STAT_ROWS_AFFECTED_NORMAL, conn->upsert_status->affected_rows); conn 2207 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2270 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, change_user)(MYSQLND_CONN_DATA * const conn, conn 2283 ext/mysqlnd/mysqlnd.c conn->thread_id, user?user:"", passwd?"***":"null", db?db:"", (silent == TRUE)?1:0 ); conn 2285 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2289 ext/mysqlnd/mysqlnd.c SET_EMPTY_ERROR(*conn->error_info); conn 2290 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 2303 ext/mysqlnd/mysqlnd.c ret = mysqlnd_run_authentication(conn, user, passwd, strlen(passwd), db, strlen(db), conn 2304 ext/mysqlnd/mysqlnd.c conn->auth_plugin_data, conn->auth_plugin_data_len, conn->options->auth_protocol, conn 2305 ext/mysqlnd/mysqlnd.c 0 /*charset not used*/, conn->options, conn->server_capabilities, silent, TRUE/*is_change*/ TSRMLS_CC); conn 2311 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2321 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_client_option)(MYSQLND_CONN_DATA * const conn, conn 2329 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu option=%u", conn->thread_id, option); conn 2331 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2350 ext/mysqlnd/mysqlnd.c ret = conn->net->data->m.set_client_option(conn->net, option, value TSRMLS_CC); conn 2354 ext/mysqlnd/mysqlnd.c conn->options->int_and_float_native = *(unsigned int*) value; conn 2359 ext/mysqlnd/mysqlnd.c conn->options->flags |= CLIENT_LOCAL_FILES; conn 2361 ext/mysqlnd/mysqlnd.c conn->options->flags &= ~CLIENT_LOCAL_FILES; conn 2370 ext/mysqlnd/mysqlnd.c new_init_commands = mnd_perealloc(conn->options->init_commands, sizeof(char *) * (conn->options->num_commands + 1), conn->persistent); conn 2374 ext/mysqlnd/mysqlnd.c conn->options->init_commands = new_init_commands; conn 2375 ext/mysqlnd/mysqlnd.c new_command = mnd_pestrdup(value, conn->persistent); conn 2379 ext/mysqlnd/mysqlnd.c conn->options->init_commands[conn->options->num_commands] = new_command; conn 2380 ext/mysqlnd/mysqlnd.c ++conn->options->num_commands; conn 2395 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_CANT_FIND_CHARSET, UNKNOWN_SQLSTATE, "Unknown character set"); conn 2400 ext/mysqlnd/mysqlnd.c new_charset_name = mnd_pestrdup(value, conn->persistent); conn 2404 ext/mysqlnd/mysqlnd.c if (conn->options->charset_name) { conn 2405 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->charset_name, conn->persistent); conn 2407 ext/mysqlnd/mysqlnd.c conn->options->charset_name = new_charset_name; conn 2408 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("charset=%s", conn->options->charset_name); conn 2412 ext/mysqlnd/mysqlnd.c conn->options->protocol = MYSQL_PROTOCOL_PIPE; conn 2416 ext/mysqlnd/mysqlnd.c conn->options->protocol = *(unsigned int*) value; conn 2433 ext/mysqlnd/mysqlnd.c conn->options->max_allowed_packet = *(unsigned int*) value; conn 2438 ext/mysqlnd/mysqlnd.c char * new_auth_protocol = value? mnd_pestrdup(value, conn->persistent) : NULL; conn 2442 ext/mysqlnd/mysqlnd.c if (conn->options->auth_protocol) { conn 2443 ext/mysqlnd/mysqlnd.c mnd_pefree(conn->options->auth_protocol, conn->persistent); conn 2445 ext/mysqlnd/mysqlnd.c conn->options->auth_protocol = new_auth_protocol; conn 2446 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("auth_protocol=%s", conn->options->auth_protocol); conn 2451 ext/mysqlnd/mysqlnd.c conn->options->flags |= CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS; conn 2453 ext/mysqlnd/mysqlnd.c conn->options->flags &= ~CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS; conn 2457 ext/mysqlnd/mysqlnd.c if (conn->options->connect_attr) { conn 2458 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("Before reset %d attribute(s)", zend_hash_num_elements(conn->options->connect_attr)); conn 2459 ext/mysqlnd/mysqlnd.c zend_hash_clean(conn->options->connect_attr); conn 2463 ext/mysqlnd/mysqlnd.c if (conn->options->connect_attr && value) { conn 2464 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("Before delete %d attribute(s)", zend_hash_num_elements(conn->options->connect_attr)); conn 2465 ext/mysqlnd/mysqlnd.c zend_hash_del(conn->options->connect_attr, value, strlen(value)); conn 2466 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("%d left", zend_hash_num_elements(conn->options->connect_attr)); conn 2478 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2481 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2482 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, FAIL TSRMLS_CC); conn 2519 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_client_option_2d)(MYSQLND_CONN_DATA * const conn, conn 2528 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu option=%u", conn->thread_id, option); conn 2530 ext/mysqlnd/mysqlnd.c if (PASS != conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2535 ext/mysqlnd/mysqlnd.c if (!conn->options->connect_attr) { conn 2537 ext/mysqlnd/mysqlnd.c conn->options->connect_attr = mnd_pemalloc(sizeof(HashTable), conn->persistent); conn 2538 ext/mysqlnd/mysqlnd.c if (!conn->options->connect_attr) { conn 2541 ext/mysqlnd/mysqlnd.c zend_hash_init(conn->options->connect_attr, 0, NULL, conn->persistent? connect_attr_item_pdtor:connect_attr_item_edtor, conn->persistent); conn 2545 ext/mysqlnd/mysqlnd.c const char * copyv = mnd_pestrdup(value, conn->persistent); conn 2549 ext/mysqlnd/mysqlnd.c zend_hash_update(conn->options->connect_attr, key, strlen(key), ©v, sizeof(char *), NULL); conn 2555 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2558 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2559 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, FAIL TSRMLS_CC); conn 2568 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, use_result)(MYSQLND_CONN_DATA * const conn, const unsigned int flags TSRMLS_DC) conn 2574 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 2576 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2578 ext/mysqlnd/mysqlnd.c if (!conn->current_result) { conn 2583 ext/mysqlnd/mysqlnd.c if (conn->last_query_type != QUERY_SELECT || CONN_GET_STATE(conn) != CONN_FETCHING_DATA) { conn 2584 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 2589 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_UNBUFFERED_SETS); conn 2591 ext/mysqlnd/mysqlnd.c conn->current_result->conn = conn->m->get_reference(conn TSRMLS_CC); conn 2592 ext/mysqlnd/mysqlnd.c result = conn->current_result->m.use_result(conn->current_result, FALSE TSRMLS_CC); conn 2595 ext/mysqlnd/mysqlnd.c conn->current_result->m.free_result(conn->current_result, TRUE TSRMLS_CC); conn 2597 ext/mysqlnd/mysqlnd.c conn->current_result = NULL; conn 2600 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS TSRMLS_CC); conn 2610 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, store_result)(MYSQLND_CONN_DATA * const conn, const unsigned int flags TSRMLS_DC) conn 2616 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu conn=%p", conn->thread_id, conn); conn 2618 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2621 ext/mysqlnd/mysqlnd.c if (!conn->current_result) { conn 2626 ext/mysqlnd/mysqlnd.c if (conn->last_query_type != QUERY_SELECT || CONN_GET_STATE(conn) != CONN_FETCHING_DATA) { conn 2627 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 2632 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_BUFFERED_SETS); conn 2635 ext/mysqlnd/mysqlnd.c if ((conn->m->get_client_api_capabilities(conn TSRMLS_CC) & MYSQLND_CLIENT_KNOWS_RSET_COPY_DATA)) { conn 2647 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, "Unknown fetch mode"); conn 2651 ext/mysqlnd/mysqlnd.c result = conn->current_result->m.store_result(conn->current_result, conn, f TSRMLS_CC); conn 2653 ext/mysqlnd/mysqlnd.c conn->current_result->m.free_result(conn->current_result, TRUE TSRMLS_CC); conn 2655 ext/mysqlnd/mysqlnd.c conn->current_result = NULL; conn 2658 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, result == NULL? FAIL:PASS TSRMLS_CC); conn 2667 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_connection_stats)(const MYSQLND_CONN_DATA * const conn, conn 2671 ext/mysqlnd/mysqlnd.c mysqlnd_fill_stats_hash(conn->stats, mysqlnd_stats_values_names, return_value TSRMLS_CC ZEND_FILE_LINE_CC); conn 2679 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, set_autocommit)(MYSQLND_CONN_DATA * conn, unsigned int mode TSRMLS_DC) conn 2685 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2686 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, (mode) ? "SET AUTOCOMMIT=1":"SET AUTOCOMMIT=0", sizeof("SET AUTOCOMMIT=1") - 1 TSRMLS_CC); conn 2687 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2697 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_commit)(MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 2699 ext/mysqlnd/mysqlnd.c return conn->m->tx_commit_or_rollback(conn, TRUE, TRANS_COR_NO_OPT, NULL TSRMLS_CC); conn 2706 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_rollback)(MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 2708 ext/mysqlnd/mysqlnd.c return conn->m->tx_commit_or_rollback(conn, FALSE, TRANS_COR_NO_OPT, NULL TSRMLS_CC); conn 2715 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 TSRMLS_DC) conn 2790 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 TSRMLS_DC) conn 2796 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2799 ext/mysqlnd/mysqlnd.c conn->m->tx_cor_options_to_string(conn, &tmp_str, flags TSRMLS_CC); conn 2816 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2820 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, query, query_len TSRMLS_CC); conn 2824 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2834 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_begin)(MYSQLND_CONN_DATA * conn, const unsigned int mode, const char * const name TSRMLS_DC) conn 2840 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2850 ext/mysqlnd/mysqlnd.c unsigned long server_version = conn->m->get_server_version(conn TSRMLS_CC); 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 TSRMLS_CC); conn 2886 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2896 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_savepoint)(MYSQLND_CONN_DATA * conn, const char * const name TSRMLS_DC) conn 2902 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2907 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, "Savepoint name not provided"); conn 2912 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2915 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, query, query_len TSRMLS_CC); conn 2918 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2928 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, tx_savepoint_release)(MYSQLND_CONN_DATA * conn, const char * const name TSRMLS_DC) conn 2934 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 2939 ext/mysqlnd/mysqlnd.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, "Savepoint name not provided"); conn 2944 ext/mysqlnd/mysqlnd.c SET_OOM_ERROR(*conn->error_info); conn 2947 ext/mysqlnd/mysqlnd.c ret = conn->m->query(conn, query, query_len TSRMLS_CC); conn 2950 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 2960 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, negotiate_client_api_capabilities)(MYSQLND_CONN_DATA * const conn, const unsigned int flags TSRMLS_DC) conn 2964 ext/mysqlnd/mysqlnd.c if (conn) { conn 2965 ext/mysqlnd/mysqlnd.c ret = conn->client_api_capabilities; conn 2966 ext/mysqlnd/mysqlnd.c conn->client_api_capabilities = flags; conn 2976 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, get_client_api_capabilities)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2979 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn? conn->client_api_capabilities : 0); conn 2986 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, local_tx_start)(MYSQLND_CONN_DATA * conn, size_t this_func TSRMLS_DC) conn 2997 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, local_tx_end)(MYSQLND_CONN_DATA * conn, size_t this_func, enum_func_status status TSRMLS_DC) conn 3007 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn_data, init)(MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 3010 ext/mysqlnd/mysqlnd.c mysqlnd_stats_init(&conn->stats, STAT_LAST); conn 3011 ext/mysqlnd/mysqlnd.c SET_ERROR_AFF_ROWS(conn); conn 3013 ext/mysqlnd/mysqlnd.c conn->net = mysqlnd_net_init(conn->persistent, conn->stats, conn->error_info TSRMLS_CC); conn 3014 ext/mysqlnd/mysqlnd.c conn->protocol = mysqlnd_protocol_init(conn->persistent TSRMLS_CC); conn 3016 ext/mysqlnd/mysqlnd.c DBG_RETURN(conn->stats && conn->net && conn->protocol? PASS:FAIL); conn 3021 ext/mysqlnd/mysqlnd.c MYSQLND_STMT * _mysqlnd_stmt_init(MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 3121 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD(mysqlnd_conn, clone_object)(MYSQLND * const conn TSRMLS_DC) conn 3125 ext/mysqlnd/mysqlnd.c ret = MYSQLND_CLASS_METHOD_TABLE_NAME(mysqlnd_object_factory).clone_connection_object(conn TSRMLS_CC); conn 3133 ext/mysqlnd/mysqlnd.c MYSQLND_METHOD_PRIVATE(mysqlnd_conn, dtor)(MYSQLND * conn TSRMLS_DC) conn 3136 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->data->thread_id); conn 3138 ext/mysqlnd/mysqlnd.c conn->data->m->free_reference(conn->data TSRMLS_CC); conn 3140 ext/mysqlnd/mysqlnd.c mnd_pefree(conn, conn->persistent); conn 3152 ext/mysqlnd/mysqlnd.c MYSQLND_CONN_DATA * conn = conn_handle->data; conn 3156 ext/mysqlnd/mysqlnd.c DBG_INF_FMT("conn=%llu", conn->thread_id); conn 3158 ext/mysqlnd/mysqlnd.c if (PASS == conn->m->local_tx_start(conn, this_func TSRMLS_CC)) { conn 3159 ext/mysqlnd/mysqlnd.c if (CONN_GET_STATE(conn) >= CONN_READY) { conn 3165 ext/mysqlnd/mysqlnd.c MYSQLND_INC_CONN_STATISTIC(conn->stats, close_type_to_stat_map[close_type]); conn 3172 ext/mysqlnd/mysqlnd.c ret = conn->m->send_close(conn TSRMLS_CC); conn 3175 ext/mysqlnd/mysqlnd.c conn->m->local_tx_end(conn, this_func, ret TSRMLS_CC); conn 78 ext/mysqlnd/mysqlnd.h #define mysqlnd_restart_psession(conn) ((conn)->data)->m->restart_psession((conn)->data TSRMLS_CC) conn 79 ext/mysqlnd/mysqlnd.h #define mysqlnd_end_psession(conn) ((conn)->data)->m->end_psession((conn)->data TSRMLS_CC) conn 90 ext/mysqlnd/mysqlnd.h PHPAPI MYSQLND * mysqlnd_connect(MYSQLND * conn, conn 100 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)) TSRMLS_CC) conn 101 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) TSRMLS_CC) conn 111 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_connection_stats(conn, values) ((conn)->data)->m->get_statistics((conn)->data, (values) TSRMLS_CC ZEND_FILE_LINE_CC) conn 114 ext/mysqlnd/mysqlnd.h #define mysqlnd_close(conn,is_forced) (conn)->m->close((conn), (is_forced) TSRMLS_CC) conn 115 ext/mysqlnd/mysqlnd.h #define mysqlnd_query(conn, query_str, query_len) ((conn)->data)->m->query((conn)->data, (query_str), (query_len) TSRMLS_CC) conn 116 ext/mysqlnd/mysqlnd.h #define mysqlnd_async_query(conn, query_str, query_len) ((conn)->data)->m->send_query((conn)->data, (query_str), (query_len) TSRMLS_CC) conn 118 ext/mysqlnd/mysqlnd.h #define mysqlnd_reap_async_query(conn) ((conn)->data)->m->reap_query((conn)->data TSRMLS_CC) conn 123 ext/mysqlnd/mysqlnd.h #define mysqlnd_use_result(conn) ((conn)->data)->m->use_result((conn)->data, 0 TSRMLS_CC) conn 124 ext/mysqlnd/mysqlnd.h #define mysqlnd_store_result(conn) ((conn)->data)->m->store_result((conn)->data, MYSQLND_STORE_NO_COPY TSRMLS_CC) conn 125 ext/mysqlnd/mysqlnd.h #define mysqlnd_store_result_ofs(conn) ((conn)->data)->m->store_result((conn)->data, MYSQLND_STORE_COPY TSRMLS_CC) conn 126 ext/mysqlnd/mysqlnd.h #define mysqlnd_next_result(conn) ((conn)->data)->m->next_result((conn)->data TSRMLS_CC) conn 127 ext/mysqlnd/mysqlnd.h #define mysqlnd_more_results(conn) ((conn)->data)->m->more_results((conn)->data TSRMLS_CC) conn 132 ext/mysqlnd/mysqlnd.h #define mysqlnd_errno(conn) ((conn)->data)->m->get_error_no((conn)->data TSRMLS_CC) conn 133 ext/mysqlnd/mysqlnd.h #define mysqlnd_error(conn) ((conn)->data)->m->get_error_str((conn)->data TSRMLS_CC) conn 134 ext/mysqlnd/mysqlnd.h #define mysqlnd_sqlstate(conn) ((conn)->data)->m->get_sqlstate((conn)->data TSRMLS_CC) conn 137 ext/mysqlnd/mysqlnd.h #define mysqlnd_character_set_name(conn) ((conn)->data)->m->charset_name((conn)->data TSRMLS_CC) conn 140 ext/mysqlnd/mysqlnd.h #define mysqlnd_field_count(conn) ((conn)->data)->m->get_field_count((conn)->data TSRMLS_CC) conn 141 ext/mysqlnd/mysqlnd.h #define mysqlnd_insert_id(conn) ((conn)->data)->m->get_last_insert_id((conn)->data TSRMLS_CC) conn 142 ext/mysqlnd/mysqlnd.h #define mysqlnd_affected_rows(conn) ((conn)->data)->m->get_affected_rows((conn)->data TSRMLS_CC) conn 143 ext/mysqlnd/mysqlnd.h #define mysqlnd_warning_count(conn) ((conn)->data)->m->get_warning_count((conn)->data TSRMLS_CC) conn 144 ext/mysqlnd/mysqlnd.h #define mysqlnd_info(conn) ((conn)->data)->m->get_last_message((conn)->data TSRMLS_CC) conn 145 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_server_info(conn) ((conn)->data)->m->get_server_information((conn)->data TSRMLS_CC) conn 146 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_server_version(conn) ((conn)->data)->m->get_server_version((conn)->data TSRMLS_CC) conn 147 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_host_info(conn) ((conn)->data)->m->get_host_information((conn)->data TSRMLS_CC) conn 148 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_proto_info(conn) ((conn)->data)->m->get_protocol_information((conn)->data TSRMLS_CC) conn 149 ext/mysqlnd/mysqlnd.h #define mysqlnd_thread_id(conn) ((conn)->data)->m->get_thread_id((conn)->data TSRMLS_CC) conn 150 ext/mysqlnd/mysqlnd.h #define mysqlnd_get_server_status(conn) ((conn)->data)->m->get_server_status((conn)->data TSRMLS_CC) conn 167 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) TSRMLS_CC) conn 191 ext/mysqlnd/mysqlnd.h PHPAPI void mysqlnd_local_infile_default(MYSQLND_CONN_DATA * conn); conn 192 ext/mysqlnd/mysqlnd.h PHPAPI void mysqlnd_set_local_infile_handler(MYSQLND_CONN_DATA * const conn, const char * const funcname); conn 195 ext/mysqlnd/mysqlnd.h #define mysqlnd_autocommit(conn, mode) ((conn)->data)->m->set_autocommit((conn)->data, (mode) TSRMLS_CC) conn 196 ext/mysqlnd/mysqlnd.h #define mysqlnd_begin_transaction(conn,flags,name) ((conn)->data)->m->tx_begin((conn)->data, (flags), (name) TSRMLS_CC) conn 197 ext/mysqlnd/mysqlnd.h #define mysqlnd_commit(conn, flags, name) ((conn)->data)->m->tx_commit_or_rollback((conn)->data, TRUE, (flags), (name) TSRMLS_CC) conn 198 ext/mysqlnd/mysqlnd.h #define mysqlnd_rollback(conn, flags, name) ((conn)->data)->m->tx_commit_or_rollback((conn)->data, FALSE, (flags), (name) TSRMLS_CC) conn 199 ext/mysqlnd/mysqlnd.h #define mysqlnd_savepoint(conn, name) ((conn)->data)->m->tx_savepoint((conn)->data, (name) TSRMLS_CC) conn 200 ext/mysqlnd/mysqlnd.h #define mysqlnd_release_savepoint(conn, name) ((conn)->data)->m->tx_savepoint_release((conn)->data, (name) TSRMLS_CC) conn 201 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 TSRMLS_CC) conn 202 ext/mysqlnd/mysqlnd.h #define mysqlnd_list_fields(conn, tab,wild) ((conn)->data)->m->list_fields((conn)->data, (tab), (wild) TSRMLS_CC) conn 203 ext/mysqlnd/mysqlnd.h #define mysqlnd_list_processes(conn) ((conn)->data)->m->list_method((conn)->data, "SHOW PROCESSLIST", NULL, NULL TSRMLS_CC) conn 204 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 TSRMLS_CC) conn 205 ext/mysqlnd/mysqlnd.h #define mysqlnd_dump_debug_info(conn) ((conn)->data)->m->server_dump_debug_information((conn)->data TSRMLS_CC) conn 206 ext/mysqlnd/mysqlnd.h #define mysqlnd_select_db(conn, db, db_len) ((conn)->data)->m->select_db((conn)->data, (db), (db_len) TSRMLS_CC) conn 207 ext/mysqlnd/mysqlnd.h #define mysqlnd_ping(conn) ((conn)->data)->m->ping((conn)->data TSRMLS_CC) conn 208 ext/mysqlnd/mysqlnd.h #define mysqlnd_kill(conn, pid) ((conn)->data)->m->kill_connection((conn)->data, (pid) TSRMLS_CC) conn 209 ext/mysqlnd/mysqlnd.h #define mysqlnd_refresh(conn, options) ((conn)->data)->m->refresh_server((conn)->data, (options) TSRMLS_CC) conn 210 ext/mysqlnd/mysqlnd.h #define mysqlnd_shutdown(conn, level) ((conn)->data)->m->shutdown_server((conn)->data, (level) TSRMLS_CC) conn 211 ext/mysqlnd/mysqlnd.h #define mysqlnd_set_character_set(conn, cs) ((conn)->data)->m->set_charset((conn)->data, (cs) TSRMLS_CC) conn 212 ext/mysqlnd/mysqlnd.h #define mysqlnd_stat(conn, msg, msg_len) ((conn)->data)->m->get_server_statistics(((conn)->data), (msg), (msg_len) TSRMLS_CC) conn 213 ext/mysqlnd/mysqlnd.h #define mysqlnd_options(conn, opt, value) ((conn)->data)->m->set_client_option((conn)->data, (opt), (value) TSRMLS_CC) conn 214 ext/mysqlnd/mysqlnd.h #define mysqlnd_options4(conn, opt, k, v) ((conn)->data)->m->set_client_option_2d((conn)->data, (opt), (k), (v) TSRMLS_CC) conn 215 ext/mysqlnd/mysqlnd.h #define mysqlnd_set_server_option(conn, op) ((conn)->data)->m->set_server_option((conn)->data, (op) TSRMLS_CC) conn 218 ext/mysqlnd/mysqlnd.h #define mysqlnd_real_escape_string(conn, newstr, escapestr, escapestr_len) \ conn 219 ext/mysqlnd/mysqlnd.h ((conn)->data)->m->escape_string((conn)->data, (newstr), (escapestr), (escapestr_len) TSRMLS_CC) conn 227 ext/mysqlnd/mysqlnd.h #define mysqlnd_stmt_init(conn) ((conn)->data)->m->stmt_init(((conn)->data) TSRMLS_CC) 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 TSRMLS_CC); 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 TSRMLS_CC); 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 TSRMLS_CC); 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 TSRMLS_CC); 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 TSRMLS_CC); 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 TSRMLS_CC); 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 TSRMLS_CC) >= 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 TSRMLS_CC) > 50113L &&conn->m->get_server_version(conn TSRMLS_CC) < 50118L) { conn 263 ext/mysqlnd/mysqlnd_auth.c MYSQLND_PACKET_OK * redundant_error_packet = conn->protocol->m.get_ok_packet(conn->protocol, FALSE TSRMLS_CC); 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 TSRMLS_CC)); 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 TSRMLS_CC) < 50123) { conn 295 ext/mysqlnd/mysqlnd_auth.c ret = conn->m->set_charset(conn, old_cs->name TSRMLS_CC); 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 503 ext/mysqlnd/mysqlnd_auth.c pk_req_packet = conn->protocol->m.get_sha256_pk_request_packet(conn->protocol, FALSE TSRMLS_CC); conn 505 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 508 ext/mysqlnd/mysqlnd_auth.c pk_resp_packet = conn->protocol->m.get_sha256_pk_request_response_packet(conn->protocol, FALSE TSRMLS_CC); conn 510 ext/mysqlnd/mysqlnd_auth.c SET_OOM_ERROR(*conn->error_info); conn 515 ext/mysqlnd/mysqlnd_auth.c if (! PACKET_WRITE(pk_req_packet, conn)) { conn 518 ext/mysqlnd/mysqlnd_auth.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 521 ext/mysqlnd/mysqlnd_auth.c if (FAIL == PACKET_READ(pk_resp_packet, conn) || NULL == pk_resp_packet->public_key) { conn 524 ext/mysqlnd/mysqlnd_auth.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 541 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, conn 573 ext/mysqlnd/mysqlnd_auth.c MYSQLND_CONN_DATA * conn, const char * const user, const char * const passwd, conn 586 ext/mysqlnd/mysqlnd_auth.c if (conn->net->data->ssl) { conn 594 ext/mysqlnd/mysqlnd_auth.c server_public_key = mysqlnd_sha256_get_rsa_key(conn, options, net_options TSRMLS_CC); conn 611 ext/mysqlnd/mysqlnd_auth.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, "password is too long"); conn 196 ext/mysqlnd/mysqlnd_driver.c MYSQLND_METHOD(mysqlnd_object_factory, get_prepared_statement)(MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 199 ext/mysqlnd/mysqlnd_driver.c MYSQLND_STMT * ret = mnd_pecalloc(1, alloc_size, conn->persistent); conn 208 ext/mysqlnd/mysqlnd_driver.c ret->persistent = conn->persistent; conn 210 ext/mysqlnd/mysqlnd_driver.c stmt = ret->data = mnd_pecalloc(1, sizeof(MYSQLND_STMT_DATA), conn->persistent); conn 215 ext/mysqlnd/mysqlnd_driver.c stmt->persistent = conn->persistent; conn 231 ext/mysqlnd/mysqlnd_driver.c stmt->conn = conn->m->get_reference(conn TSRMLS_CC); conn 237 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 242 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 TSRMLS_DC) 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 TSRMLS_DC) 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 TSRMLS_DC); 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 TSRMLS_DC); 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 141 ext/mysqlnd/mysqlnd_loaddata.c mysqlnd_set_local_infile_handler(MYSQLND_CONN_DATA * const conn, const char * const funcname) conn 143 ext/mysqlnd/mysqlnd_loaddata.c if (!conn->infile.callback) { conn 144 ext/mysqlnd/mysqlnd_loaddata.c MAKE_STD_ZVAL(conn->infile.callback); conn 146 ext/mysqlnd/mysqlnd_loaddata.c zval_dtor(conn->infile.callback); conn 148 ext/mysqlnd/mysqlnd_loaddata.c ZVAL_STRING(conn->infile.callback, (char*) funcname, 1); conn 158 ext/mysqlnd/mysqlnd_loaddata.c mysqlnd_handle_local_infile(MYSQLND_CONN_DATA * conn, const char * filename, zend_bool * is_warning TSRMLS_DC) conn 168 ext/mysqlnd/mysqlnd_loaddata.c MYSQLND_NET * net = conn->net; conn 172 ext/mysqlnd/mysqlnd_loaddata.c if (!(conn->options->flags & CLIENT_LOCAL_FILES)) { conn 175 ext/mysqlnd/mysqlnd_loaddata.c ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC); conn 180 ext/mysqlnd/mysqlnd_loaddata.c infile = conn->infile; conn 187 ext/mysqlnd/mysqlnd_loaddata.c if (infile.local_infile_init(&info, (char *)filename, conn->infile.userdata TSRMLS_CC)) { conn 188 ext/mysqlnd/mysqlnd_loaddata.c char tmp_buf[sizeof(conn->error_info->error)]; conn 193 ext/mysqlnd/mysqlnd_loaddata.c SET_CLIENT_ERROR(*conn->error_info, tmp_error_no, UNKNOWN_SQLSTATE, tmp_buf); conn 195 ext/mysqlnd/mysqlnd_loaddata.c ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC); conn 201 ext/mysqlnd/mysqlnd_loaddata.c if ((ret = net->data->m.send_ex(net, buf, bufsize, conn->stats, conn->error_info TSRMLS_CC)) == 0) { conn 203 ext/mysqlnd/mysqlnd_loaddata.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn); conn 209 ext/mysqlnd/mysqlnd_loaddata.c if ((ret = net->data->m.send_ex(net, empty_packet, 0, conn->stats, conn->error_info TSRMLS_CC)) == 0) { conn 210 ext/mysqlnd/mysqlnd_loaddata.c SET_CLIENT_ERROR(*conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn); conn 216 ext/mysqlnd/mysqlnd_loaddata.c char tmp_buf[sizeof(conn->error_info->error)]; conn 221 ext/mysqlnd/mysqlnd_loaddata.c SET_CLIENT_ERROR(*conn->error_info, tmp_error_no, UNKNOWN_SQLSTATE, tmp_buf); conn 229 ext/mysqlnd/mysqlnd_loaddata.c if (FAIL == conn->m->simple_command_handle_response(conn, PROT_OK_PACKET, FALSE, COM_QUERY, FALSE TSRMLS_CC)) { conn 233 ext/mysqlnd/mysqlnd_loaddata.c (*conn->infile.local_infile_end)(info TSRMLS_CC); conn 192 ext/mysqlnd/mysqlnd_priv.h enum_func_status mysqlnd_handle_local_infile(MYSQLND_CONN_DATA * conn, const char * filename, zend_bool * is_warning TSRMLS_DC); conn 212 ext/mysqlnd/mysqlnd_priv.h mysqlnd_auth_handshake(MYSQLND_CONN_DATA * conn, conn 232 ext/mysqlnd/mysqlnd_priv.h mysqlnd_auth_change_user(MYSQLND_CONN_DATA * const conn, conn 51 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 55 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->result) { conn 60 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 73 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) != CONN_FETCHING_DATA || conn 76 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, conn 84 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*conn->error_info); conn 85 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_PS_BUFFERED_SETS); conn 93 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 97 ext/mysqlnd/mysqlnd_ps.c ret = result->m.store_result_fetch_data(conn, result, result->meta, &result->stored_data->row_buffers, TRUE TSRMLS_CC); conn 108 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 114 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 130 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*conn->error_info, result->stored_data->error_info); conn 147 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 151 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->result) { conn 156 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 169 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) != CONN_FETCHING_DATA || stmt->state != MYSQLND_STMT_WAITING_USE_OR_STORE) { conn 170 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, conn 176 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*conn->error_info); conn 177 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_BUFFERED_SETS); conn 180 ext/mysqlnd/mysqlnd_ps.c result = conn->m->result_init(stmt->result->field_count, stmt->persistent TSRMLS_CC); conn 182 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 188 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 192 ext/mysqlnd/mysqlnd_ps.c if ((result = result->m.store_result(result, conn, MYSQLND_STORE_PS | MYSQLND_STORE_NO_COPY TSRMLS_CC))) { conn 197 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 219 ext/mysqlnd/mysqlnd_ps.c DBG_RETURN((stmt && stmt->conn && (stmt->conn->m->get_server_status(stmt->conn TSRMLS_CC) & SERVER_MORE_RESULTS_EXISTS))? conn 231 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 234 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->result) { conn 237 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 240 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) != CONN_NEXT_RESULT_PENDING || !(conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS)) { conn 267 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->conn->protocol) { conn 272 ext/mysqlnd/mysqlnd_ps.c field_packet = stmt->conn->protocol->m.get_result_field_packet(stmt->conn->protocol, FALSE TSRMLS_CC); conn 275 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 280 ext/mysqlnd/mysqlnd_ps.c if (FAIL == PACKET_READ(field_packet, stmt->conn)) { conn 302 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->conn->protocol) { conn 307 ext/mysqlnd/mysqlnd_ps.c prepare_resp = stmt->conn->protocol->m.get_prepare_response_packet(stmt->conn->protocol, FALSE TSRMLS_CC); conn 310 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 314 ext/mysqlnd/mysqlnd_ps.c if (FAIL == PACKET_READ(prepare_resp, stmt->conn)) { conn 320 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->conn->error_info, prepare_resp->error_info); conn 325 ext/mysqlnd/mysqlnd_ps.c stmt->warning_count = stmt->conn->upsert_status->warning_count = prepare_resp->warning_count; conn 326 ext/mysqlnd/mysqlnd_ps.c stmt->field_count = stmt->conn->field_count = prepare_resp->field_count; conn 346 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->conn->protocol) { conn 351 ext/mysqlnd/mysqlnd_ps.c fields_eof = stmt->conn->protocol->m.get_eof_packet(stmt->conn->protocol, FALSE TSRMLS_CC); conn 354 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 356 ext/mysqlnd/mysqlnd_ps.c if (FAIL == (ret = PACKET_READ(fields_eof, stmt->conn))) { conn 385 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 392 ext/mysqlnd/mysqlnd_ps.c SET_ERROR_AFF_ROWS(stmt->conn); conn 395 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 412 ext/mysqlnd/mysqlnd_ps.c s_to_prepare = stmt->conn->m->stmt_init(stmt->conn TSRMLS_CC); conn 419 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 TSRMLS_CC) || conn 439 ext/mysqlnd/mysqlnd_ps.c MYSQLND_RES * result = stmt->conn->m->result_init(stmt_to_prepare->field_count, stmt_to_prepare->persistent TSRMLS_CC); conn 441 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 447 ext/mysqlnd/mysqlnd_ps.c result->conn = stmt_to_prepare->conn->m->get_reference(stmt_to_prepare->conn TSRMLS_CC); conn 451 ext/mysqlnd/mysqlnd_ps.c if (FAIL == result->m.read_result_metadata(result, stmt_to_prepare->conn TSRMLS_CC) || conn 495 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 498 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 501 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 502 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(conn, CONN_QUERY_SENT); conn 504 ext/mysqlnd/mysqlnd_ps.c ret = mysqlnd_query_read_result_set_header(stmt->conn, s TSRMLS_CC); conn 506 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 508 ext/mysqlnd/mysqlnd_ps.c stmt->upsert_status->affected_rows = conn->upsert_status->affected_rows; conn 509 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) == CONN_QUIT_SENT) { conn 523 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 524 ext/mysqlnd/mysqlnd_ps.c *stmt->upsert_status = *conn->upsert_status; /* copy status */ conn 526 ext/mysqlnd/mysqlnd_ps.c if (conn->last_query_type == QUERY_UPSERT || conn->last_query_type == QUERY_LOAD_LOCAL) { conn 532 ext/mysqlnd/mysqlnd_ps.c if (!stmt->result->conn) { conn 537 ext/mysqlnd/mysqlnd_ps.c stmt->result->conn = stmt->conn->m->get_reference(stmt->conn TSRMLS_CC); conn 541 ext/mysqlnd/mysqlnd_ps.c stmt->field_count = stmt->result->field_count = conn->field_count; conn 560 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(conn, CONN_READY); conn 608 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 614 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 617 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 621 ext/mysqlnd/mysqlnd_ps.c SET_ERROR_AFF_ROWS(stmt->conn); conn 667 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, conn 702 ext/mysqlnd/mysqlnd_ps.c ret = stmt->conn->m->simple_command(stmt->conn, COM_STMT_EXECUTE, request, request_len, conn 714 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 724 ext/mysqlnd/mysqlnd_ps.c if (ret == PASS && conn->last_query_type == QUERY_UPSERT && stmt->upsert_status->affected_rows) { conn 725 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, STAT_ROWS_AFFECTED_PS, stmt->upsert_status->affected_rows); conn 762 ext/mysqlnd/mysqlnd_ps.c result->conn->options->int_and_float_native, conn 763 ext/mysqlnd/mysqlnd_ps.c result->conn->stats TSRMLS_CC); conn 852 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { conn 853 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, conn 869 ext/mysqlnd/mysqlnd_ps.c if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { conn 873 ext/mysqlnd/mysqlnd_ps.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL TSRMLS_CC); conn 884 ext/mysqlnd/mysqlnd_ps.c result->conn->options->int_and_float_native, conn 885 ext/mysqlnd/mysqlnd_ps.c result->conn->stats TSRMLS_CC)) conn 910 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(stmt->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_PS_UNBUF); conn 927 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->conn->error_info, row_packet->error_info); conn 930 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(result->conn, CONN_READY); conn 936 ext/mysqlnd/mysqlnd_ps.c memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); conn 937 ext/mysqlnd/mysqlnd_ps.c result->conn->upsert_status->warning_count = row_packet->warning_count; conn 938 ext/mysqlnd/mysqlnd_ps.c result->conn->upsert_status->server_status = row_packet->server_status; conn 943 ext/mysqlnd/mysqlnd_ps.c if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 944 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); conn 946 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(result->conn, CONN_READY); conn 962 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 965 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !stmt->result) { conn 970 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 973 ext/mysqlnd/mysqlnd_ps.c (!stmt->cursor_exists && CONN_GET_STATE(conn) != CONN_FETCHING_DATA) || conn 974 ext/mysqlnd/mysqlnd_ps.c (stmt->cursor_exists && CONN_GET_STATE(conn) != CONN_READY) || conn 977 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*conn->error_info, CR_COMMANDS_OUT_OF_SYNC, conn 985 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(stmt->conn->stats, STAT_PS_UNBUFFERED_SETS); conn 1013 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !result || !result->conn || !result->unbuf) { conn 1022 ext/mysqlnd/mysqlnd_ps.c SET_CLIENT_ERROR(*stmt->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, conn 1032 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1037 ext/mysqlnd/mysqlnd_ps.c if (FAIL == stmt->conn->m->simple_command(stmt->conn, COM_STMT_FETCH, buf, sizeof(buf), conn 1040 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *stmt->conn->error_info); conn 1047 ext/mysqlnd/mysqlnd_ps.c if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { conn 1052 ext/mysqlnd/mysqlnd_ps.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL TSRMLS_CC); conn 1063 ext/mysqlnd/mysqlnd_ps.c result->conn->options->int_and_float_native, conn 1064 ext/mysqlnd/mysqlnd_ps.c result->conn->stats TSRMLS_CC)) conn 1104 ext/mysqlnd/mysqlnd_ps.c ret = PACKET_READ(row_packet, result->conn); conn 1109 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(stmt->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_PS_CURSOR); conn 1117 ext/mysqlnd/mysqlnd_ps.c stmt->conn->upsert_status->warning_count = conn 1121 ext/mysqlnd/mysqlnd_ps.c stmt->conn->upsert_status->server_status = conn 1127 ext/mysqlnd/mysqlnd_ps.c stmt->conn->upsert_status->warning_count = conn 1130 ext/mysqlnd/mysqlnd_ps.c stmt->conn->upsert_status->server_status = conn 1149 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1168 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1205 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1211 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1214 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn = stmt->conn; conn 1235 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) == CONN_READY && conn 1236 ext/mysqlnd/mysqlnd_ps.c FAIL == (ret = conn->m->simple_command(conn, COM_STMT_RESET, cmd_buf, conn 1239 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 1241 ext/mysqlnd/mysqlnd_ps.c *stmt->upsert_status = *conn->upsert_status; conn 1257 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1294 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 1299 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1304 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 1307 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1340 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) == CONN_READY) { conn 1351 ext/mysqlnd/mysqlnd_ps.c ret = conn->m->simple_command(conn, cmd, cmd_buf, packet_len, PROT_LAST , FALSE, TRUE TSRMLS_CC); conn 1354 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 1359 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*conn->error_info); conn 1381 ext/mysqlnd/mysqlnd_ps.c if ((packet_len = conn->net->m.consume_uneaten_data(conn->net, cmd TSRMLS_CC))) { conn 1405 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1420 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1476 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1493 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1532 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1544 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1561 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1576 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1615 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1633 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 1796 ext/mysqlnd/mysqlnd_ps.c if (!stmt->field_count || !stmt->conn || !stmt->result || !stmt->result->meta) { conn 1803 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 1804 ext/mysqlnd/mysqlnd_ps.c stmt->conn->options->int_and_float_native TSRMLS_CC); conn 1816 ext/mysqlnd/mysqlnd_ps.c result = stmt->conn->m->result_init(stmt->field_count, stmt->persistent TSRMLS_CC); conn 1835 ext/mysqlnd/mysqlnd_ps.c SET_OOM_ERROR(*stmt->conn->error_info); conn 1938 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 1979 ext/mysqlnd/mysqlnd_ps.c CONN_SET_STATE(stmt->conn, CONN_READY); conn 2166 ext/mysqlnd/mysqlnd_ps.c MYSQLND_CONN_DATA * conn; conn 2171 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn) { conn 2176 ext/mysqlnd/mysqlnd_ps.c conn = stmt->conn; conn 2179 ext/mysqlnd/mysqlnd_ps.c SET_EMPTY_ERROR(*stmt->conn->error_info); conn 2208 ext/mysqlnd/mysqlnd_ps.c if (CONN_GET_STATE(conn) == CONN_READY && conn 2209 ext/mysqlnd/mysqlnd_ps.c FAIL == conn->m->simple_command(conn, COM_STMT_CLOSE, cmd_buf, sizeof(cmd_buf), conn 2212 ext/mysqlnd/mysqlnd_ps.c COPY_CLIENT_ERROR(*stmt->error_info, *conn->error_info); conn 2227 ext/mysqlnd/mysqlnd_ps.c MYSQLND_INC_CONN_STATISTIC(conn->stats, statistic); conn 2237 ext/mysqlnd/mysqlnd_ps.c if (stmt->conn) { conn 2238 ext/mysqlnd/mysqlnd_ps.c stmt->conn->m->free_reference(stmt->conn TSRMLS_CC); conn 2239 ext/mysqlnd/mysqlnd_ps.c stmt->conn = NULL; conn 2381 ext/mysqlnd/mysqlnd_ps.c _mysqlnd_stmt_init(MYSQLND_CONN_DATA * const conn TSRMLS_DC) conn 2385 ext/mysqlnd/mysqlnd_ps.c ret = MYSQLND_CLASS_METHOD_TABLE_NAME(mysqlnd_object_factory).get_prepared_statement(conn TSRMLS_CC); conn 373 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_result(result->unbuf, result->conn? result->conn->stats : NULL TSRMLS_CC); conn 413 ext/mysqlnd/mysqlnd_result.c if (result->conn) { conn 414 ext/mysqlnd/mysqlnd_result.c result->conn->m->free_reference(result->conn TSRMLS_CC); conn 415 ext/mysqlnd/mysqlnd_result.c result->conn = NULL; conn 427 ext/mysqlnd/mysqlnd_result.c MYSQLND_METHOD(mysqlnd_res, read_result_metadata)(MYSQLND_RES * result, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 444 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 451 ext/mysqlnd/mysqlnd_result.c if (FAIL == result->meta->m->read_metadata(result->meta, conn TSRMLS_CC)) { conn 472 ext/mysqlnd/mysqlnd_result.c mysqlnd_query_read_result_set_header(MYSQLND_CONN_DATA * conn, MYSQLND_STMT * s TSRMLS_DC) conn 484 ext/mysqlnd/mysqlnd_result.c rset_header = conn->protocol->m.get_rset_header_packet(conn->protocol, FALSE TSRMLS_CC); conn 486 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 491 ext/mysqlnd/mysqlnd_result.c SET_ERROR_AFF_ROWS(conn); conn 493 ext/mysqlnd/mysqlnd_result.c if (FAIL == (ret = PACKET_READ(rset_header, conn))) { conn 508 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->server_status &= ~SERVER_MORE_RESULTS_EXISTS; conn 513 ext/mysqlnd/mysqlnd_result.c COPY_CLIENT_ERROR(*conn->error_info, rset_header->error_info); conn 517 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_READY); conn 520 ext/mysqlnd/mysqlnd_result.c conn->error_info->error_no = 0; conn 526 ext/mysqlnd/mysqlnd_result.c conn->last_query_type = QUERY_LOAD_LOCAL; conn 527 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 528 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_SENDING_LOAD_DATA); conn 529 ext/mysqlnd/mysqlnd_result.c ret = mysqlnd_handle_local_infile(conn, rset_header->info_or_local_file, &is_warning TSRMLS_CC); conn 530 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, (ret == PASS || is_warning == TRUE)? CONN_READY:CONN_QUIT_SENT); conn 531 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_NON_RSET_QUERY); conn 536 ext/mysqlnd/mysqlnd_result.c conn->last_query_type = QUERY_UPSERT; conn 537 ext/mysqlnd/mysqlnd_result.c conn->field_count = rset_header->field_count; conn 538 ext/mysqlnd/mysqlnd_result.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 539 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->warning_count = rset_header->warning_count; conn 540 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->server_status = rset_header->server_status; conn 541 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->affected_rows = rset_header->affected_rows; conn 542 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->last_insert_id = rset_header->last_insert_id; conn 543 ext/mysqlnd/mysqlnd_result.c SET_NEW_MESSAGE(conn->last_message, conn->last_message_len, conn 545 ext/mysqlnd/mysqlnd_result.c conn->persistent); conn 547 ext/mysqlnd/mysqlnd_result.c if (conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 548 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_NEXT_RESULT_PENDING); conn 550 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_READY); conn 553 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_NON_RSET_QUERY); conn 560 ext/mysqlnd/mysqlnd_result.c SET_EMPTY_MESSAGE(conn->last_message, conn->last_message_len, conn->persistent); conn 562 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_RSET_QUERY); conn 563 ext/mysqlnd/mysqlnd_result.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 565 ext/mysqlnd/mysqlnd_result.c SET_ERROR_AFF_ROWS(conn); conn 567 ext/mysqlnd/mysqlnd_result.c conn->last_query_type = QUERY_SELECT; conn 568 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_FETCHING_DATA); conn 570 ext/mysqlnd/mysqlnd_result.c conn->field_count = rset_header->field_count; conn 572 ext/mysqlnd/mysqlnd_result.c result = conn->current_result = conn->m->result_init(rset_header->field_count, conn->persistent TSRMLS_CC); conn 581 ext/mysqlnd/mysqlnd_result.c result = stmt->result = conn->m->result_init(rset_header->field_count, stmt->persistent TSRMLS_CC); conn 599 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 604 ext/mysqlnd/mysqlnd_result.c if (FAIL == (ret = result->m.read_result_metadata(result, conn TSRMLS_CC))) { conn 606 ext/mysqlnd/mysqlnd_result.c if (!stmt && conn->current_result) { conn 607 ext/mysqlnd/mysqlnd_result.c mnd_efree(conn->current_result); conn 608 ext/mysqlnd/mysqlnd_result.c conn->current_result = NULL; conn 615 ext/mysqlnd/mysqlnd_result.c fields_eof = conn->protocol->m.get_eof_packet(conn->protocol, FALSE TSRMLS_CC); conn 617 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 621 ext/mysqlnd/mysqlnd_result.c if (FAIL == (ret = PACKET_READ(fields_eof, conn))) { conn 626 ext/mysqlnd/mysqlnd_result.c conn->current_result = NULL; conn 636 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->warning_count = fields_eof->warning_count; conn 644 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->server_status = fields_eof->server_status; conn 659 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(conn->stats, statistic); conn 772 ext/mysqlnd/mysqlnd_result.c if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { conn 773 ext/mysqlnd/mysqlnd_result.c SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 787 ext/mysqlnd/mysqlnd_result.c if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { conn 788 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL TSRMLS_CC); conn 795 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(result->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_NORMAL_UNBUF); conn 804 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 805 ext/mysqlnd/mysqlnd_result.c result->conn->stats TSRMLS_CC); conn 837 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*result->conn->error_info); conn 845 ext/mysqlnd/mysqlnd_result.c COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); conn 848 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_READY); conn 854 ext/mysqlnd/mysqlnd_result.c memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); conn 855 ext/mysqlnd/mysqlnd_result.c result->conn->upsert_status->warning_count = row_packet->warning_count; conn 856 ext/mysqlnd/mysqlnd_result.c result->conn->upsert_status->server_status = row_packet->server_status; conn 861 ext/mysqlnd/mysqlnd_result.c if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 862 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); conn 864 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_READY); conn 866 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL TSRMLS_CC); conn 891 ext/mysqlnd/mysqlnd_result.c if (CONN_GET_STATE(result->conn) != CONN_FETCHING_DATA) { conn 892 ext/mysqlnd/mysqlnd_result.c SET_CLIENT_ERROR(*result->conn->error_info, CR_COMMANDS_OUT_OF_SYNC, UNKNOWN_SQLSTATE, mysqlnd_out_of_sync); conn 906 ext/mysqlnd/mysqlnd_result.c if (PASS == (ret = PACKET_READ(row_packet, result->conn)) && !row_packet->eof) { conn 907 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL TSRMLS_CC); conn 914 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(result->conn->stats, STAT_ROWS_FETCHED_FROM_CLIENT_NORMAL_UNBUF); conn 923 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 924 ext/mysqlnd/mysqlnd_result.c result->conn->stats TSRMLS_CC); conn 975 ext/mysqlnd/mysqlnd_result.c COPY_CLIENT_ERROR(*result->conn->error_info, row_packet->error_info); conn 978 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_READY); conn 984 ext/mysqlnd/mysqlnd_result.c memset(result->conn->upsert_status, 0, sizeof(*result->conn->upsert_status)); conn 985 ext/mysqlnd/mysqlnd_result.c result->conn->upsert_status->warning_count = row_packet->warning_count; conn 986 ext/mysqlnd/mysqlnd_result.c result->conn->upsert_status->server_status = row_packet->server_status; conn 991 ext/mysqlnd/mysqlnd_result.c if (result->conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 992 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_NEXT_RESULT_PENDING); conn 994 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(result->conn, CONN_READY); conn 996 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL TSRMLS_CC); conn 1011 ext/mysqlnd/mysqlnd_result.c SET_EMPTY_ERROR(*result->conn->error_info); conn 1030 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet = result->conn->protocol->m.get_row_packet(result->conn->protocol, FALSE TSRMLS_CC); conn 1043 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*result->conn->error_info); conn 1075 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 1076 ext/mysqlnd/mysqlnd_result.c result->conn->stats TSRMLS_CC); conn 1115 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*result->conn->error_info); conn 1166 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 1167 ext/mysqlnd/mysqlnd_result.c result->conn->stats TSRMLS_CC); conn 1255 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*result->conn->error_info); conn 1263 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native, conn 1264 ext/mysqlnd/mysqlnd_result.c result->conn->stats TSRMLS_CC); conn 1364 ext/mysqlnd/mysqlnd_result.c MYSQLND_METHOD(mysqlnd_res, store_result_fetch_data)(MYSQLND_CONN_DATA * const conn, MYSQLND_RES * result, conn 1385 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1393 ext/mysqlnd/mysqlnd_result.c row_packet = conn->protocol->m.get_row_packet(conn->protocol, FALSE TSRMLS_CC); conn 1395 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1408 ext/mysqlnd/mysqlnd_result.c while (FAIL != (ret = PACKET_READ(row_packet, conn)) && !row_packet->eof) { conn 1416 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 1445 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC_W_VALUE(conn->stats, conn 1452 ext/mysqlnd/mysqlnd_result.c memset(conn->upsert_status, 0, sizeof(*conn->upsert_status)); conn 1453 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->warning_count = row_packet->warning_count; conn 1454 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->server_status = row_packet->server_status; conn 1460 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1467 ext/mysqlnd/mysqlnd_result.c if (conn->upsert_status->server_status & SERVER_MORE_RESULTS_EXISTS) { conn 1468 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_NEXT_RESULT_PENDING); conn 1470 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_READY); conn 1477 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->affected_rows = set->row_count; conn 1480 ext/mysqlnd/mysqlnd_result.c ret == PASS? "PASS":"FAIL", (uint) set->row_count, conn->upsert_status->warning_count, conn->upsert_status->server_status); conn 1492 ext/mysqlnd/mysqlnd_result.c MYSQLND_CONN_DATA * const conn, conn 1502 ext/mysqlnd/mysqlnd_result.c result->conn = conn->m->get_reference(conn TSRMLS_CC); conn 1505 ext/mysqlnd/mysqlnd_result.c CONN_SET_STATE(conn, CONN_FETCHING_DATA); conn 1510 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1517 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1522 ext/mysqlnd/mysqlnd_result.c ret = result->m.store_result_fetch_data(conn, result, result->meta, row_buffers, flags & MYSQLND_STORE_PS TSRMLS_CC); conn 1526 ext/mysqlnd/mysqlnd_result.c COPY_CLIENT_ERROR(*conn->error_info, result->stored_data->error_info); conn 1528 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1539 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1545 ext/mysqlnd/mysqlnd_result.c SET_OOM_ERROR(*conn->error_info); conn 1560 ext/mysqlnd/mysqlnd_result.c conn->upsert_status->affected_rows = result->stored_data->row_count; conn 1582 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(result->conn->stats, conn 1601 ext/mysqlnd/mysqlnd_result.c MYSQLND_INC_CONN_STATISTIC(result->conn? result->conn->stats : NULL, conn 1718 ext/mysqlnd/mysqlnd_result.c if (PASS != result->stored_data->m.initialize_result_set_rest(result->stored_data, result->meta, result->conn->stats, conn 1719 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native TSRMLS_CC)) conn 1752 ext/mysqlnd/mysqlnd_result.c if (PASS != result->stored_data->m.initialize_result_set_rest(result->stored_data, result->meta, result->conn->stats, conn 1753 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native TSRMLS_CC)) conn 1776 ext/mysqlnd/mysqlnd_result.c if (PASS != result->stored_data->m.initialize_result_set_rest(result->stored_data, result->meta, result->conn->stats, conn 1777 ext/mysqlnd/mysqlnd_result.c result->conn->options->int_and_float_native TSRMLS_CC)) conn 1881 ext/mysqlnd/mysqlnd_result.c if (result->conn) { conn 1882 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 TSRMLS_DC); conn 97 ext/mysqlnd/mysqlnd_result_meta.c MYSQLND_METHOD(mysqlnd_res_meta, read_metadata)(MYSQLND_RES_METADATA * const meta, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 104 ext/mysqlnd/mysqlnd_result_meta.c field_packet = conn->protocol->m.get_result_field_packet(conn->protocol, FALSE TSRMLS_CC); conn 106 ext/mysqlnd/mysqlnd_result_meta.c SET_OOM_ERROR(*conn->error_info); conn 120 ext/mysqlnd/mysqlnd_result_meta.c if (FAIL == PACKET_READ(field_packet, conn)) { conn 125 ext/mysqlnd/mysqlnd_result_meta.c COPY_CLIENT_ERROR(*conn->error_info, field_packet->error_info); conn 407 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND * (*func_mysqlnd_object_factory__clone_connection_object)(MYSQLND * conn TSRMLS_DC); conn 408 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_STMT * (*func_mysqlnd_object_factory__get_prepared_statement)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 423 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__init)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 424 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 TSRMLS_DC); conn 425 ext/mysqlnd/mysqlnd_structs.h typedef ulong (*func_mysqlnd_conn_data__escape_string)(MYSQLND_CONN_DATA * const conn, char *newstr, const char *escapestr, size_t escapestr_len TSRMLS_DC); conn 426 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__set_charset)(MYSQLND_CONN_DATA * const conn, const char * const charset TSRMLS_DC); conn 427 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 TSRMLS_DC); conn 428 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 TSRMLS_DC); conn 429 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__reap_query)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 430 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_RES * (*func_mysqlnd_conn_data__use_result)(MYSQLND_CONN_DATA * const conn, const unsigned int flags TSRMLS_DC); conn 431 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_RES * (*func_mysqlnd_conn_data__store_result)(MYSQLND_CONN_DATA * const conn, const unsigned int flags TSRMLS_DC); conn 432 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__next_result)(MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 433 ext/mysqlnd/mysqlnd_structs.h typedef zend_bool (*func_mysqlnd_conn_data__more_results)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 435 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_STMT * (*func_mysqlnd_conn_data__stmt_init)(MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 437 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__shutdown_server)(MYSQLND_CONN_DATA * const conn, uint8_t level TSRMLS_DC); conn 438 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__refresh_server)(MYSQLND_CONN_DATA * const conn, uint8_t options TSRMLS_DC); conn 440 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__ping)(MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 441 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__kill_connection)(MYSQLND_CONN_DATA * conn, unsigned int pid TSRMLS_DC); conn 442 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 TSRMLS_DC); conn 443 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__server_dump_debug_information)(MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 444 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 TSRMLS_DC); conn 446 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_error_no)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 447 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_error_str)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 448 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_sqlstate)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 449 ext/mysqlnd/mysqlnd_structs.h typedef uint64_t (*func_mysqlnd_conn_data__get_thread_id)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 450 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn_data__get_statistics)(const MYSQLND_CONN_DATA * const conn, zval *return_value TSRMLS_DC ZEND_FILE_LINE_DC); conn 452 ext/mysqlnd/mysqlnd_structs.h typedef unsigned long (*func_mysqlnd_conn_data__get_server_version)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 453 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_server_information)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 454 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__get_server_statistics)(MYSQLND_CONN_DATA * conn, char **message, unsigned int * message_len TSRMLS_DC); conn 455 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_host_information)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 456 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_protocol_information)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 457 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__get_last_message)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 458 ext/mysqlnd/mysqlnd_structs.h typedef const char * (*func_mysqlnd_conn_data__charset_name)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 459 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 TSRMLS_DC); conn 460 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 TSRMLS_DC); conn 462 ext/mysqlnd/mysqlnd_structs.h typedef uint64_t (*func_mysqlnd_conn_data__get_last_insert_id)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 463 ext/mysqlnd/mysqlnd_structs.h typedef uint64_t (*func_mysqlnd_conn_data__get_affected_rows)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 464 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_warning_count)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 466 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_field_count)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 468 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_server_status)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 469 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 TSRMLS_DC); conn 470 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 TSRMLS_DC); conn 471 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn_data__free_contents)(MYSQLND_CONN_DATA * conn TSRMLS_DC);/* private */ conn 472 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn_data__free_options)(MYSQLND_CONN_DATA * conn TSRMLS_DC); /* private */ conn 473 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn_data__dtor)(MYSQLND_CONN_DATA * conn TSRMLS_DC); /* private */ conn 475 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 TSRMLS_DC); conn 477 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND_CONN_DATA * (*func_mysqlnd_conn_data__get_reference)(MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 478 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__free_reference)(MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 479 ext/mysqlnd/mysqlnd_structs.h typedef enum mysqlnd_connection_state (*func_mysqlnd_conn_data__get_state)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 485 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__restart_psession)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 486 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__end_psession)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 487 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__send_close)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 494 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__tx_commit)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 495 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__tx_rollback)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 504 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_conn_data__execute_init_commands)(MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 514 ext/mysqlnd/mysqlnd_structs.h typedef unsigned int (*func_mysqlnd_conn_data__get_client_api_capabilities)(const MYSQLND_CONN_DATA * const conn TSRMLS_DC); conn 615 ext/mysqlnd/mysqlnd_structs.h typedef MYSQLND * (*func_mysqlnd_conn__clone_object)(MYSQLND * const conn TSRMLS_DC); conn 616 ext/mysqlnd/mysqlnd_structs.h typedef void (*func_mysqlnd_conn__dtor)(MYSQLND * conn TSRMLS_DC); conn 649 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_res__read_result_metadata)(MYSQLND_RES * result, MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 739 ext/mysqlnd/mysqlnd_structs.h typedef enum_func_status (*func_mysqlnd_res_meta__read_metadata)(MYSQLND_RES_METADATA * const meta, MYSQLND_CONN_DATA * conn TSRMLS_DC); 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) TSRMLS_CC)) {\ 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) TSRMLS_CC)) { \ 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 323 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_greet_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 333 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, sizeof(buf), "greeting", PROT_GREET_PACKET); conn 485 ext/mysqlnd/mysqlnd_wireprotocol.c size_t php_mysqlnd_auth_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 521 ext/mysqlnd/mysqlnd_wireprotocol.c SET_CLIENT_ERROR(*conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, msg); conn 580 ext/mysqlnd/mysqlnd_wireprotocol.c zend_hash_move_forward_ex(conn->options->connect_attr, &pos_value); conn 602 ext/mysqlnd/mysqlnd_wireprotocol.c zend_hash_move_forward_ex(conn->options->connect_attr, &pos_value); conn 610 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 617 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 TSRMLS_CC); conn 619 ext/mysqlnd/mysqlnd_wireprotocol.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 643 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_auth_response_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 646 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.buffer? conn->net->cmd_buffer.length: AUTH_RESP_BUFFER_SIZE; conn 647 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = conn->net->cmd_buffer.buffer? (zend_uchar *) conn->net->cmd_buffer.buffer : local_buf; conn 657 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); conn 763 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_change_auth_response_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 766 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 777 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 TSRMLS_CC); conn 778 ext/mysqlnd/mysqlnd_wireprotocol.c if (buffer != conn->net->cmd_buffer.buffer) { conn 782 ext/mysqlnd/mysqlnd_wireprotocol.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 806 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_ok_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 809 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.buffer? conn->net->cmd_buffer.length : OK_BUFFER_SIZE; conn 810 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = conn->net->cmd_buffer.buffer? (zend_uchar *) conn->net->cmd_buffer.buffer : local_buf; conn 818 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "OK", PROT_OK_PACKET); conn 831 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 892 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_eof_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 901 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 902 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 908 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "EOF", PROT_EOF_PACKET); conn 969 ext/mysqlnd/mysqlnd_wireprotocol.c size_t php_mysqlnd_cmd_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 973 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_NET * net = conn->net; conn 989 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_PACKETS_SENT_CMD); conn 999 ext/mysqlnd/mysqlnd_wireprotocol.c sent = net->data->m.send_ex(net, buffer, 1, conn->stats, conn->error_info TSRMLS_CC); conn 1014 ext/mysqlnd/mysqlnd_wireprotocol.c sent = net->data->m.send_ex(net, tmp, tmp_len - MYSQLND_HEADER_SIZE, conn->stats, conn->error_info TSRMLS_CC); conn 1016 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC(conn->stats, STAT_CMD_BUFFER_TOO_SMALL); conn 1026 ext/mysqlnd/mysqlnd_wireprotocol.c CONN_SET_STATE(conn, CONN_QUIT_SENT); conn 1047 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_rset_header_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 1050 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 1051 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 1059 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "resultset header", PROT_RSET_HEADER_PACKET); conn 1074 ext/mysqlnd/mysqlnd_wireprotocol.c DBG_INF_FMT("conn->server_status=%u", conn->upsert_status->server_status); conn 1098 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1125 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1186 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_rset_field_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 1190 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length, total_len = 0; conn 1191 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 1201 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "field", PROT_RSET_FLD_PACKET); conn 1302 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1314 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1396 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_read_row_ex(MYSQLND_CONN_DATA * conn, MYSQLND_MEMORY_POOL * result_set_memory_pool, conn 1418 ext/mysqlnd/mysqlnd_wireprotocol.c if (FAIL == mysqlnd_read_header(conn->net, &header, conn->stats, conn->error_info TSRMLS_CC)) { conn 1450 ext/mysqlnd/mysqlnd_wireprotocol.c SET_OOM_ERROR(*conn->error_info); conn 1458 ext/mysqlnd/mysqlnd_wireprotocol.c if (PASS != (ret = conn->net->data->m.receive_ex(conn->net, p, header.size, conn->stats, conn->error_info TSRMLS_CC))) { conn 1798 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_rowp_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 1813 ext/mysqlnd/mysqlnd_wireprotocol.c ret = php_mysqlnd_read_row_ex(conn, packet->result_set_memory_pool, &packet->row_buffer, &data_size, conn 1819 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC_W_VALUE2(conn->stats, packet_type_to_statistic_byte_count[PROT_ROW_PACKET], conn 1852 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC(conn->stats, conn 1876 ext/mysqlnd/mysqlnd_wireprotocol.c MYSQLND_INC_CONN_STATISTIC(conn->stats, conn 1918 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_stats_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 1921 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 1922 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 1926 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "statistics", PROT_STATS_PACKET); conn 1960 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_prepare_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 1963 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 1964 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 1972 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "prepare", PROT_PREPARE_RESP_PACKET); conn 2048 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_chg_user_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 2051 ext/mysqlnd/mysqlnd_wireprotocol.c size_t buf_len = conn->net->cmd_buffer.length; conn 2052 ext/mysqlnd/mysqlnd_wireprotocol.c zend_uchar *buf = (zend_uchar *) conn->net->cmd_buffer.buffer; conn 2059 ext/mysqlnd/mysqlnd_wireprotocol.c PACKET_READ_HEADER_AND_BODY(packet, conn, buf, buf_len, "change user response", PROT_CHG_USER_RESP_PACKET); conn 2136 ext/mysqlnd/mysqlnd_wireprotocol.c size_t php_mysqlnd_sha256_pk_request_write(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 2144 ext/mysqlnd/mysqlnd_wireprotocol.c sent = conn->net->data->m.send_ex(conn->net, buffer, 1, conn->stats, conn->error_info TSRMLS_CC); conn 2167 ext/mysqlnd/mysqlnd_wireprotocol.c php_mysqlnd_sha256_pk_request_response_read(void * _packet, MYSQLND_CONN_DATA * conn TSRMLS_DC) conn 2177 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) TSRMLS_CC)) conn 40 ext/mysqlnd/mysqlnd_wireprotocol.h #define PACKET_READ(packet, conn) ((packet)->header.m->read_from_net((packet), (conn) TSRMLS_CC)) conn 54 ext/mysqlnd/mysqlnd_wireprotocol.h enum_func_status (*read_from_net)(void * packet, MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 55 ext/mysqlnd/mysqlnd_wireprotocol.h size_t (*write_to_net)(void * packet, MYSQLND_CONN_DATA * conn TSRMLS_DC); conn 163 ext/odbc/birdstep.c #define PHP_BIRDSTEP_CHK_LNK(id) if (!(conn = birdstep_find_conn(list, id))) { php_error_docref(NULL TSRMLS_CC, 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 TSRMLS_DC) conn 231 ext/odbc/birdstep.c ind = zend_list_insert(conn,php_birdstep_module.le_link TSRMLS_CC); 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 43 ext/odbc/php_birdstep.h VConn *conn; conn 477 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 505 ext/odbc/php_odbc.c odbc_connection *conn = (odbc_connection *)rsrc->ptr; conn 512 ext/odbc/php_odbc.c if (res->conn_ptr == conn) { conn 518 ext/odbc/php_odbc.c safe_odbc_disconnect(conn->hdbc); conn 519 ext/odbc/php_odbc.c SQLFreeConnect(conn->hdbc); conn 520 ext/odbc/php_odbc.c SQLFreeEnv(conn->henv); conn 521 ext/odbc/php_odbc.c free(conn); conn 879 ext/odbc/php_odbc.c ODBC_SQL_CONN_T conn; conn 884 ext/odbc/php_odbc.c conn = conn_resource->hdbc; conn 887 ext/odbc/php_odbc.c conn = SQL_NULL_HDBC; conn 895 ext/odbc/php_odbc.c rc = SQLError(henv, conn, stmt, state, &error, errormsg, sizeof(errormsg)-1, &errormsgsize); conn 1043 ext/odbc/php_odbc.c odbc_connection *conn; conn 1051 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 1053 ext/odbc/php_odbc.c rc = SQLTransact(conn->henv, conn->hdbc, (SQLUSMALLINT)((type)?SQL_COMMIT:SQL_ROLLBACK)); conn 1055 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLTransact"); conn 1187 ext/odbc/php_odbc.c odbc_connection *conn; conn 1198 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 1205 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 1213 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 1221 ext/odbc/php_odbc.c rc = SQLGetInfo(conn->hdbc, SQL_FETCH_DIRECTION, (void *) &scrollopts, sizeof(scrollopts), NULL); conn 1239 ext/odbc/php_odbc.c odbc_sql_error(conn, result->stmt, "SQLPrepare"); conn 1242 ext/odbc/php_odbc.c odbc_sql_error(conn, result->stmt, "SQLPrepare"); conn 1257 ext/odbc/php_odbc.c zend_list_addref(conn->id); conn 1258 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 1559 ext/odbc/php_odbc.c odbc_connection *conn; conn 1574 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &zv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 1577 ext/odbc/php_odbc.c rc = SQLDataSources(conn->henv, conn 1588 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLDataSources"); conn 1616 ext/odbc/php_odbc.c odbc_connection *conn; conn 1628 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 1632 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 1640 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 1648 ext/odbc/php_odbc.c rc = SQLGetInfo(conn->hdbc, SQL_FETCH_DIRECTION, (void *) &scrollopts, sizeof(scrollopts), NULL); conn 1666 ext/odbc/php_odbc.c odbc_sql_error(conn, result->stmt, "SQLExecDirect"); conn 1683 ext/odbc/php_odbc.c zend_list_addref(conn->id); conn 1684 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 2411 ext/odbc/php_odbc.c int odbc_sqlconnect(odbc_connection **conn, char *db, char *uid, char *pwd, int cur_opt, int persistent TSRMLS_DC) conn 2415 ext/odbc/php_odbc.c *conn = (odbc_connection *)pemalloc(sizeof(odbc_connection), persistent); conn 2416 ext/odbc/php_odbc.c (*conn)->persistent = persistent; conn 2417 ext/odbc/php_odbc.c SQLAllocEnv(&((*conn)->henv)); conn 2418 ext/odbc/php_odbc.c SQLAllocConnect((*conn)->henv, &((*conn)->hdbc)); conn 2421 ext/odbc/php_odbc.c SQLSetConnectOption((*conn)->hdbc, SQL_TRANSLATE_OPTION, conn 2458 ext/odbc/php_odbc.c rc = SQLDriverConnect((*conn)->hdbc, NULL, lpszConnStr, SQL_NTS, lpszConnStr, CONNSTRSIZE, &cbszConnStr, SQL_DRIVER_NOPROMPT); conn 2468 ext/odbc/php_odbc.c rc = SQLDriverConnect((*conn)->hdbc, NULL, db, SQL_NTS, dsnbuf, sizeof(dsnbuf) - 1, &dsnbuflen, SQL_DRIVER_NOPROMPT); conn 2472 ext/odbc/php_odbc.c rc = SQLSetConnectOption((*conn)->hdbc, SQL_ODBC_CURSORS, cur_opt); conn 2474 ext/odbc/php_odbc.c odbc_sql_error(*conn, SQL_NULL_HSTMT, "SQLSetConnectOption"); conn 2475 ext/odbc/php_odbc.c SQLFreeConnect((*conn)->hdbc); conn 2476 ext/odbc/php_odbc.c pefree(*conn, persistent); conn 2504 ext/odbc/php_odbc.c rc = SQLDriverConnect((*conn)->hdbc, NULL, ldb, strlen(ldb), dsnbuf, sizeof(dsnbuf) - 1, &dsnbuflen, SQL_DRIVER_NOPROMPT); conn 2506 ext/odbc/php_odbc.c rc = SQLConnect((*conn)->hdbc, db, SQL_NTS, uid, SQL_NTS, pwd, SQL_NTS); conn 2514 ext/odbc/php_odbc.c rc = SQLConnect((*conn)->hdbc, db, SQL_NTS, uid, SQL_NTS, pwd, SQL_NTS); conn 2519 ext/odbc/php_odbc.c odbc_sql_error(*conn, SQL_NULL_HSTMT, "SQLConnect"); conn 2520 ext/odbc/php_odbc.c SQLFreeConnect((*conn)->hdbc); conn 2521 ext/odbc/php_odbc.c pefree((*conn), persistent); conn 2711 ext/odbc/php_odbc.c odbc_connection *conn; conn 2723 ext/odbc/php_odbc.c conn = (odbc_connection *) zend_fetch_resource(&pv_conn TSRMLS_CC, -1, "ODBC-Link", &found_resource_type, 2, le_conn, le_pconn); conn 2734 ext/odbc/php_odbc.c if(res->conn_ptr == conn){ conn 2954 ext/odbc/php_odbc.c odbc_connection *conn; conn 2963 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 2966 ext/odbc/php_odbc.c rc = SQLSetConnectOption(conn->hdbc, SQL_AUTOCOMMIT, (pv_onoff) ? SQL_AUTOCOMMIT_ON : SQL_AUTOCOMMIT_OFF); conn 2968 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "Set autocommit"); conn 2975 ext/odbc/php_odbc.c rc = SQLGetConnectOption(conn->hdbc, SQL_AUTOCOMMIT, (PTR)&status); conn 2977 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "Get commit status"); conn 3004 ext/odbc/php_odbc.c odbc_connection *conn; conn 3020 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_handle, -1, "ODBC-Link", le_conn, le_pconn); conn 3023 ext/odbc/php_odbc.c strlcpy(ptr, conn->laststate, len+1); conn 3025 ext/odbc/php_odbc.c strlcpy(ptr, conn->lasterrormsg, len+1); conn 3065 ext/odbc/php_odbc.c odbc_connection *conn; conn 3077 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_handle, -1, "ODBC-Link", le_conn, le_pconn); conn 3079 ext/odbc/php_odbc.c if (conn->persistent) { conn 3083 ext/odbc/php_odbc.c rc = SQLSetConnectOption(conn->hdbc, (unsigned short) pv_opt, pv_val); conn 3085 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SetConnectOption"); conn 3119 ext/odbc/php_odbc.c odbc_connection *conn; conn 3129 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3133 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3141 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3158 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLTables"); conn 3174 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3186 ext/odbc/php_odbc.c odbc_connection *conn; conn 3196 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3200 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3208 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3227 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLColumns"); conn 3243 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3256 ext/odbc/php_odbc.c odbc_connection *conn; conn 3266 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3270 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3278 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3290 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLColumnPrivileges"); conn 3306 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3320 ext/odbc/php_odbc.c odbc_connection *conn; conn 3342 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3346 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3354 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3368 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLForeignKeys"); conn 3384 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3398 ext/odbc/php_odbc.c odbc_connection *conn; conn 3408 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3412 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3420 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3428 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLGetTypeInfo"); conn 3444 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3456 ext/odbc/php_odbc.c odbc_connection *conn; conn 3465 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3469 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3477 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3488 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLPrimaryKeys"); conn 3504 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3517 ext/odbc/php_odbc.c odbc_connection *conn; conn 3531 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3535 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3543 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3555 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLProcedureColumns"); conn 3571 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3585 ext/odbc/php_odbc.c odbc_connection *conn; conn 3598 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3602 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3610 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3621 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLProcedures"); conn 3637 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3651 ext/odbc/php_odbc.c odbc_connection *conn; conn 3666 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3670 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3678 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3692 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLSpecialColumns"); conn 3708 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3721 ext/odbc/php_odbc.c odbc_connection *conn; conn 3735 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "ODBC-Link", le_conn, le_pconn); conn 3739 ext/odbc/php_odbc.c rc = PHP_ODBC_SQLALLOCSTMT(conn->hdbc, &(result->stmt)); conn 3747 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLAllocStmt"); conn 3760 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLStatistics"); conn 3776 ext/odbc/php_odbc.c result->conn_ptr = conn; conn 3789 ext/odbc/php_odbc.c odbc_connection *conn; conn 3798 ext/odbc/php_odbc.c ZEND_FETCH_RESOURCE2(conn, odbc_connection *, &pv_conn, -1, "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 3821 ext/odbc/php_odbc.c odbc_sql_error(conn, SQL_NULL_HSTMT, "SQLTablePrivileges"); conn 3837 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 155 ext/pdo_pgsql/pgsql_driver.c lo_close(self->conn, self->lfd); conn 171 ext/pdo_pgsql/pgsql_driver.c int pos = lo_lseek(self->conn, self->lfd, offset, whence); conn 197 ext/pdo_pgsql/pgsql_driver.c self->conn = H->server; conn 99 ext/pdo_pgsql/php_pdo_pgsql_int.h PGconn *conn; conn 786 ext/pgsql/pgsql.c #define PQescapeStringConn(conn, to, from, len, error) PQescapeString(to, from, len) conn 790 ext/pgsql/pgsql.c #define PGSQLescapeLiteral(conn, str, len) PQescapeLiteral(conn, str, len) conn 791 ext/pgsql/pgsql.c #define PGSQLescapeIdentifier(conn, str, len) PQescapeIdentifier(conn, str, len) conn 794 ext/pgsql/pgsql.c #define PGSQLescapeLiteral(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 1, 0) conn 795 ext/pgsql/pgsql.c #define PGSQLescapeLiteral2(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 1, 1) conn 796 ext/pgsql/pgsql.c #define PGSQLescapeIdentifier(conn, str, len) php_pgsql_PQescapeInternal(conn, str, len, 0, 0) conn 800 ext/pgsql/pgsql.c static char* php_pgsql_PQescapeInternal(PGconn *conn, const char *str, size_t len, int escape_literal, int safe) { conn 804 ext/pgsql/pgsql.c if (!conn) { conn 819 ext/pgsql/pgsql.c new_len = PQescapeStringConn(conn, tmp, str, len, NULL); conn 828 ext/pgsql/pgsql.c encoding = (char *) pg_encoding_to_char(PQclientEncoding(conn)); conn 1887 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 2027 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 2110 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 2234 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 2459 ext/pgsql/pgsql.c if ((tmp_res = PQexec(pg_result->conn, querystr.c)) == NULL || PQresultStatus(tmp_res) != PGRES_TUPLES_OK) { conn 2529 ext/pgsql/pgsql.c Z_STRVAL_P(return_value) = get_field_name(pg_result->conn, PQftype(pgsql_result, field), &EG(regular_list) TSRMLS_CC); conn 3419 ext/pgsql/pgsql.c pgsql_lofp->conn = pgsql; conn 3431 ext/pgsql/pgsql.c pgsql_lofp->conn = pgsql; conn 3451 ext/pgsql/pgsql.c if (lo_close((PGconn *)pgsql->conn, pgsql->lofd) < 0) { conn 3486 ext/pgsql/pgsql.c if ((nbytes = lo_read((PGconn *)pgsql->conn, pgsql->lofd, buf, buf_len))<0) { conn 3529 ext/pgsql/pgsql.c if ((nbytes = lo_write((PGconn *)pgsql->conn, pgsql->lofd, str, len)) == -1) { conn 3554 ext/pgsql/pgsql.c while ((nbytes = lo_read((PGconn *)pgsql->conn, pgsql->lofd, buf, PGSQL_LO_READ_BUF_SIZE))>0) { conn 3761 ext/pgsql/pgsql.c if (PQserverVersion((PGconn *)pgsql->conn) >= 90300) { conn 3762 ext/pgsql/pgsql.c result = lo_lseek64((PGconn *)pgsql->conn, pgsql->lofd, offset, whence); conn 3764 ext/pgsql/pgsql.c result = lo_lseek((PGconn *)pgsql->conn, pgsql->lofd, offset, whence); conn 3767 ext/pgsql/pgsql.c result = lo_lseek((PGconn *)pgsql->conn, pgsql->lofd, offset, whence); conn 3793 ext/pgsql/pgsql.c if (PQserverVersion((PGconn *)pgsql->conn) >= 90300) { conn 3794 ext/pgsql/pgsql.c offset = lo_tell64((PGconn *)pgsql->conn, pgsql->lofd); conn 3796 ext/pgsql/pgsql.c offset = lo_tell((PGconn *)pgsql->conn, pgsql->lofd); conn 3799 ext/pgsql/pgsql.c offset = lo_tell((PGconn *)pgsql->conn, pgsql->lofd); conn 3823 ext/pgsql/pgsql.c if (PQserverVersion((PGconn *)pgsql->conn) >= 90300) { conn 3824 ext/pgsql/pgsql.c result = lo_truncate64((PGconn *)pgsql->conn, pgsql->lofd, size); conn 3826 ext/pgsql/pgsql.c result = lo_truncate((PGconn *)pgsql->conn, pgsql->lofd, size); conn 3829 ext/pgsql/pgsql.c result = lo_truncate((PGconn *)pgsql->conn, pgsql->lofd, size); conn 5209 ext/pgsql/pgsql.c pg_result->conn = pgsql; conn 6726 ext/pgsql/pgsql.c pgsql_handle->conn = pg_link; conn 284 ext/pgsql/php_pgsql.h PGconn *conn; conn 289 ext/pgsql/php_pgsql.h PGconn *conn; conn 44 netware/start.c int (*readRoutineP)( int conn, void *fileHandle, size_t offset, conn 70 sapi/aolserver/aolserver.c Ns_Conn *conn; conn 95 sapi/aolserver/aolserver.c n = Ns_ConnWrite(NSG(conn), (void *) str, str_length); conn 129 sapi/aolserver/aolserver.c Ns_ConnSetTypeHeader(NSG(conn), header_content); conn 131 sapi/aolserver/aolserver.c Ns_ConnSetHeaders(NSG(conn), header_name, header_content); conn 151 sapi/aolserver/aolserver.c Ns_ConnSetRequiredHeaders(NSG(conn), "text/html", 0); conn 154 sapi/aolserver/aolserver.c Ns_ConnFlushHeaders(NSG(conn), SG(sapi_headers).http_response_code); conn 172 sapi/aolserver/aolserver.c total_read = Ns_ConnRead(NSG(conn), buf, max_read); conn 193 sapi/aolserver/aolserver.c i = Ns_SetIFind(NSG(conn->headers), "cookie"); conn 195 sapi/aolserver/aolserver.c http_cookie = Ns_SetValue(NSG(conn->headers), i); conn 229 sapi/aolserver/aolserver.c php_info_print_table_row(2, "HTTP Request", NSG(conn)->request->line); conn 230 sapi/aolserver/aolserver.c for (i = 0; i < Ns_SetSize(NSG(conn)->headers); i++) { conn 231 sapi/aolserver/aolserver.c php_info_print_table_row(2, Ns_SetKey(NSG(conn)->headers, i), Ns_SetValue(NSG(conn)->headers, i)); conn 235 sapi/aolserver/aolserver.c for (i = 0; i < Ns_SetSize(NSG(conn)->outputheaders); i++) { conn 236 sapi/aolserver/aolserver.c php_info_print_table_row(2, Ns_SetKey(NSG(conn)->outputheaders, i), Ns_SetValue(NSG(conn)->outputheaders, i)); conn 272 sapi/aolserver/aolserver.c for (i = 0; i < Ns_SetSize(NSG(conn->headers)); i++) { conn 273 sapi/aolserver/aolserver.c char *key = Ns_SetKey(NSG(conn->headers), i); conn 274 sapi/aolserver/aolserver.c char *value = Ns_SetValue(NSG(conn->headers), i); conn 310 sapi/aolserver/aolserver.c for(i = 0; i < Ns_SetSize(NSG(conn->headers)); i++) { conn 311 sapi/aolserver/aolserver.c char *key = Ns_SetKey(NSG(conn->headers), i); conn 312 sapi/aolserver/aolserver.c char *value = Ns_SetValue(NSG(conn->headers), i); conn 331 sapi/aolserver/aolserver.c snprintf(buf, NS_BUF_SIZE, "HTTP/%1.1f", NSG(conn)->request->version); conn 334 sapi/aolserver/aolserver.c ADD_STRINGX("REQUEST_METHOD", NSG(conn)->request->method); conn 336 sapi/aolserver/aolserver.c if(NSG(conn)->request->query) conn 337 sapi/aolserver/aolserver.c ADD_STRINGX("QUERY_STRING", NSG(conn)->request->query); conn 341 sapi/aolserver/aolserver.c ADD_STRINGX("REMOTE_ADDR", Ns_ConnPeer(NSG(conn))); conn 343 sapi/aolserver/aolserver.c snprintf(buf, NS_BUF_SIZE, "%d", Ns_ConnPeerPort(NSG(conn))); conn 346 sapi/aolserver/aolserver.c snprintf(buf, NS_BUF_SIZE, "%d", Ns_ConnPort(NSG(conn))); conn 349 sapi/aolserver/aolserver.c tmp = Ns_ConnHost(NSG(conn)); conn 439 sapi/aolserver/aolserver.c server = Ns_ConnServer(NSG(conn)); conn 442 sapi/aolserver/aolserver.c SG(request_info).query_string = safe_strdup(NSG(conn->request->query)); conn 445 sapi/aolserver/aolserver.c Ns_UrlToFile(&ds, server, NSG(conn->request->url)); conn 452 sapi/aolserver/aolserver.c SG(request_info).request_method = NSG(conn)->request->method; conn 453 sapi/aolserver/aolserver.c if(NSG(conn)->request->version > 1.0) SG(request_info).proto_num = 1001; conn 455 sapi/aolserver/aolserver.c SG(request_info).content_length = Ns_ConnContentLength(NSG(conn)); conn 456 sapi/aolserver/aolserver.c index = Ns_SetIFind(NSG(conn)->headers, "content-type"); conn 458 sapi/aolserver/aolserver.c Ns_SetValue(NSG(conn)->headers, index); conn 461 sapi/aolserver/aolserver.c tmp = Ns_ConnAuthUser(NSG(conn)); conn 466 sapi/aolserver/aolserver.c tmp = Ns_ConnAuthPasswd(NSG(conn)); conn 494 sapi/aolserver/aolserver.c php_ns_request_handler(void *context, Ns_Conn *conn) conn 499 sapi/aolserver/aolserver.c NSG(conn) = conn; conn 203 sapi/phttpd/phttpd.c server = Ns_ConnServer(NSG(conn)); conn 206 sapi/phttpd/phttpd.c Ns_UrlToFile(&ds, server, NSG(conn->request->url)); conn 213 sapi/phttpd/phttpd.c SG(request_info).content_length = Ns_ConnContentLength(NSG(conn)); conn 214 sapi/phttpd/phttpd.c index = Ns_SetIFind(NSG(conn)->headers, "content-type"); conn 216 sapi/phttpd/phttpd.c Ns_SetValue(NSG(conn)->headers, index); conn 218 sapi/phttpd/phttpd.c tmp = Ns_ConnAuthUser(NSG(conn)); conn 224 sapi/phttpd/phttpd.c tmp = Ns_ConnAuthPasswd(NSG(conn)); conn 26 sapi/webjames/php_webjames.h void webjames_php_request(struct connection *conn); conn 33 sapi/webjames/webjames.c struct connection *conn; /*structure holding all the details of the current request*/ conn 49 sapi/webjames/webjames.c bytes = webjames_writebuffer(WG(conn),str,str_length); conn 69 sapi/webjames/webjames.c if (WG(conn)->flags.outputheaders) { conn 72 sapi/webjames/webjames.c bytes = webjames_writebuffer(WG(conn), header, len); conn 83 sapi/webjames/webjames.c webjames_writestring(WG(conn), "\r\n"); conn 90 sapi/webjames/webjames.c if (WG(conn)->body==NULL) return 0; conn 91 sapi/webjames/webjames.c if (count_bytes+WG(bodyread)>WG(conn)->bodysize) count_bytes=WG(conn)->bodysize-WG(bodyread); conn 92 sapi/webjames/webjames.c memcpy(buffer, WG(conn)->body+WG(bodyread), count_bytes); conn 99 sapi/webjames/webjames.c return WG(conn)->cookie; conn 107 sapi/webjames/webjames.c snprintf(buf, BUF_SIZE, "%d", WG(conn)->field);\ conn 112 sapi/webjames/webjames.c if (WG(conn)->field) { \ conn 113 sapi/webjames/webjames.c php_register_variable(name, WG(conn)->field, track_vars_array TSRMLS_CC); \ conn 130 sapi/webjames/webjames.c docroot = __unixify(WG(conn)->homedir,0,NULL,1024,0); conn 141 sapi/webjames/webjames.c snprintf(buf, BUF_SIZE, "%d.%d.%d.%d", WG(conn)->ipaddr[0], WG(conn)->ipaddr[1], WG(conn)->ipaddr[2], WG(conn)->ipaddr[3]); conn 143 sapi/webjames/webjames.c if (WG(conn)->dnsstatus == DNS_OK) ADD_FIELD("REMOTE_HOST", host); conn 145 sapi/webjames/webjames.c if ((WG(conn)->method == METHOD_POST) || (WG(conn)->method == METHOD_PUT)) { conn 150 sapi/webjames/webjames.c if ((WG(conn)->method == METHOD_PUT) || (WG(conn)->method == METHOD_DELETE)) ADD_FIELD("ENTITY_PATH", requesturi); conn 152 sapi/webjames/webjames.c if (WG(conn)->pwd) { conn 174 sapi/webjames/webjames.c path = __unixify(WG(conn)->filename,0,NULL,1024,0); conn 177 sapi/webjames/webjames.c SG(request_info).query_string = WG(conn)->args; conn 178 sapi/webjames/webjames.c SG(request_info).request_uri = WG(conn)->requesturi; conn 179 sapi/webjames/webjames.c SG(request_info).request_method = WG(conn)->methodstr; conn 180 sapi/webjames/webjames.c if (WG(conn)->method==METHOD_HEAD) { conn 186 sapi/webjames/webjames.c SG(request_info).content_type = WG(conn)->type; conn 187 sapi/webjames/webjames.c SG(request_info).content_length = WG(conn)->bodysize; conn 191 sapi/webjames/webjames.c if (WG(conn)->authorization) { conn 192 sapi/webjames/webjames.c char *colon=strchr(WG(conn)->authorization,':'); conn 194 sapi/webjames/webjames.c SG(request_info).auth_user = emalloc(colon-WG(conn)->authorization+1); conn 196 sapi/webjames/webjames.c memcpy(SG(request_info).auth_user,WG(conn)->authorization,colon-WG(conn)->authorization); conn 197 sapi/webjames/webjames.c SG(request_info).auth_user[colon-WG(conn)->authorization]='\0'; conn 219 sapi/webjames/webjames.c static void webjames_php_close(struct connection *conn, int force) conn 225 sapi/webjames/webjames.c WG(oldclose)(conn,force); conn 228 sapi/webjames/webjames.c void webjames_php_request(struct connection *conn) conn 233 sapi/webjames/webjames.c WG(conn) = conn; conn 235 sapi/webjames/webjames.c WG(oldclose) = conn->close; conn 236 sapi/webjames/webjames.c conn->close=webjames_php_close; conn 240 sapi/webjames/webjames.c WG(oldclose)(WG(conn), 0);