fumiama/simple-dict
1
0
Fork 0
mirror of https://github.com/fumiama/simple-dict.git synced 2026-06-10 05:04:13 +08:00
Code Activity

timer noquit

Browse Source
This commit is contained in:
源文雨
2022-10-24 22:55:36 +08:00
parent 9cfaba65e0
commit 0872e79f02
1 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
server.c
View File

@@ -590,6 +590,7 @@ static void accept_timer(void *p) {
uint8_t isbusy = timer->isbusy; uint8_t isbusy = timer->isbusy;
pthread_rwlock_unlock(&timer->mb); pthread_rwlock_unlock(&timer->mb);
if(!isbusy) { if(!isbusy) {
TIMER_SLEEP:
pthread_mutex_lock(&timer->tmc); pthread_mutex_lock(&timer->tmc);
timer->hastimerslept = 1; timer->hastimerslept = 1;
puts("Timer sleep"); puts("Timer sleep");
@@ -608,17 +609,10 @@ static void accept_timer(void *p) {
pthread_kill(thread, SIGQUIT); pthread_kill(thread, SIGQUIT);
puts("Kill thread"); puts("Kill thread");
} }
break; goto TIMER_SLEEP;
} }
sleep(MAXWAITSEC / 4); sleep(MAXWAITSEC / 4);
} }
pthread_cond_destroy(&timer->tc);
printf("Destroy timer cond, ");
pthread_mutex_destroy(&timer->tmc);
printf("Destroy timer mutex, ");
timer->timerthread = NULL;
timer->hastimerslept = 0;
puts("Clear timer thread");
} }
static void cleanup_thread(thread_timer_t* timer) { static void cleanup_thread(thread_timer_t* timer) {
@@ -649,8 +643,6 @@ static void cleanup_thread(thread_timer_t* timer) {
static void process_defer() { static void process_defer() {
for(int i = 0; i < THREADCNT; i++) { for(int i = 0; i < THREADCNT; i++) {
if(timers[i].thread) pthread_kill(timers[i].thread, SIGQUIT); if(timers[i].thread) pthread_kill(timers[i].thread, SIGQUIT);
pthread_cond_destroy(&timers[i].tc);
pthread_mutex_destroy(&timers[i].tmc);
if(timers[i].timerthread) pthread_kill(timers[i].timerthread, SIGQUIT); if(timers[i].timerthread) pthread_kill(timers[i].timerthread, SIGQUIT);
} }
fflush(stdout); fflush(stdout);