...
|
...
|
@@ -452,7 +452,7 @@ static void *acceptloop_th(void *arg)
|
452
|
452
|
closesocket(fds->buf[i].fd);
|
453
|
453
|
}
|
454
|
454
|
fds_free(fds);
|
455
|
|
-
|
|
455
|
+ pthread_mutex_destroy(fds->buf_mutex);
|
456
|
456
|
pthread_mutex_lock(&exit_mutex);
|
457
|
457
|
progexit = 1;
|
458
|
458
|
pthread_mutex_unlock(&exit_mutex);
|
...
|
...
|
@@ -1344,6 +1344,8 @@ int recvloop_th(int *socketds, unsigned nsockets, struct cl_engine *engine, unsi
|
1344
|
1344
|
|
1345
|
1345
|
pthread_join(accept_th, NULL);
|
1346
|
1346
|
fds_free(fds);
|
|
1347
|
+ pthread_mutex_destroy(fds->buf_mutex);
|
|
1348
|
+ pthread_cond_destroy(&acceptdata.cond_nfds);
|
1347
|
1349
|
#ifdef _WIN32
|
1348
|
1350
|
CloseHandle(event_wake_accept);
|
1349
|
1351
|
CloseHandle(event_wake_recv);
|