Lines Matching refs:row_packet

851 	MYSQLND_PACKET_ROW * row_packet;  in mysqlnd_stmt_fetch_row_unbuffered()  local
870 if (!(row_packet = result->unbuf->row_packet)) { in mysqlnd_stmt_fetch_row_unbuffered()
875 row_packet->skip_extraction = stmt && stmt->result_bind? FALSE:TRUE; in mysqlnd_stmt_fetch_row_unbuffered()
884 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in mysqlnd_stmt_fetch_row_unbuffered()
887 if (!row_packet->skip_extraction) { in mysqlnd_stmt_fetch_row_unbuffered()
890 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_stmt_fetch_row_unbuffered()
891 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_stmt_fetch_row_unbuffered()
892 row_packet->fields = NULL; in mysqlnd_stmt_fetch_row_unbuffered()
893 row_packet->row_buffer.ptr = NULL; in mysqlnd_stmt_fetch_row_unbuffered()
897 row_packet->field_count, in mysqlnd_stmt_fetch_row_unbuffered()
898 row_packet->fields_metadata, in mysqlnd_stmt_fetch_row_unbuffered()
941 row_packet->result_set_memory_pool->free_chunk( in mysqlnd_stmt_fetch_row_unbuffered()
942 row_packet->result_set_memory_pool, row_packet->row_buffer.ptr); in mysqlnd_stmt_fetch_row_unbuffered()
943 row_packet->row_buffer.ptr = NULL; in mysqlnd_stmt_fetch_row_unbuffered()
949 if (row_packet->error_info.error_no) { in mysqlnd_stmt_fetch_row_unbuffered()
950 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in mysqlnd_stmt_fetch_row_unbuffered()
951 COPY_CLIENT_ERROR(stmt->error_info, row_packet->error_info); in mysqlnd_stmt_fetch_row_unbuffered()
955 } else if (row_packet->eof) { in mysqlnd_stmt_fetch_row_unbuffered()
960 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in mysqlnd_stmt_fetch_row_unbuffered()
961 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in mysqlnd_stmt_fetch_row_unbuffered()
1032 MYSQLND_PACKET_ROW * row_packet; in mysqlnd_fetch_stmt_row_cursor() local
1048 if (!(row_packet = result->unbuf->row_packet)) { in mysqlnd_fetch_stmt_row_cursor()
1069 row_packet->skip_extraction = stmt->result_bind? FALSE:TRUE; in mysqlnd_fetch_stmt_row_cursor()
1072 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in mysqlnd_fetch_stmt_row_cursor()
1076 if (!row_packet->skip_extraction) { in mysqlnd_fetch_stmt_row_cursor()
1079 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_fetch_stmt_row_cursor()
1080 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_fetch_stmt_row_cursor()
1081 row_packet->fields = NULL; in mysqlnd_fetch_stmt_row_cursor()
1082 row_packet->row_buffer.ptr = NULL; in mysqlnd_fetch_stmt_row_cursor()
1086 row_packet->field_count, in mysqlnd_fetch_stmt_row_cursor()
1087 row_packet->fields_metadata, in mysqlnd_fetch_stmt_row_cursor()
1133 row_packet->result_set_memory_pool->free_chunk( in mysqlnd_fetch_stmt_row_cursor()
1134 row_packet->result_set_memory_pool, row_packet->row_buffer.ptr); in mysqlnd_fetch_stmt_row_cursor()
1135 row_packet->row_buffer.ptr = NULL; in mysqlnd_fetch_stmt_row_cursor()
1138 ret = PACKET_READ(conn, row_packet); in mysqlnd_fetch_stmt_row_cursor()
1139 if (row_packet->row_buffer.ptr) { in mysqlnd_fetch_stmt_row_cursor()
1140 row_packet->result_set_memory_pool->free_chunk( in mysqlnd_fetch_stmt_row_cursor()
1141 row_packet->result_set_memory_pool, row_packet->row_buffer.ptr); in mysqlnd_fetch_stmt_row_cursor()
1142 row_packet->row_buffer.ptr = NULL; in mysqlnd_fetch_stmt_row_cursor()
1150 UPSERT_STATUS_SET_WARNINGS(stmt->upsert_status, row_packet->warning_count); in mysqlnd_fetch_stmt_row_cursor()
1151 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in mysqlnd_fetch_stmt_row_cursor()
1153 UPSERT_STATUS_SET_SERVER_STATUS(stmt->upsert_status, row_packet->server_status); in mysqlnd_fetch_stmt_row_cursor()
1154 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in mysqlnd_fetch_stmt_row_cursor()
1156 result->unbuf->eof_reached = row_packet->eof; in mysqlnd_fetch_stmt_row_cursor()
1158 UPSERT_STATUS_SET_WARNINGS(stmt->upsert_status, row_packet->warning_count); in mysqlnd_fetch_stmt_row_cursor()
1159 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in mysqlnd_fetch_stmt_row_cursor()
1161 UPSERT_STATUS_SET_SERVER_STATUS(stmt->upsert_status, row_packet->server_status); in mysqlnd_fetch_stmt_row_cursor()
1162 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in mysqlnd_fetch_stmt_row_cursor()
1166 row_packet->server_status, row_packet->warning_count, in mysqlnd_fetch_stmt_row_cursor()