Commit 8206e02a authored by Yoni Fogel's avatar Yoni Fogel

refs #5467 merge onto handlerton (kill putloader)

git-svn-id: file:///svn/mysql/tokudb-engine/tokudb-engine@50180 c7de825b-a66e-492c-adef-691d508d4ae1
parent b6fae997
...@@ -3144,7 +3144,7 @@ void ha_tokudb::start_bulk_insert(ha_rows rows) { ...@@ -3144,7 +3144,7 @@ void ha_tokudb::start_bulk_insert(ha_rows rows) {
mult_put_flags[primary_key] = DB_NOOVERWRITE; mult_put_flags[primary_key] = DB_NOOVERWRITE;
} }
uint32_t loader_flags = (get_load_save_space(thd)) ? uint32_t loader_flags = (get_load_save_space(thd)) ?
LOADER_USE_PUTS : 0; LOADER_COMPRESS_INTERMEDIATES : 0;
int error = db_env->create_loader( int error = db_env->create_loader(
db_env, db_env,
...@@ -7336,9 +7336,9 @@ int ha_tokudb::tokudb_add_index( ...@@ -7336,9 +7336,9 @@ int ha_tokudb::tokudb_add_index(
THD* thd = ha_thd(); THD* thd = ha_thd();
DB_LOADER* loader = NULL; DB_LOADER* loader = NULL;
DB_INDEXER* indexer = NULL; DB_INDEXER* indexer = NULL;
bool loader_use_puts = get_load_save_space(thd); bool loader_save_space = get_load_save_space(thd);
bool use_hot_index = (lock.type == TL_WRITE_ALLOW_WRITE); bool use_hot_index = (lock.type == TL_WRITE_ALLOW_WRITE);
uint32_t loader_flags = loader_use_puts ? LOADER_USE_PUTS : 0; uint32_t loader_flags = loader_save_space ? LOADER_COMPRESS_INTERMEDIATES : 0;
uint32_t indexer_flags = 0; uint32_t indexer_flags = 0;
uint32_t mult_db_flags[MAX_KEY + 1] = {0}; uint32_t mult_db_flags[MAX_KEY + 1] = {0};
uint32_t mult_put_flags[MAX_KEY + 1]; uint32_t mult_put_flags[MAX_KEY + 1];
...@@ -7592,12 +7592,7 @@ int ha_tokudb::tokudb_add_index( ...@@ -7592,12 +7592,7 @@ int ha_tokudb::tokudb_add_index(
num_processed++; num_processed++;
if ((num_processed % 1000) == 0) { if ((num_processed % 1000) == 0) {
if (loader_use_puts) { sprintf(status_msg, "Adding indexes: Fetched %llu of about %llu rows, loading of data still remains.", num_processed, (long long unsigned) share->rows);
sprintf(status_msg, "Adding indexes: Processed %llu of about %llu rows.", num_processed, (long long unsigned) share->rows);
}
else {
sprintf(status_msg, "Adding indexes: Fetched %llu of about %llu rows, loading of data still remains.", num_processed, (long long unsigned) share->rows);
}
thd_proc_info(thd, status_msg); thd_proc_info(thd, status_msg);
#ifdef HA_TOKUDB_HAS_THD_PROGRESS #ifdef HA_TOKUDB_HAS_THD_PROGRESS
......
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