Skip to content

Commit 4912289

Browse files
committed
Use thd_killed() instead of underlaying killed field
1 parent 395fa55 commit 4912289

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

handlersocket/database.cpp

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -246,12 +246,12 @@ wait_server_to_start(THD *thd, volatile int& shutdown_flag)
246246
&abstime);
247247
pthread_mutex_unlock(&LOCK_server_started);
248248
pthread_mutex_lock(&thd->mysys_var->mutex);
249-
THD::killed_state st = thd->killed;
249+
int killed = thd_killed(thd);
250250
pthread_mutex_unlock(&thd->mysys_var->mutex);
251-
DBG_SHUT(fprintf(stderr, "HNDSOCK wsts kst %d\n", (int)st));
251+
DBG_SHUT(fprintf(stderr, "HNDSOCK wsts kst %d\n", killed));
252252
pthread_mutex_lock(&LOCK_server_started);
253-
if (st != THD::NOT_KILLED) {
254-
DBG_SHUT(fprintf(stderr, "HNDSOCK wsts kst %d break\n", (int)st));
253+
if (killed) {
254+
DBG_SHUT(fprintf(stderr, "HNDSOCK wsts kst %d break\n", killed));
255255
r = -1;
256256
break;
257257
}
@@ -358,12 +358,12 @@ bool
358358
dbcontext::check_alive()
359359
{
360360
pthread_mutex_lock(&thd->mysys_var->mutex);
361-
THD::killed_state st = thd->killed;
361+
int killed = thd_killed(thd);
362362
pthread_mutex_unlock(&thd->mysys_var->mutex);
363-
DBG_SHUT(fprintf(stderr, "chk HNDSOCK kst %p %p %d %zu\n", thd, &thd->killed,
363+
DBG_SHUT(fprintf(stderr, "chk HNDSOCK kst %p %p %d %u\n", thd, killed,
364364
(int)st, sizeof(*thd)));
365-
if (st != THD::NOT_KILLED) {
366-
DBG_SHUT(fprintf(stderr, "chk HNDSOCK kst %d break\n", (int)st));
365+
if (killed) {
366+
DBG_SHUT(fprintf(stderr, "chk HNDSOCK kst %d break\n", killed));
367367
return false;
368368
}
369369
return true;

0 commit comments

Comments
 (0)