Commit 5392e6c5 authored by Zardosht Kasheff's avatar Zardosht Kasheff Committed by Yoni Fogel

[t:2651], fix test_row_packing so that incorrect results are not given

git-svn-id: file:///svn/mysql/tokudb-engine/tokudb-engine@20561 c7de825b-a66e-492c-adef-691d508d4ae1
parent ed5b5cdd
......@@ -1480,6 +1480,7 @@ bool ha_tokudb::can_replace_into_be_fast(TABLE_SHARE* table_share, KEY_AND_COL_I
}
}
exit:
printf("replace can be fast: %d\n", ret_val);
return ret_val;
}
......@@ -3200,7 +3201,7 @@ cleanup:
return error;
}
int ha_tokudb::test_row_packing(uchar* record, DBT* pk_key, DBT* pk_val) {
void ha_tokudb::test_row_packing(uchar* record, DBT* pk_key, DBT* pk_val) {
int error;
DBT row, key;
//
......@@ -3264,7 +3265,7 @@ int ha_tokudb::test_row_packing(uchar* record, DBT* pk_key, DBT* pk_val) {
//
if (table->key_info[keynr].flags & HA_CLUSTERING) {
error = pack_row(&row, (const uchar *) record, keynr);
if (error) { goto cleanup; }
assert(error == 0);
uchar* tmp_buff = NULL;
tmp_buff = (uchar *)my_malloc(alloced_rec_buff_length,MYF(MY_WME));
assert(tmp_buff);
......@@ -3286,11 +3287,13 @@ int ha_tokudb::test_row_packing(uchar* record, DBT* pk_key, DBT* pk_val) {
}
}
error = 0;
cleanup:
//
// copy stuff back out
//
error = pack_row(pk_val, (const uchar *) record, primary_key);
my_free(tmp_pk_key_data,MYF(MY_ALLOW_ZERO_PTR));
my_free(tmp_pk_val_data,MYF(MY_ALLOW_ZERO_PTR));
return error;
}
//
......@@ -3499,8 +3502,7 @@ int ha_tokudb::write_row(uchar * record) {
fix_mult_rec_buff();
if (tokudb_debug & TOKUDB_DEBUG_CHECK_KEY) {
error = test_row_packing(record,&prim_key,&row);
if (error) { goto cleanup; }
test_row_packing(record,&prim_key,&row);
}
if (loader) {
......
......@@ -316,7 +316,7 @@ private:
void set_main_dict_put_flags(THD* thd, u_int32_t* put_flags);
int insert_row_to_main_dictionary(uchar* record, DBT* pk_key, DBT* pk_val, DB_TXN* txn);
int insert_rows_to_dictionaries_mult(DBT* pk_key, DBT* pk_val, DB_TXN* txn, THD* thd);
int test_row_packing(uchar* record, DBT* pk_key, DBT* pk_val);
void test_row_packing(uchar* record, DBT* pk_key, DBT* pk_val);
public:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment