mirror of
https://github.com/MariaDB/server.git
synced 2025-08-01 03:47:19 +03:00
Review fixes:
Fixed portability problem with bool in C programs Moved close_thread_tables out from LOCK_thread_count mutex (safety fix) my_sleep() -> pthread_cond_timedwait() include/thr_lock.h: bool -> my_bool (bool is not portable in C programs) mysys/thr_lock.c: bool -> my_bool (bool is not portable in C programs) sql/lock.cc: Added comment Don't use | on bool variable sql/mysql_priv.h: Added comment sql/slave.cc: Moved close_thread_tables out from LOCK_thread_count mutex (safety fix) sql/sql_base.cc: Added comments my_sleep() -> pthread_cond_timedwait() to get less code and potentitally faster loop BitKeeper/etc/ignore: added ac_available_languages_fragment
This commit is contained in:
@ -546,3 +546,4 @@ vio/viotest-ssl
|
|||||||
scripts/make_win_binary_distribution
|
scripts/make_win_binary_distribution
|
||||||
EXCEPTIONS-CLIENT
|
EXCEPTIONS-CLIENT
|
||||||
support-files/my-innodb-heavy-4G.cnf
|
support-files/my-innodb-heavy-4G.cnf
|
||||||
|
ac_available_languages_fragment
|
||||||
|
@ -107,7 +107,7 @@ void thr_unlock(THR_LOCK_DATA *data);
|
|||||||
int thr_multi_lock(THR_LOCK_DATA **data,uint count);
|
int thr_multi_lock(THR_LOCK_DATA **data,uint count);
|
||||||
void thr_multi_unlock(THR_LOCK_DATA **data,uint count);
|
void thr_multi_unlock(THR_LOCK_DATA **data,uint count);
|
||||||
void thr_abort_locks(THR_LOCK *lock);
|
void thr_abort_locks(THR_LOCK *lock);
|
||||||
bool thr_abort_locks_for_thread(THR_LOCK *lock, pthread_t thread);
|
my_bool thr_abort_locks_for_thread(THR_LOCK *lock, pthread_t thread);
|
||||||
void thr_print_locks(void); /* For debugging */
|
void thr_print_locks(void); /* For debugging */
|
||||||
my_bool thr_upgrade_write_delay_lock(THR_LOCK_DATA *data);
|
my_bool thr_upgrade_write_delay_lock(THR_LOCK_DATA *data);
|
||||||
my_bool thr_reschedule_write_lock(THR_LOCK_DATA *data);
|
my_bool thr_reschedule_write_lock(THR_LOCK_DATA *data);
|
||||||
|
@ -966,10 +966,10 @@ void thr_abort_locks(THR_LOCK *lock)
|
|||||||
This is used to abort all locks for a specific thread
|
This is used to abort all locks for a specific thread
|
||||||
*/
|
*/
|
||||||
|
|
||||||
bool thr_abort_locks_for_thread(THR_LOCK *lock, pthread_t thread)
|
my_bool thr_abort_locks_for_thread(THR_LOCK *lock, pthread_t thread)
|
||||||
{
|
{
|
||||||
THR_LOCK_DATA *data;
|
THR_LOCK_DATA *data;
|
||||||
bool found= FALSE;
|
my_bool found= FALSE;
|
||||||
DBUG_ENTER("thr_abort_locks_for_thread");
|
DBUG_ENTER("thr_abort_locks_for_thread");
|
||||||
|
|
||||||
pthread_mutex_lock(&lock->mutex);
|
pthread_mutex_lock(&lock->mutex);
|
||||||
|
20
sql/lock.cc
20
sql/lock.cc
@ -331,7 +331,18 @@ void mysql_lock_abort(THD *thd, TABLE *table)
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/* Abort one thread / table combination */
|
/*
|
||||||
|
Abort one thread / table combination
|
||||||
|
|
||||||
|
SYNOPSIS
|
||||||
|
mysql_lock_abort_for_thread()
|
||||||
|
thd Thread handler
|
||||||
|
table Table that should be removed from lock queue
|
||||||
|
|
||||||
|
RETURN
|
||||||
|
0 Table was not locked by another thread
|
||||||
|
1 Table was locked by at least one other thread
|
||||||
|
*/
|
||||||
|
|
||||||
bool mysql_lock_abort_for_thread(THD *thd, TABLE *table)
|
bool mysql_lock_abort_for_thread(THD *thd, TABLE *table)
|
||||||
{
|
{
|
||||||
@ -344,10 +355,9 @@ bool mysql_lock_abort_for_thread(THD *thd, TABLE *table)
|
|||||||
{
|
{
|
||||||
for (uint i=0; i < locked->lock_count; i++)
|
for (uint i=0; i < locked->lock_count; i++)
|
||||||
{
|
{
|
||||||
bool found;
|
if (thr_abort_locks_for_thread(locked->locks[i]->lock,
|
||||||
found= thr_abort_locks_for_thread(locked->locks[i]->lock,
|
table->in_use->real_id))
|
||||||
table->in_use->real_id);
|
result= TRUE;
|
||||||
result|= found;
|
|
||||||
}
|
}
|
||||||
my_free((gptr) locked,MYF(0));
|
my_free((gptr) locked,MYF(0));
|
||||||
}
|
}
|
||||||
|
@ -606,12 +606,15 @@ bool rename_temporary_table(THD* thd, TABLE *table, const char *new_db,
|
|||||||
const char *table_name);
|
const char *table_name);
|
||||||
void remove_db_from_cache(const my_string db);
|
void remove_db_from_cache(const my_string db);
|
||||||
void flush_tables();
|
void flush_tables();
|
||||||
|
|
||||||
|
/* bits for last argument to remove_table_from_cache() */
|
||||||
#define RTFC_NO_FLAG 0x0000
|
#define RTFC_NO_FLAG 0x0000
|
||||||
#define RTFC_OWNED_BY_THD_FLAG 0x0001
|
#define RTFC_OWNED_BY_THD_FLAG 0x0001
|
||||||
#define RTFC_WAIT_OTHER_THREAD_FLAG 0x0002
|
#define RTFC_WAIT_OTHER_THREAD_FLAG 0x0002
|
||||||
#define RTFC_CHECK_KILLED_FLAG 0x0004
|
#define RTFC_CHECK_KILLED_FLAG 0x0004
|
||||||
bool remove_table_from_cache(THD *thd, const char *db, const char *table,
|
bool remove_table_from_cache(THD *thd, const char *db, const char *table,
|
||||||
uint flags);
|
uint flags);
|
||||||
|
|
||||||
bool close_cached_tables(THD *thd, bool wait_for_refresh, TABLE_LIST *tables);
|
bool close_cached_tables(THD *thd, bool wait_for_refresh, TABLE_LIST *tables);
|
||||||
void copy_field_from_tmp_record(Field *field,int offset);
|
void copy_field_from_tmp_record(Field *field,int offset);
|
||||||
int fill_record(List<Item> &fields,List<Item> &values, bool ignore_errors);
|
int fill_record(List<Item> &fields,List<Item> &values, bool ignore_errors);
|
||||||
|
@ -2719,9 +2719,9 @@ err:
|
|||||||
mi->abort_slave = 0; // TODO: check if this is needed
|
mi->abort_slave = 0; // TODO: check if this is needed
|
||||||
DBUG_ASSERT(thd->net.buff != 0);
|
DBUG_ASSERT(thd->net.buff != 0);
|
||||||
net_end(&thd->net); // destructor will not free it, because net.vio is 0
|
net_end(&thd->net); // destructor will not free it, because net.vio is 0
|
||||||
|
close_thread_tables(thd, 0);
|
||||||
pthread_mutex_lock(&LOCK_thread_count);
|
pthread_mutex_lock(&LOCK_thread_count);
|
||||||
THD_CHECK_SENTRY(thd);
|
THD_CHECK_SENTRY(thd);
|
||||||
close_thread_tables(thd);
|
|
||||||
delete thd;
|
delete thd;
|
||||||
pthread_mutex_unlock(&LOCK_thread_count);
|
pthread_mutex_unlock(&LOCK_thread_count);
|
||||||
pthread_cond_broadcast(&mi->stop_cond); // tell the world we are done
|
pthread_cond_broadcast(&mi->stop_cond); // tell the world we are done
|
||||||
|
@ -2403,8 +2403,14 @@ void flush_tables()
|
|||||||
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
** Mark all entries with the table as deleted to force an reopen of the table
|
Mark all entries with the table as deleted to force an reopen of the table
|
||||||
** Returns true if the table is in use by another thread
|
|
||||||
|
PREREQUISITES
|
||||||
|
Lock on LOCK_open()
|
||||||
|
|
||||||
|
RETURN
|
||||||
|
0 If the table is NOT in use by another thread
|
||||||
|
1 If the table is NOT in use by another thread
|
||||||
*/
|
*/
|
||||||
|
|
||||||
bool remove_table_from_cache(THD *thd, const char *db, const char *table_name,
|
bool remove_table_from_cache(THD *thd, const char *db, const char *table_name,
|
||||||
@ -2416,6 +2422,7 @@ bool remove_table_from_cache(THD *thd, const char *db, const char *table_name,
|
|||||||
bool result=0, signalled= 0;
|
bool result=0, signalled= 0;
|
||||||
DBUG_ENTER("remove_table_from_cache");
|
DBUG_ENTER("remove_table_from_cache");
|
||||||
|
|
||||||
|
|
||||||
key_length=(uint) (strmov(strmov(key,db)+1,table_name)-key)+1;
|
key_length=(uint) (strmov(strmov(key,db)+1,table_name)-key)+1;
|
||||||
for (;;)
|
for (;;)
|
||||||
{
|
{
|
||||||
@ -2473,15 +2480,12 @@ bool remove_table_from_cache(THD *thd, const char *db, const char *table_name,
|
|||||||
{
|
{
|
||||||
if (!(flags & RTFC_CHECK_KILLED_FLAG) || !thd->killed)
|
if (!(flags & RTFC_CHECK_KILLED_FLAG) || !thd->killed)
|
||||||
{
|
{
|
||||||
|
dropping_tables++;
|
||||||
if (likely(signalled))
|
if (likely(signalled))
|
||||||
{
|
|
||||||
dropping_tables++;
|
|
||||||
(void) pthread_cond_wait(&COND_refresh, &LOCK_open);
|
(void) pthread_cond_wait(&COND_refresh, &LOCK_open);
|
||||||
dropping_tables--;
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
struct timespec abstime;
|
||||||
/*
|
/*
|
||||||
It can happen that another thread has opened the
|
It can happen that another thread has opened the
|
||||||
table but has not yet locked any table at all. Since
|
table but has not yet locked any table at all. Since
|
||||||
@ -2492,11 +2496,11 @@ bool remove_table_from_cache(THD *thd, const char *db, const char *table_name,
|
|||||||
and then we retry another loop in the
|
and then we retry another loop in the
|
||||||
remove_table_from_cache routine.
|
remove_table_from_cache routine.
|
||||||
*/
|
*/
|
||||||
pthread_mutex_unlock(&LOCK_open);
|
set_timespec(abstime, 10);
|
||||||
my_sleep(10);
|
pthread_cond_timedwait(&COND_refresh, &LOCK_open, &abstime);
|
||||||
pthread_mutex_lock(&LOCK_open);
|
|
||||||
continue;
|
|
||||||
}
|
}
|
||||||
|
dropping_tables--;
|
||||||
|
continue;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
Reference in New Issue
Block a user