unbuf 33 ext/mysqli/mysqli_mysqlnd.h #define mysqli_result_is_unbuffered(r) ((r)->unbuf) unbuf 34 ext/mysqli/mysqli_mysqlnd.h #define mysqli_result_is_unbuffered_and_not_everything_is_fetched(r) ((r)->unbuf && !(r)->unbuf->eof_reached) unbuf 124 ext/mysqli/mysqli_result_iterator.c if (result->unbuf->eof_reached) { unbuf 1519 ext/mysqlnd/mysqlnd.c result->unbuf = mysqlnd_result_unbuffered_init(result->field_count, FALSE, result->persistent); unbuf 1520 ext/mysqlnd/mysqlnd.c if (!result->unbuf) { unbuf 1527 ext/mysqlnd/mysqlnd.c result->unbuf->eof_reached = TRUE; unbuf 124 ext/mysqlnd/mysqlnd_libmysql_compat.h #define mysql_eof(r) (((r)->unbuf && (r)->unbuf->eof_reached) || (r)->stored_data) unbuf 545 ext/mysqlnd/mysqlnd_ps.c } else if (stmt->result->unbuf) { unbuf 546 ext/mysqlnd/mysqlnd_ps.c stmt->result->unbuf->lengths = NULL; unbuf 864 ext/mysqlnd/mysqlnd_ps.c if (result->unbuf->eof_reached) { unbuf 875 ext/mysqlnd/mysqlnd_ps.c if (!(row_packet = result->unbuf->row_packet)) { unbuf 890 ext/mysqlnd/mysqlnd_ps.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); unbuf 892 ext/mysqlnd/mysqlnd_ps.c result->unbuf->last_row_data = row_packet->fields; unbuf 893 ext/mysqlnd/mysqlnd_ps.c result->unbuf->last_row_buffer = row_packet->row_buffer; unbuf 897 ext/mysqlnd/mysqlnd_ps.c if (PASS != result->unbuf->m.row_decoder(result->unbuf->last_row_buffer, unbuf 898 ext/mysqlnd/mysqlnd_ps.c result->unbuf->last_row_data, unbuf 909 ext/mysqlnd/mysqlnd_ps.c zval *data = &result->unbuf->last_row_data[i]; unbuf 946 ext/mysqlnd/mysqlnd_ps.c result->unbuf->row_count++; unbuf 954 ext/mysqlnd/mysqlnd_ps.c result->unbuf->eof_reached = TRUE; /* so next time we won't get an error */ unbuf 958 ext/mysqlnd/mysqlnd_ps.c result->unbuf->eof_reached = TRUE; unbuf 1012 ext/mysqlnd/mysqlnd_ps.c result->unbuf->m.fetch_row = stmt->cursor_exists? mysqlnd_fetch_stmt_row_cursor: unbuf 1036 ext/mysqlnd/mysqlnd_ps.c if (!stmt || !stmt->conn || !result || !result->conn || !result->unbuf) { unbuf 1050 ext/mysqlnd/mysqlnd_ps.c if (!(row_packet = result->unbuf->row_packet)) { unbuf 1075 ext/mysqlnd/mysqlnd_ps.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); unbuf 1077 ext/mysqlnd/mysqlnd_ps.c result->unbuf->last_row_data = row_packet->fields; unbuf 1078 ext/mysqlnd/mysqlnd_ps.c result->unbuf->last_row_buffer = row_packet->row_buffer; unbuf 1082 ext/mysqlnd/mysqlnd_ps.c if (PASS != result->unbuf->m.row_decoder(result->unbuf->last_row_buffer, unbuf 1083 ext/mysqlnd/mysqlnd_ps.c result->unbuf->last_row_data, unbuf 1095 ext/mysqlnd/mysqlnd_ps.c zval *data = &result->unbuf->last_row_data[i]; unbuf 1142 ext/mysqlnd/mysqlnd_ps.c result->unbuf->row_count++; unbuf 1155 ext/mysqlnd/mysqlnd_ps.c result->unbuf->eof_reached = row_packet->eof; unbuf 1167 ext/mysqlnd/mysqlnd_ps.c result->unbuf->eof_reached); unbuf 1852 ext/mysqlnd/mysqlnd_ps.c result->unbuf = mysqlnd_result_unbuffered_init(stmt->field_count, TRUE, result->persistent); unbuf 1853 ext/mysqlnd/mysqlnd_ps.c if (!result->unbuf) { unbuf 1856 ext/mysqlnd/mysqlnd_ps.c result->unbuf->eof_reached = TRUE; unbuf 146 ext/mysqlnd/mysqlnd_result.c MYSQLND_METHOD(mysqlnd_result_unbuffered, free_last_data)(MYSQLND_RES_UNBUFFERED * unbuf, MYSQLND_STATS * const global_stats) unbuf 150 ext/mysqlnd/mysqlnd_result.c if (!unbuf) { unbuf 154 ext/mysqlnd/mysqlnd_result.c DBG_INF_FMT("field_count=%u", unbuf->field_count); unbuf 155 ext/mysqlnd/mysqlnd_result.c if (unbuf->last_row_data) { unbuf 157 ext/mysqlnd/mysqlnd_result.c for (i = 0; i < unbuf->field_count; i++) { unbuf 158 ext/mysqlnd/mysqlnd_result.c zval_ptr_dtor(&(unbuf->last_row_data[i])); unbuf 162 ext/mysqlnd/mysqlnd_result.c mnd_efree(unbuf->last_row_data); unbuf 163 ext/mysqlnd/mysqlnd_result.c unbuf->last_row_data = NULL; unbuf 165 ext/mysqlnd/mysqlnd_result.c if (unbuf->last_row_buffer) { unbuf 168 ext/mysqlnd/mysqlnd_result.c unbuf->last_row_buffer->free_chunk(unbuf->last_row_buffer); unbuf 169 ext/mysqlnd/mysqlnd_result.c unbuf->last_row_buffer = NULL; unbuf 300 ext/mysqlnd/mysqlnd_result.c DBG_INF_FMT("%s", result->unbuf? "unbuffered":(result->stored_data? "buffered":"unknown")); unbuf 302 ext/mysqlnd/mysqlnd_result.c if (result->unbuf) { unbuf 303 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_result(result->unbuf, result->conn? result->conn->stats : NULL); unbuf 304 ext/mysqlnd/mysqlnd_result.c result->unbuf = NULL; unbuf 668 ext/mysqlnd/mysqlnd_result.c (result->unbuf && result->unbuf->m.fetch_lengths ? unbuf 669 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.fetch_lengths(result->unbuf) : unbuf 683 ext/mysqlnd/mysqlnd_result.c MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; unbuf 689 ext/mysqlnd/mysqlnd_result.c if (result->unbuf->eof_reached) { unbuf 709 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); unbuf 711 ext/mysqlnd/mysqlnd_result.c result->unbuf->last_row_data = row_packet->fields; unbuf 712 ext/mysqlnd/mysqlnd_result.c result->unbuf->last_row_buffer = row_packet->row_buffer; unbuf 721 ext/mysqlnd/mysqlnd_result.c enum_func_status rc = result->unbuf->m.row_decoder(result->unbuf->last_row_buffer, unbuf 722 ext/mysqlnd/mysqlnd_result.c result->unbuf->last_row_data, unbuf 734 ext/mysqlnd/mysqlnd_result.c zend_ulong * lengths = result->unbuf->lengths; unbuf 737 ext/mysqlnd/mysqlnd_result.c zval * data = &result->unbuf->last_row_data[i]; unbuf 762 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_count++; unbuf 770 ext/mysqlnd/mysqlnd_result.c result->unbuf->eof_reached = TRUE; /* so next time we won't get an error */ unbuf 774 ext/mysqlnd/mysqlnd_result.c result->unbuf->eof_reached = TRUE; unbuf 787 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); unbuf 802 ext/mysqlnd/mysqlnd_result.c MYSQLND_PACKET_ROW *row_packet = result->unbuf->row_packet; unbuf 808 ext/mysqlnd/mysqlnd_result.c if (result->unbuf->eof_reached) { unbuf 828 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); unbuf 830 ext/mysqlnd/mysqlnd_result.c result->unbuf->last_row_data = row_packet->fields; unbuf 831 ext/mysqlnd/mysqlnd_result.c result->unbuf->last_row_buffer = row_packet->row_buffer; unbuf 840 ext/mysqlnd/mysqlnd_result.c enum_func_status rc = result->unbuf->m.row_decoder(result->unbuf->last_row_buffer, unbuf 841 ext/mysqlnd/mysqlnd_result.c result->unbuf->last_row_data, unbuf 852 ext/mysqlnd/mysqlnd_result.c zend_ulong * lengths = result->unbuf->lengths; unbuf 855 ext/mysqlnd/mysqlnd_result.c zval * data = &result->unbuf->last_row_data[i]; unbuf 888 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_count++; unbuf 896 ext/mysqlnd/mysqlnd_result.c result->unbuf->eof_reached = TRUE; /* so next time we won't get an error */ unbuf 900 ext/mysqlnd/mysqlnd_result.c result->unbuf->eof_reached = TRUE; unbuf 913 ext/mysqlnd/mysqlnd_result.c result->unbuf->m.free_last_data(result->unbuf, result->conn? result->conn->stats : NULL); unbuf 936 ext/mysqlnd/mysqlnd_result.c result->unbuf = mysqlnd_result_unbuffered_init(result->field_count, ps, result->persistent); unbuf 937 ext/mysqlnd/mysqlnd_result.c if (!result->unbuf) { unbuf 947 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet = result->conn->protocol->m.get_row_packet(result->conn->protocol, FALSE); unbuf 948 ext/mysqlnd/mysqlnd_result.c if (!result->unbuf->row_packet) { unbuf 951 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet->result_set_memory_pool = result->unbuf->result_set_memory_pool; unbuf 952 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet->field_count = result->field_count; unbuf 953 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet->binary_protocol = ps; unbuf 954 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet->fields_metadata = result->meta->fields; unbuf 955 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet->bit_fields_count = result->meta->bit_fields_count; unbuf 956 ext/mysqlnd/mysqlnd_result.c result->unbuf->row_packet->bit_fields_total_len = result->meta->bit_fields_total_len; unbuf 1255 ext/mysqlnd/mysqlnd_result.c const mysqlnd_fetch_row_func f = result->stored_data? result->stored_data->m.fetch_row:(result->unbuf? result->unbuf->m.fetch_row:NULL); unbuf 1484 ext/mysqlnd/mysqlnd_result.c if (result->unbuf && !result->unbuf->eof_reached) { unbuf 1589 ext/mysqlnd/mysqlnd_result.c (result->unbuf? result->unbuf->m.num_rows(result->unbuf) : 0); unbuf 1763 ext/mysqlnd/mysqlnd_result.c } else if (result->unbuf && result->unbuf->m.fetch_row == MYSQLND_METHOD(mysqlnd_result_unbuffered, fetch_row)) { unbuf 1784 ext/mysqlnd/mysqlnd_result.c if ((!result->unbuf && !set)) { unbuf 663 ext/pdo_mysql/mysql_statement.c if (S->result->unbuf && !S->result->unbuf->eof_reached && mysql_errno(S->H->server)) {