Commit 4d374c7c authored by serg@serg.mylan's avatar serg@serg.mylan

update max_used_connections *after* thread_count was increased to take into...

update max_used_connections *after* thread_count was increased to take into account the current connection
parent 9200fe3b
...@@ -2951,8 +2951,6 @@ static void create_new_thread(THD *thd) ...@@ -2951,8 +2951,6 @@ static void create_new_thread(THD *thd)
DBUG_VOID_RETURN; DBUG_VOID_RETURN;
} }
pthread_mutex_lock(&LOCK_thread_count); pthread_mutex_lock(&LOCK_thread_count);
if (thread_count-delayed_insert_threads > max_used_connections)
max_used_connections=thread_count-delayed_insert_threads;
thd->thread_id=thread_id++; thd->thread_id=thread_id++;
thd->real_id=pthread_self(); // Keep purify happy thd->real_id=pthread_self(); // Keep purify happy
...@@ -2981,6 +2979,8 @@ static void create_new_thread(THD *thd) ...@@ -2981,6 +2979,8 @@ static void create_new_thread(THD *thd)
thread_count++; thread_count++;
thread_created++; thread_created++;
threads.append(thd); threads.append(thd);
if (thread_count-delayed_insert_threads > max_used_connections)
max_used_connections=thread_count-delayed_insert_threads;
DBUG_PRINT("info",(("creating thread %d"), thd->thread_id)); DBUG_PRINT("info",(("creating thread %d"), thd->thread_id));
thd->connect_time = time(NULL); thd->connect_time = time(NULL);
if ((error=pthread_create(&thd->real_id,&connection_attrib, if ((error=pthread_create(&thd->real_id,&connection_attrib,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment