diff options
author | unknown <andrey@lmy004.> | 2006-07-10 23:54:46 +0200 |
---|---|---|
committer | unknown <andrey@lmy004.> | 2006-07-10 23:54:46 +0200 |
commit | 084f74426b5f19b47984ef298309e9a4015940c3 (patch) | |
tree | 09cdd81d63936aee123b5ad452a7e925b299f9f6 | |
parent | 5d91dc2560836ae28351baf446df7bee97e2cd05 (diff) | |
download | mariadb-git-084f74426b5f19b47984ef298309e9a4015940c3.tar.gz |
Remove trailing whitespace.
After merge fixes.
sql/event_data_objects.cc:
after merge fix. use thd->strmake instead of strmake_root
Remove commented out code.
Remove trailing whitespace.
sql/event_db_repository.cc:
After merge fix.
Before closing thread tables check whether table is actuall non-NULL.
And always initialize it to NULL.
sql/event_queue.cc:
Remove trailing whitespace.
sql/event_scheduler_ng.cc:
Remove trailing whitespace.
Tabs to spaces.
sql/events.cc:
Remove trailing whitespace.
-rw-r--r-- | sql/event_data_objects.cc | 62 | ||||
-rw-r--r-- | sql/event_db_repository.cc | 21 | ||||
-rw-r--r-- | sql/event_queue.cc | 10 | ||||
-rw-r--r-- | sql/event_scheduler_ng.cc | 6 | ||||
-rw-r--r-- | sql/events.cc | 2 |
5 files changed, 31 insertions, 70 deletions
diff --git a/sql/event_data_objects.cc b/sql/event_data_objects.cc index 5153553d06b..0dd03e152af 100644 --- a/sql/event_data_objects.cc +++ b/sql/event_data_objects.cc @@ -87,21 +87,16 @@ void Event_parse_data::init_name(THD *thd, sp_name *spn) { DBUG_ENTER("Event_parse_data::init_name"); - /* During parsing, we must use thd->mem_root */ - MEM_ROOT *root= thd->mem_root; /* We have to copy strings to get them into the right memroot */ dbname.length= spn->m_db.length; - dbname.str= strmake_root(root, spn->m_db.str, spn->m_db.length); + dbname.str= thd->strmake(spn->m_db.str, spn->m_db.length); name.length= spn->m_name.length; - name.str= strmake_root(root, spn->m_name.str, spn->m_name.length); + name.str= thd->strmake(spn->m_name.str, spn->m_name.length); if (spn->m_qname.length == 0) spn->init_qname(thd); - DBUG_PRINT("dbname", ("len=%d db=%s",dbname.length, dbname.str)); - DBUG_PRINT("name", ("len=%d name=%s",name.length, name.str)); - DBUG_VOID_RETURN; } @@ -116,7 +111,7 @@ Event_parse_data::init_name(THD *thd, sp_name *spn) NOTE The body is extracted by copying all data between the start of the body set by another method and the current pointer in Lex. - + Some questionable removal of characters is done in here, and that part should be refactored when the parser is smarter. */ @@ -187,7 +182,7 @@ Event_parse_data::init_body(THD *thd) SYNOPSIS Event_parse_data::init_definer() - + RETURN VALUE 0 OK */ @@ -615,7 +610,7 @@ Event_basic::Event_basic() dbname.length= name.length= 0; DBUG_VOID_RETURN; } - + /* Destructor @@ -652,7 +647,7 @@ Event_basic::load_string_fields(Field **fields, ...) LEX_STRING *field_value; DBUG_ENTER("Event_basic::load_string_fields"); - + va_start(args, fields); field_name= (enum enum_events_table_field) va_arg(args, int); while (field_name != ET_FIELD_COUNT) @@ -668,7 +663,7 @@ Event_basic::load_string_fields(Field **fields, ...) field_name= (enum enum_events_table_field) va_arg(args, int); } va_end(args); - + DBUG_RETURN(ret); } @@ -757,7 +752,7 @@ Event_job_data::Event_job_data(): */ Event_job_data::~Event_job_data() -{ +{ free_sp(); } @@ -819,25 +814,6 @@ Event_job_data::load_from_row(TABLE *table) ET_FIELD_BODY, &body, ET_FIELD_DEFINER, &definer, ET_FIELD_COUNT); -/* - if ((dbname.str= get_field(&mem_root, table->field[ET_FIELD_DB])) == NullS) - goto error; - dbname.length= strlen(dbname.str); - - if ((name.str= get_field(&mem_root, table->field[ET_FIELD_NAME])) == NullS) - goto error; - name.length= strlen(name.str); - - if ((body.str= get_field(&mem_root, table->field[ET_FIELD_BODY])) == NullS) - goto error; - body.length= strlen(body.str); - - if ((definer.str= get_field(&mem_root, - table->field[ET_FIELD_DEFINER])) == NullS) - goto error; - - definer.length= strlen(definer.str); -*/ ptr= strchr(definer.str, '@'); if (! ptr) @@ -848,7 +824,7 @@ Event_job_data::load_from_row(TABLE *table) definer_user.length= len; len= definer.length - len - 1; /* 1:because of @ */ - definer_host.str= strmake_root(&mem_root, ptr + 1, len); + definer_host.str= strmake_root(&mem_root, ptr + 1, len); definer_host.length= len; sql_mode= (ulong) table->field[ET_FIELD_SQL_MODE]->val_int(); @@ -891,26 +867,13 @@ Event_queue_element::load_from_row(TABLE *table) load_string_fields(table->field, ET_FIELD_DB, &dbname, ET_FIELD_NAME, &name, ET_FIELD_DEFINER, &definer, ET_FIELD_COUNT); -/* - if ((dbname.str= get_field(&mem_root, table->field[ET_FIELD_DB])) == NullS) - goto error; - dbname.length= strlen(dbname.str); - - if ((name.str= get_field(&mem_root, table->field[ET_FIELD_NAME])) == NullS) - goto error; - name.length= strlen(name.str); - if ((definer.str= get_field(&mem_root, - table->field[ET_FIELD_DEFINER])) == NullS) - goto error; - definer.length= strlen(definer.str); -*/ starts_null= table->field[ET_FIELD_STARTS]->is_null(); res1= table->field[ET_FIELD_STARTS]->get_date(&starts, TIME_NO_ZERO_DATE); ends_null= table->field[ET_FIELD_ENDS]->is_null(); res2= table->field[ET_FIELD_ENDS]->get_date(&ends, TIME_NO_ZERO_DATE); - + if (!table->field[ET_FIELD_INTERVAL_EXPR]->is_null()) expression= table->field[ET_FIELD_INTERVAL_EXPR]->val_int(); else @@ -990,12 +953,7 @@ Event_timed::load_from_row(TABLE *table) goto error; load_string_fields(table->field, ET_FIELD_BODY, &body, ET_FIELD_COUNT); -/* - if ((body.str= get_field(&mem_root, table->field[ET_FIELD_BODY])) == NullS) - goto error; - body.length= strlen(body.str); -*/ ptr= strchr(definer.str, '@'); if (! ptr) diff --git a/sql/event_db_repository.cc b/sql/event_db_repository.cc index 22dcdd97a48..6e0ff89e453 100644 --- a/sql/event_db_repository.cc +++ b/sql/event_db_repository.cc @@ -524,8 +524,10 @@ Event_db_repository::create_event(THD *thd, Event_parse_data *parse_data, int ret= 0; CHARSET_INFO *scs= system_charset_info; TABLE *table; - char olddb[128]; + char old_db_buf[NAME_LEN+1]; + LEX_STRING old_db= { old_db_buf, sizeof(old_db_buf) }; bool dbchanged= FALSE; + DBUG_ENTER("Event_db_repository::create_event"); *rows_affected= 0; @@ -557,8 +559,8 @@ Event_db_repository::create_event(THD *thd, Event_parse_data *parse_data, } DBUG_PRINT("info", ("non-existant, go forward")); - if ((ret= sp_use_new_db(thd, parse_data->dbname.str, olddb, sizeof(olddb), 0, - &dbchanged))) + + if ((ret= sp_use_new_db(thd, parse_data->dbname, &old_db, 0, &dbchanged))) { my_error(ER_BAD_DB_ERROR, MYF(0)); goto err; @@ -618,14 +620,14 @@ Event_db_repository::create_event(THD *thd, Event_parse_data *parse_data, *rows_affected= 1; ok: if (dbchanged) - (void) mysql_change_db(thd, olddb, 1); + (void) mysql_change_db(thd, old_db.str, 1); if (table) close_thread_tables(thd); DBUG_RETURN(EVEX_OK); err: if (dbchanged) - (void) mysql_change_db(thd, olddb, 1); + (void) mysql_change_db(thd, old_db.str, 1); if (table) close_thread_tables(thd); DBUG_RETURN(EVEX_GENERAL_ERROR); @@ -655,7 +657,7 @@ Event_db_repository::update_event(THD *thd, Event_parse_data *parse_data, sp_name *new_name) { CHARSET_INFO *scs= system_charset_info; - TABLE *table; + TABLE *table= NULL; int ret= EVEX_OPEN_TABLE_FAILED; DBUG_ENTER("Event_db_repository::update_event"); @@ -765,7 +767,7 @@ int Event_db_repository::drop_event(THD *thd, LEX_STRING db, LEX_STRING name, bool drop_if_exists, uint *rows_affected) { - TABLE *table; + TABLE *table= NULL; Open_tables_state backup; int ret; @@ -804,7 +806,8 @@ Event_db_repository::drop_event(THD *thd, LEX_STRING db, LEX_STRING name, } done: - close_thread_tables(thd); + if (table) + close_thread_tables(thd); thd->restore_backup_open_tables_state(&backup); DBUG_RETURN(ret); } @@ -965,7 +968,7 @@ int Event_db_repository::find_event(THD *thd, LEX_STRING dbname, LEX_STRING name, Event_basic *et) { - TABLE *table; + TABLE *table= NULL; int ret; DBUG_ENTER("Event_db_repository::find_event"); DBUG_PRINT("enter", ("name: %*s", name.length, name.str)); diff --git a/sql/event_queue.cc b/sql/event_queue.cc index bd8809ba708..0fbde5d8910 100644 --- a/sql/event_queue.cc +++ b/sql/event_queue.cc @@ -42,7 +42,7 @@ SYNOPSIS event_queue_element_data_compare_q() - + vptr - not used (set it to NULL) a - first Event_queue_element object b - second Event_queue_element object @@ -51,7 +51,7 @@ -1 - a->execute_at < b->execute_at 0 - a->execute_at == b->execute_at 1 - a->execute_at > b->execute_at - + NOTES execute_at.second_part is not considered during comparison */ @@ -409,7 +409,7 @@ Event_queue::drop_matching_events(THD *thd, LEX_STRING pattern, DBUG_ENTER("Event_queue::drop_matching_events"); DBUG_PRINT("enter", ("pattern=%*s state=%d", pattern.length, pattern.str)); - uint i= 0; + uint i= 0; while (i < queue.elements) { Event_queue_element *et= (Event_queue_element *) queue_element(&queue, i); @@ -438,7 +438,7 @@ Event_queue::drop_matching_events(THD *thd, LEX_STRING pattern, not notify the scheduler and it will realize the change when it wakes up from timedwait. */ - + DBUG_VOID_RETURN; } @@ -499,7 +499,7 @@ Event_queue::events_count() SYNOPSIS Event_queue::load_events_from_db() thd - Thread context. Used for memory allocation in some cases. - + RETURN VALUE 0 OK !0 Error (EVEX_OPEN_TABLE_FAILED, EVEX_MICROSECOND_UNSUP, diff --git a/sql/event_scheduler_ng.cc b/sql/event_scheduler_ng.cc index 4e2820b8f65..54261cf902e 100644 --- a/sql/event_scheduler_ng.cc +++ b/sql/event_scheduler_ng.cc @@ -191,7 +191,7 @@ pthread_handler_t event_scheduler_ng_thread(void *arg) { /* needs to be first for thread_stack */ - THD *thd= (THD *)(*(struct scheduler_param *) arg).thd; + THD *thd= (THD *)(*(struct scheduler_param *) arg).thd; thd->thread_stack= (char *)&thd; // remember where our stack is DBUG_ENTER("event_scheduler_ng_thread"); @@ -207,7 +207,7 @@ event_scheduler_ng_thread(void *arg) #if !defined(__WIN__) && !defined(OS2) && !defined(__NETWARE__) sigset_t set; - VOID(sigemptyset(&set)); // Get mask in use + VOID(sigemptyset(&set)); // Get mask in use VOID(pthread_sigmask(SIG_UNBLOCK,&set,&thd->block_signals)); #endif @@ -256,7 +256,7 @@ event_worker_ng_thread(void *arg) #if !defined(__WIN__) && !defined(OS2) && !defined(__NETWARE__) sigset_t set; - VOID(sigemptyset(&set)); // Get mask in use + VOID(sigemptyset(&set)); // Get mask in use VOID(pthread_sigmask(SIG_UNBLOCK, &set, &thd->block_signals)); #endif thd->init_for_queries(); diff --git a/sql/events.cc b/sql/events.cc index 08e17a9578a..d3eb4bcd128 100644 --- a/sql/events.cc +++ b/sql/events.cc @@ -111,7 +111,7 @@ int sortcmp_lex_string(LEX_STRING s, LEX_STRING t, CHARSET_INFO *cs) Events::get_instance() RETURN VALUE - address + address */ Events * |