mirror/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-01-19 13:32:33 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

addresses #893

Browse source 
add instances of read_range_first and read_range_next in ha_tokudb
currently just call parent class version

git-svn-id: file:///svn/mysql/tokudb-engine/src@4385 c7de825b-a66e-492c-adef-691d508d4ae1
This commit is contained in:
Zardosht Kasheff 2013-04-17 00:01:42 -04:00 committed by Yoni Fogel
parent 5ff958a2c6
commit f6228085b6
2 changed files with 23 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
storage/tokudb/ha_tokudb.cc
View file

@ -2737,6 +2737,22 @@ int ha_tokudb::rnd_pos(uchar * buf, uchar * pos) {
TOKUDB_DBUG_RETURN(read_row(share->file->get(share->file, transaction, key, &current_row, 0), buf, primary_key, &current_row, key, 0));
}
int ha_tokudb::read_range_first(
const key_range *start_key,
const key_range *end_key,
bool eq_range,
bool sorted)
{
return handler::read_range_first(start_key, end_key, eq_range, sorted);
}
int ha_tokudb::read_range_next()
{
return handler::read_range_next();
}
/*
Set a reference to the current record in (ref,ref_length).
@ -2982,7 +2998,7 @@ int ha_tokudb::start_stmt(THD * thd, thr_lock_type lock_type) {
*/
THR_LOCK_DATA **ha_tokudb::store_lock(THD * thd, THR_LOCK_DATA ** to, enum thr_lock_type lock_type) {
TOKUDB_DBUG_ENTER("ha_tokudb::store_lock");
TOKUDB_DBUG_ENTER("ha_tokudb::store_lock, lock_type=%d", lock_type);
if (lock_type != TL_IGNORE && lock.type == TL_UNLOCK) {
/* If we are not doing a LOCK TABLE, then allow multiple writers */
if ((lock_type >= TL_WRITE_CONCURRENT_INSERT && lock_type <= TL_WRITE) && !thd->in_lock_tables)

6
storage/tokudb/ha_tokudb.h
View file

@ -222,6 +222,12 @@ public:
int rnd_next(uchar * buf);
int rnd_pos(uchar * buf, uchar * pos);
int read_range_first(const key_range *start_key,
const key_range *end_key,
bool eq_range, bool sorted);
int read_range_next();
void position(const uchar * record);
int info(uint);
int extra(enum ha_extra_function operation);