Loading server-tools/instance-manager/angel.cc +0 −2 Original line number Diff line number Diff line Loading @@ -349,8 +349,6 @@ static int angel_main_loop() int Angel::main() { int ret_status; log_info("Angel: started."); /* Open log file. */ Loading sql/event_queue.cc +2 −2 Original line number Diff line number Diff line Loading @@ -201,7 +201,7 @@ void Event_queue::create_event(THD *thd, Event_queue_element *new_element) { DBUG_ENTER("Event_queue::create_event"); DBUG_PRINT("enter", ("thd=0x%lx et=%s.%s",thd, DBUG_PRINT("enter", ("thd: 0x%lx et=%s.%s", (long) thd, new_element->dbname.str, new_element->name.str)); if (new_element->status == Event_queue_element::DISABLED) Loading @@ -209,7 +209,7 @@ Event_queue::create_event(THD *thd, Event_queue_element *new_element) else { new_element->compute_next_execution_time(); DBUG_PRINT("info", ("new event in the queue 0x%lx", new_element)); DBUG_PRINT("info", ("new event in the queue: 0x%lx", (long) new_element)); LOCK_QUEUE_DATA(); queue_insert_safe(&queue, (byte *) new_element); Loading sql/event_scheduler.cc +8 −8 Original line number Diff line number Diff line Loading @@ -289,9 +289,8 @@ Event_worker_thread::run(THD *thd, Event_queue_element_for_exec *event) res= post_init_event_thread(thd); DBUG_ENTER("Event_worker_thread::run"); DBUG_PRINT("info", ("Baikonur, time is %d, BURAN reporting and operational." "THD=0x%lx", time(NULL), thd)); DBUG_PRINT("info", ("Time is %ld, THD: 0x%lx", (long) time(NULL), (long) thd)); if (res) goto end; Loading Loading @@ -349,7 +348,7 @@ Event_worker_thread::run(THD *thd, Event_queue_element_for_exec *event) */ events_facade->drop_event(thd, event->dbname, event->name, FALSE); } DBUG_PRINT("info", ("BURAN %s.%s is landing!", event->dbname.str, DBUG_PRINT("info", ("Done with Event %s.%s", event->dbname.str, event->name.str)); delete event; Loading Loading @@ -522,7 +521,8 @@ Event_scheduler::run(THD *thd) break; } DBUG_PRINT("info", ("get_top returned job_data=0x%lx", event_name)); DBUG_PRINT("info", ("get_top_for_execution_if_time returned " "event_name=0x%lx", (long) event_name)); if (event_name) { if ((res= execute_top(thd, event_name))) Loading Loading @@ -571,7 +571,7 @@ Event_scheduler::execute_top(THD *thd, Event_queue_element_for_exec *event_name) pre_init_event_thread(new_thd); new_thd->system_thread= SYSTEM_THREAD_EVENT_WORKER; event_name->thd= new_thd; DBUG_PRINT("info", ("BURAN %s@%s ready for start t-3..2..1..0..ignition", DBUG_PRINT("info", ("Event %s@%s ready for start", event_name->dbname.str, event_name->name.str)); /* Major failure */ Loading @@ -581,11 +581,11 @@ Event_scheduler::execute_top(THD *thd, Event_queue_element_for_exec *event_name) ++started_events; DBUG_PRINT("info", ("Launch succeeded. BURAN is in THD: 0x%lx", (long) new_thd)); DBUG_PRINT("info", ("Event is in THD: 0x%lx", (long) new_thd)); DBUG_RETURN(FALSE); error: DBUG_PRINT("error", ("Baikonur, we have a problem! res: %d", res)); DBUG_PRINT("error", ("Event_scheduler::execute_top() res: %d", res)); if (new_thd) { new_thd->proc_info= "Clearing"; Loading sql/events.cc +1 −1 Original line number Diff line number Diff line Loading @@ -923,7 +923,7 @@ Events::load_events_from_db(THD *thd) bool clean_the_queue= TRUE; DBUG_ENTER("Events::load_events_from_db"); DBUG_PRINT("enter", ("thd=0x%lx", thd)); DBUG_PRINT("enter", ("thd: 0x%lx", (long) thd)); if ((ret= db_repository->open_event_table(thd, TL_READ, &table))) { Loading Loading
server-tools/instance-manager/angel.cc +0 −2 Original line number Diff line number Diff line Loading @@ -349,8 +349,6 @@ static int angel_main_loop() int Angel::main() { int ret_status; log_info("Angel: started."); /* Open log file. */ Loading
sql/event_queue.cc +2 −2 Original line number Diff line number Diff line Loading @@ -201,7 +201,7 @@ void Event_queue::create_event(THD *thd, Event_queue_element *new_element) { DBUG_ENTER("Event_queue::create_event"); DBUG_PRINT("enter", ("thd=0x%lx et=%s.%s",thd, DBUG_PRINT("enter", ("thd: 0x%lx et=%s.%s", (long) thd, new_element->dbname.str, new_element->name.str)); if (new_element->status == Event_queue_element::DISABLED) Loading @@ -209,7 +209,7 @@ Event_queue::create_event(THD *thd, Event_queue_element *new_element) else { new_element->compute_next_execution_time(); DBUG_PRINT("info", ("new event in the queue 0x%lx", new_element)); DBUG_PRINT("info", ("new event in the queue: 0x%lx", (long) new_element)); LOCK_QUEUE_DATA(); queue_insert_safe(&queue, (byte *) new_element); Loading
sql/event_scheduler.cc +8 −8 Original line number Diff line number Diff line Loading @@ -289,9 +289,8 @@ Event_worker_thread::run(THD *thd, Event_queue_element_for_exec *event) res= post_init_event_thread(thd); DBUG_ENTER("Event_worker_thread::run"); DBUG_PRINT("info", ("Baikonur, time is %d, BURAN reporting and operational." "THD=0x%lx", time(NULL), thd)); DBUG_PRINT("info", ("Time is %ld, THD: 0x%lx", (long) time(NULL), (long) thd)); if (res) goto end; Loading Loading @@ -349,7 +348,7 @@ Event_worker_thread::run(THD *thd, Event_queue_element_for_exec *event) */ events_facade->drop_event(thd, event->dbname, event->name, FALSE); } DBUG_PRINT("info", ("BURAN %s.%s is landing!", event->dbname.str, DBUG_PRINT("info", ("Done with Event %s.%s", event->dbname.str, event->name.str)); delete event; Loading Loading @@ -522,7 +521,8 @@ Event_scheduler::run(THD *thd) break; } DBUG_PRINT("info", ("get_top returned job_data=0x%lx", event_name)); DBUG_PRINT("info", ("get_top_for_execution_if_time returned " "event_name=0x%lx", (long) event_name)); if (event_name) { if ((res= execute_top(thd, event_name))) Loading Loading @@ -571,7 +571,7 @@ Event_scheduler::execute_top(THD *thd, Event_queue_element_for_exec *event_name) pre_init_event_thread(new_thd); new_thd->system_thread= SYSTEM_THREAD_EVENT_WORKER; event_name->thd= new_thd; DBUG_PRINT("info", ("BURAN %s@%s ready for start t-3..2..1..0..ignition", DBUG_PRINT("info", ("Event %s@%s ready for start", event_name->dbname.str, event_name->name.str)); /* Major failure */ Loading @@ -581,11 +581,11 @@ Event_scheduler::execute_top(THD *thd, Event_queue_element_for_exec *event_name) ++started_events; DBUG_PRINT("info", ("Launch succeeded. BURAN is in THD: 0x%lx", (long) new_thd)); DBUG_PRINT("info", ("Event is in THD: 0x%lx", (long) new_thd)); DBUG_RETURN(FALSE); error: DBUG_PRINT("error", ("Baikonur, we have a problem! res: %d", res)); DBUG_PRINT("error", ("Event_scheduler::execute_top() res: %d", res)); if (new_thd) { new_thd->proc_info= "Clearing"; Loading
sql/events.cc +1 −1 Original line number Diff line number Diff line Loading @@ -923,7 +923,7 @@ Events::load_events_from_db(THD *thd) bool clean_the_queue= TRUE; DBUG_ENTER("Events::load_events_from_db"); DBUG_PRINT("enter", ("thd=0x%lx", thd)); DBUG_PRINT("enter", ("thd: 0x%lx", (long) thd)); if ((ret= db_repository->open_event_table(thd, TL_READ, &table))) { Loading