summaryrefslogtreecommitdiff
path: root/sql/event.cc
diff options
context:
space:
mode:
authorunknown <andrey@lmy004.>2006-02-28 18:33:38 +0100
committerunknown <andrey@lmy004.>2006-02-28 18:33:38 +0100
commit58a6d96c8ff92b432d685736cd3e01a74bba611f (patch)
treed9e13af16df5bdf88f82141b1eea817c196c726d /sql/event.cc
parent0c4ef91556d781fc68bc82cf25641b502c4c4170 (diff)
downloadmariadb-git-58a6d96c8ff92b432d685736cd3e01a74bba611f.tar.gz
class event_timed -> Event_timed
fix for bug#17793 (Scheduler uses class event_timed should be Event_timed) sql/event.cc: class event_timed -> Event_timed sql/event.h: class event_timed -> Event_timed sql/event_executor.cc: class event_timed -> Event_timed sql/event_priv.h: class event_timed -> Event_timed sql/event_timed.cc: class event_timed -> Event_timed sql/sql_lex.h: class event_timed -> Event_timed sql/sql_show.cc: class event_timed -> Event_timed sql/sql_yacc.yy: class event_timed -> Event_timed
Diffstat (limited to 'sql/event.cc')
-rw-r--r--sql/event.cc64
1 files changed, 32 insertions, 32 deletions
diff --git a/sql/event.cc b/sql/event.cc
index 7ed3ec8f600..aa59f40a3ec 100644
--- a/sql/event.cc
+++ b/sql/event.cc
@@ -49,11 +49,11 @@
- Consider using conditional variable when doing shutdown instead of
waiting till all worker threads end.
- - Make event_timed::get_show_create_event() work
+ - Make Event_timed::get_show_create_event() work
- Add logging to file
- - Move comparison code to class event_timed
+ - Move comparison code to class Event_timed
Warning:
- For now parallel execution is not possible because the same sp_head cannot be
@@ -276,13 +276,13 @@ my_time_compare(TIME *a, TIME *b)
/*
- Compares the execute_at members of 2 event_timed instances
+ Compares the execute_at members of 2 Event_timed instances
Synopsis
event_timed_compare()
- a - first event_timed object
- b - second event_timed object
+ a - first Event_timed object
+ b - second Event_timed object
RETURNS:
-1 - a->execute_at < b->execute_at
@@ -294,14 +294,14 @@ my_time_compare(TIME *a, TIME *b)
*/
int
-event_timed_compare(event_timed *a, event_timed *b)
+event_timed_compare(Event_timed *a, Event_timed *b)
{
return my_time_compare(&a->execute_at, &b->execute_at);
}
/*
- Compares the execute_at members of 2 event_timed instances.
+ Compares the execute_at members of 2 Event_timed instances.
Used as callback for the prioritized queue when shifting
elements inside.
@@ -309,8 +309,8 @@ event_timed_compare(event_timed *a, event_timed *b)
event_timed_compare()
vptr - not used (set it to NULL)
- a - first event_timed object
- b - second event_timed object
+ a - first Event_timed object
+ b - second Event_timed object
RETURNS:
-1 - a->execute_at < b->execute_at
@@ -324,7 +324,7 @@ event_timed_compare(event_timed *a, event_timed *b)
int
event_timed_compare_q(void *vptr, byte* a, byte *b)
{
- return event_timed_compare((event_timed *)a, (event_timed *)b);
+ return event_timed_compare((Event_timed *)a, (Event_timed *)b);
}
@@ -520,7 +520,7 @@ evex_open_event_table(THD *thd, enum thr_lock_type lock_type, TABLE **table)
*/
inline int
-evex_db_find_event_aux(THD *thd, event_timed *et, TABLE *table)
+evex_db_find_event_aux(THD *thd, Event_timed *et, TABLE *table)
{
return evex_db_find_event_by_name(thd, et->dbname, et->name,
et->definer, table);
@@ -600,7 +600,7 @@ evex_db_find_event_by_name(THD *thd, const LEX_STRING dbname,
*/
static int
-evex_fill_row(THD *thd, TABLE *table, event_timed *et, my_bool is_update)
+evex_fill_row(THD *thd, TABLE *table, Event_timed *et, my_bool is_update)
{
enum evex_table_field field_num;
@@ -707,7 +707,7 @@ trunc_err:
SYNOPSIS
db_create_event()
thd THD
- et event_timed object containing information for the event
+ et Event_timed object containing information for the event
create_if_not - if an warning should be generated in case event exists
rows_affected - how many rows were affected
@@ -720,7 +720,7 @@ trunc_err:
*/
static int
-db_create_event(THD *thd, event_timed *et, my_bool create_if_not,
+db_create_event(THD *thd, Event_timed *et, my_bool create_if_not,
uint *rows_affected)
{
int ret= 0;
@@ -855,7 +855,7 @@ err:
*/
static int
-db_update_event(THD *thd, event_timed *et, sp_name *new_name)
+db_update_event(THD *thd, Event_timed *et, sp_name *new_name)
{
TABLE *table;
int ret= EVEX_OPEN_TABLE_FAILED;
@@ -954,13 +954,13 @@ err:
*/
static int
-db_find_event(THD *thd, sp_name *name, LEX_STRING *definer, event_timed **ett,
+db_find_event(THD *thd, sp_name *name, LEX_STRING *definer, Event_timed **ett,
TABLE *tbl, MEM_ROOT *root)
{
TABLE *table;
int ret;
char *ptr;
- event_timed *et=NULL;
+ Event_timed *et=NULL;
DBUG_ENTER("db_find_event");
DBUG_PRINT("enter", ("name: %*s", name->m_name.length, name->m_name.str));
@@ -982,7 +982,7 @@ db_find_event(THD *thd, sp_name *name, LEX_STRING *definer, event_timed **ett,
my_error(ER_EVENT_DOES_NOT_EXIST, MYF(0), name->m_name.str);
goto done;
}
- et= new event_timed;
+ et= new Event_timed;
/*
1)The table should not be closed beforehand. ::load_from_row() only loads
@@ -1032,7 +1032,7 @@ evex_load_and_compile_event(THD * thd, sp_name *spn, LEX_STRING definer,
{
int ret= 0;
MEM_ROOT *tmp_mem_root;
- event_timed *ett;
+ Event_timed *ett;
Open_tables_state backup;
DBUG_ENTER("db_load_and_compile_event");
@@ -1089,7 +1089,7 @@ done:
use_lock - whether to lock the mutex LOCK_event_arrays or not in case it
has been already locked outside
is_drop - if an event is currently being executed then we can also delete
- the event_timed instance, so we alarm the event that it should
+ the Event_timed instance, so we alarm the event that it should
drop itself if this parameter is set to TRUE. It's false on
ALTER EVENT.
@@ -1116,7 +1116,7 @@ evex_remove_from_cache(LEX_STRING *db, LEX_STRING *name, bool use_lock,
for (i= 0; i < evex_queue_num_elements(EVEX_EQ_NAME); ++i)
{
- event_timed *et= evex_queue_element(&EVEX_EQ_NAME, i, event_timed*);
+ Event_timed *et= evex_queue_element(&EVEX_EQ_NAME, i, Event_timed*);
DBUG_PRINT("info", ("[%s.%s]==[%s.%s]?",db->str,name->str, et->dbname.str,
et->name.str));
if (!sortcmp_lex_string(*name, et->name, system_charset_info) &&
@@ -1168,7 +1168,7 @@ done:
*/
int
-evex_create_event(THD *thd, event_timed *et, uint create_options,
+evex_create_event(THD *thd, Event_timed *et, uint create_options,
uint *rows_affected)
{
int ret = 0;
@@ -1213,7 +1213,7 @@ done:
*/
int
-evex_update_event(THD *thd, event_timed *et, sp_name *new_name,
+evex_update_event(THD *thd, Event_timed *et, sp_name *new_name,
uint *rows_affected)
{
int ret, i;
@@ -1267,7 +1267,7 @@ done:
rows_affected affected number of rows is returned heres
*/
-int db_drop_event(THD *thd, event_timed *et, bool drop_if_exists,
+int db_drop_event(THD *thd, Event_timed *et, bool drop_if_exists,
uint *rows_affected)
{
TABLE *table;
@@ -1308,7 +1308,7 @@ int db_drop_event(THD *thd, event_timed *et, bool drop_if_exists,
done:
/*
- evex_drop_event() is used by event_timed::drop therefore
+ evex_drop_event() is used by Event_timed::drop therefore
we have to close our thread tables.
*/
close_thread_tables(thd);
@@ -1330,7 +1330,7 @@ done:
*/
int
-evex_drop_event(THD *thd, event_timed *et, bool drop_if_exists,
+evex_drop_event(THD *thd, Event_timed *et, bool drop_if_exists,
uint *rows_affected)
{
TABLE *table;
@@ -1373,7 +1373,7 @@ int
evex_show_create_event(THD *thd, sp_name *spn, LEX_STRING definer)
{
int ret;
- event_timed *et= NULL;
+ Event_timed *et= NULL;
Open_tables_state backup;
DBUG_ENTER("evex_update_event");
@@ -1442,15 +1442,15 @@ evex_show_create_event(THD *thd, sp_name *spn, LEX_STRING definer)
1. Go through the in-memory cache, if the scheduler is working
and for every event whose dbname matches the database we drop
check whether is currently in execution:
- - event_timed::can_spawn() returns true -> the event is not
+ - Event_timed::can_spawn() returns true -> the event is not
being executed in a child thread. The reason not to use
- event_timed::is_running() is that the latter shows only if
+ Event_timed::is_running() is that the latter shows only if
it is being executed, which is 99% of the time in the thread
but there are some initiliazations before and after the
anonymous SP is being called. So if we delete in this moment
-=> *boom*, so we have to check whether the thread has been
spawned and can_spawn() is the right method.
- - event_timed::can_spawn() returns false -> being runned ATM
+ - Event_timed::can_spawn() returns false -> being runned ATM
just set the flags so it should drop itself.
*/
@@ -1484,7 +1484,7 @@ evex_drop_db_events(THD *thd, char *db)
for (i= 0; i < evex_queue_num_elements(EVEX_EQ_NAME); ++i)
{
- event_timed *et= evex_queue_element(&EVEX_EQ_NAME, i, event_timed*);
+ Event_timed *et= evex_queue_element(&EVEX_EQ_NAME, i, Event_timed*);
if (sortcmp_lex_string(et->dbname, db_lex, system_charset_info))
continue;
@@ -1561,7 +1561,7 @@ skip_memory:
LEX_STRING et_db_lex= {et_db, strlen(et_db)};
if (!sortcmp_lex_string(et_db_lex, db_lex, system_charset_info))
{
- event_timed ett;
+ Event_timed ett;
char *ptr;
if ((ptr= get_field(thd->mem_root, table->field[EVEX_FIELD_STATUS]))