Commit afae1c78 authored by Yoni Fogel's avatar Yoni Fogel

Merge branch '6712'

parents f8277efc aba70249
...@@ -4504,10 +4504,12 @@ int ha_tokudb::prepare_index_key_scan(const uchar * key, uint key_len) { ...@@ -4504,10 +4504,12 @@ int ha_tokudb::prepare_index_key_scan(const uchar * key, uint key_len) {
pack_key(&end_key, tokudb_active_index, prelocked_right_range, key, key_len, COL_POS_INF); pack_key(&end_key, tokudb_active_index, prelocked_right_range, key, key_len, COL_POS_INF);
prelocked_right_range_size = end_key.size; prelocked_right_range_size = end_key.size;
error = cursor->c_pre_acquire_range_lock( error = cursor->c_set_bounds(
cursor, cursor,
&start_key, &start_key,
&end_key &end_key,
true,
(cursor_flags & DB_SERIALIZABLE) != 0 ? DB_NOTFOUND : 0
); );
if (error){ if (error){
...@@ -5783,10 +5785,12 @@ int ha_tokudb::prelock_range( const key_range *start_key, const key_range *end_k ...@@ -5783,10 +5785,12 @@ int ha_tokudb::prelock_range( const key_range *start_key, const key_range *end_k
prelocked_right_range_size = 0; prelocked_right_range_size = 0;
} }
error = cursor->c_pre_acquire_range_lock( error = cursor->c_set_bounds(
cursor, cursor,
start_key ? &start_dbt_key : share->key_file[tokudb_active_index]->dbt_neg_infty(), start_key ? &start_dbt_key : share->key_file[tokudb_active_index]->dbt_neg_infty(),
end_key ? &end_dbt_key : share->key_file[tokudb_active_index]->dbt_pos_infty() end_key ? &end_dbt_key : share->key_file[tokudb_active_index]->dbt_pos_infty(),
true,
(cursor_flags & DB_SERIALIZABLE) != 0 ? DB_NOTFOUND : 0
); );
if (error){ if (error){
last_cursor_error = error; last_cursor_error = error;
...@@ -7856,10 +7860,12 @@ int ha_tokudb::tokudb_add_index( ...@@ -7856,10 +7860,12 @@ int ha_tokudb::tokudb_add_index(
// first a global read lock on the main DB, because // first a global read lock on the main DB, because
// we intend to scan the entire thing // we intend to scan the entire thing
// //
error = tmp_cursor->c_pre_acquire_range_lock( error = tmp_cursor->c_set_bounds(
tmp_cursor, tmp_cursor,
share->file->dbt_neg_infty(), share->file->dbt_neg_infty(),
share->file->dbt_pos_infty() share->file->dbt_pos_infty(),
true,
0
); );
if (error) { goto cleanup; } if (error) { goto cleanup; }
......
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