Skip to content

Commit

Permalink
#261 debug prelocking for index scans
Browse files Browse the repository at this point in the history
  • Loading branch information
prohaska committed Jul 18, 2014
1 parent e543cf1 commit 444af9c
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions storage/tokudb/ha_tokudb.cc
Original file line number Diff line number Diff line change
Expand Up @@ -5628,8 +5628,8 @@ int ha_tokudb::rnd_pos(uchar * buf, uchar * pos) {
TOKUDB_HANDLER_DBUG_RETURN(error);
}

int ha_tokudb::prelock_range( const key_range *start_key, const key_range *end_key) {
TOKUDB_HANDLER_DBUG_ENTER("");
int ha_tokudb::prelock_range(const key_range *start_key, const key_range *end_key) {
TOKUDB_HANDLER_DBUG_ENTER("%p %p", start_key, end_key);
THD* thd = ha_thd();

int error = 0;
Expand Down Expand Up @@ -5710,7 +5710,7 @@ int ha_tokudb::prelock_range( const key_range *start_key, const key_range *end_k
// Forward scans use read_range_first()/read_range_next().
//
int ha_tokudb::prepare_range_scan( const key_range *start_key, const key_range *end_key) {
TOKUDB_HANDLER_DBUG_ENTER("");
TOKUDB_HANDLER_DBUG_ENTER("%p %p", start_key, end_key);
int error = prelock_range(start_key, end_key);
if (!error) {
range_lock_grabbed = true;
Expand All @@ -5724,7 +5724,7 @@ int ha_tokudb::read_range_first(
bool eq_range,
bool sorted)
{
TOKUDB_HANDLER_DBUG_ENTER("");
TOKUDB_HANDLER_DBUG_ENTER("%p %p %u %u", start_key, end_key, eq_range, sorted);
int error = prelock_range(start_key, end_key);
if (error) { goto cleanup; }
range_lock_grabbed = true;
Expand Down

0 comments on commit 444af9c

Please sign in to comment.