Commit e41daf16 authored by Zardosht Kasheff's avatar Zardosht Kasheff Committed by Yoni Fogel

[t:2983], add some status messages

git-svn-id: file:///svn/mysql/tokudb-engine/tokudb-engine@24825 c7de825b-a66e-492c-adef-691d508d4ae1
parent f140ba9f
...@@ -1153,6 +1153,7 @@ static bool tokudb_show_engine_status(THD * thd, stat_print_fn * stat_print) { ...@@ -1153,6 +1153,7 @@ static bool tokudb_show_engine_status(THD * thd, stat_print_fn * stat_print) {
void tokudb_checkpoint_lock(THD * thd) { void tokudb_checkpoint_lock(THD * thd) {
int error; int error;
tokudb_trx_data* trx = NULL; tokudb_trx_data* trx = NULL;
char status_msg[200]; //buffer of 200 should be a good upper bound.
trx = (tokudb_trx_data *) thd_data_get(thd, tokudb_hton->slot); trx = (tokudb_trx_data *) thd_data_get(thd, tokudb_hton->slot);
if (!trx) { if (!trx) {
error = create_tokudb_trx_data_instance(&trx); error = create_tokudb_trx_data_instance(&trx);
...@@ -1170,6 +1171,8 @@ void tokudb_checkpoint_lock(THD * thd) { ...@@ -1170,6 +1171,8 @@ void tokudb_checkpoint_lock(THD * thd) {
// This can only fail if environment is not created, which is not possible // This can only fail if environment is not created, which is not possible
// in handlerton // in handlerton
// //
sprintf(status_msg, "Trying to grab checkpointing lock.");
thd_proc_info(thd, status_msg);
error = db_env->checkpointing_postpone(db_env); error = db_env->checkpointing_postpone(db_env);
assert(!error); assert(!error);
...@@ -1180,6 +1183,7 @@ void tokudb_checkpoint_lock(THD * thd) { ...@@ -1180,6 +1183,7 @@ void tokudb_checkpoint_lock(THD * thd) {
void tokudb_checkpoint_unlock(THD * thd) { void tokudb_checkpoint_unlock(THD * thd) {
int error; int error;
char status_msg[200]; //buffer of 200 should be a good upper bound.
tokudb_trx_data* trx = NULL; tokudb_trx_data* trx = NULL;
trx = (tokudb_trx_data *) thd_data_get(thd, tokudb_hton->slot); trx = (tokudb_trx_data *) thd_data_get(thd, tokudb_hton->slot);
if (!trx) { if (!trx) {
...@@ -1193,6 +1197,8 @@ void tokudb_checkpoint_unlock(THD * thd) { ...@@ -1193,6 +1197,8 @@ void tokudb_checkpoint_unlock(THD * thd) {
// //
// at this point, we know the checkpoint lock has been taken // at this point, we know the checkpoint lock has been taken
// //
sprintf(status_msg, "Trying to release checkpointing lock.");
thd_proc_info(thd, status_msg);
error = db_env->checkpointing_resume(db_env); error = db_env->checkpointing_resume(db_env);
assert(!error); assert(!error);
......
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