summaryrefslogtreecommitdiff
path: root/sql/event_scheduler.cc
diff options
context:
space:
mode:
authorandrey@lmy004. <>2006-05-23 00:19:02 +0200
committerandrey@lmy004. <>2006-05-23 00:19:02 +0200
commitec0e9d5977ad1de68fd9aa9feb877ba63c7dc571 (patch)
tree5bcc3b3f34323bb51275641ae8c2eb18ae62b56f /sql/event_scheduler.cc
parent644049120d6f8240ed38a0d1b1ef978f44ddb7ff (diff)
downloadmariadb-git-ec0e9d5977ad1de68fd9aa9feb877ba63c7dc571.tar.gz
fix win32 build after push for bug#17619
Diffstat (limited to 'sql/event_scheduler.cc')
-rw-r--r--sql/event_scheduler.cc26
1 files changed, 7 insertions, 19 deletions
diff --git a/sql/event_scheduler.cc b/sql/event_scheduler.cc
index a19f14d3726..784c87c0e8e 100644
--- a/sql/event_scheduler.cc
+++ b/sql/event_scheduler.cc
@@ -505,7 +505,6 @@ event_worker_thread(void *arg)
THD *thd; /* needs to be first for thread_stack */
Worker_thread_param *param= (Worker_thread_param *) arg;
Event_timed *event= param->et;
- MEM_ROOT worker_mem_root;
int ret;
bool startup_error= FALSE;
Security_context *save_ctx;
@@ -550,8 +549,6 @@ event_worker_thread(void *arg)
if (!startup_error)
{
- uint flags;
-
thd->init_for_queries();
thd->enable_slow_log= TRUE;
@@ -1272,10 +1269,7 @@ Event_scheduler::run(THD *thd)
abstime.tv_nsec= 0;
while (is_running_or_suspended())
{
- TIME time_now_utc;
Event_timed *et;
- my_bool tmp;
- time_t now_utc;
LOCK_SCHEDULER_DATA();
if (check_n_wait_for_non_empty_queue(thd))
@@ -1356,7 +1350,7 @@ Event_scheduler::run(THD *thd)
break;
}
}
-end_loop:
+
thd->proc_info= (char *)"Cleaning";
LOCK_SCHEDULER_DATA();
@@ -1509,7 +1503,6 @@ Event_scheduler::clean_queue(THD *thd)
{
CHARSET_INFO *scs= system_charset_info;
uint i;
- int ret;
DBUG_ENTER("Event_scheduler::clean_queue");
DBUG_PRINT("enter", ("thd=%p", thd));
@@ -1630,7 +1623,6 @@ Event_scheduler::stop_all_running_events(THD *thd)
enum Event_scheduler::enum_error_code
Event_scheduler::stop()
{
- int ret;
THD *thd= current_thd;
DBUG_ENTER("Event_scheduler::stop");
DBUG_PRINT("enter", ("thd=%p", current_thd));
@@ -1697,7 +1689,6 @@ enum Event_scheduler::enum_error_code
Event_scheduler::suspend_or_resume(
enum Event_scheduler::enum_suspend_or_resume action)
{
- enum enum_error_code ret;
DBUG_ENTER("Event_scheduler::suspend_or_resume");
DBUG_PRINT("enter", ("action=%d", action));
@@ -1887,18 +1878,17 @@ Event_scheduler::check_n_wait_for_non_empty_queue(THD *thd)
Error code of pthread_mutex_lock()
*/
-inline int
+inline void
Event_scheduler::lock_data(const char *func, uint line)
{
- int ret;
DBUG_ENTER("Event_scheduler::lock_mutex");
DBUG_PRINT("enter", ("mutex_lock=%p func=%s line=%u",
&LOCK_scheduler_data, func, line));
- ret= pthread_mutex_lock(&LOCK_scheduler_data);
+ pthread_mutex_lock(&LOCK_scheduler_data);
mutex_last_locked_in_func= func;
mutex_last_locked_at_line= line;
mutex_scheduler_data_locked= TRUE;
- DBUG_RETURN(ret);
+ DBUG_VOID_RETURN;
}
@@ -1909,12 +1899,9 @@ Event_scheduler::lock_data(const char *func, uint line)
Event_scheduler::unlock_data()
mutex Mutex to unlock
line The line number on which the unlock is done
-
- RETURN VALUE
- Error code of pthread_mutex_lock()
*/
-inline int
+inline void
Event_scheduler::unlock_data(const char *func, uint line)
{
DBUG_ENTER("Event_scheduler::UNLOCK_mutex");
@@ -1923,7 +1910,8 @@ Event_scheduler::unlock_data(const char *func, uint line)
mutex_last_unlocked_at_line= line;
mutex_scheduler_data_locked= FALSE;
mutex_last_unlocked_in_func= func;
- DBUG_RETURN(pthread_mutex_unlock(&LOCK_scheduler_data));
+ pthread_mutex_unlock(&LOCK_scheduler_data);
+ DBUG_VOID_RETURN;
}