sigmasternchen/CFloor
1
0
Fork 0
mirror of https://github.com/sigmasternchen/CFloor synced 2025-03-15 20:28:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

cleanup should be done now

Browse source
This commit is contained in:
overflowerror 2021-05-13 14:07:04 +02:00
parent d12a968cc2
commit 7490e0a739
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/networking.c
View file

@ -690,6 +690,8 @@ void startRequestHandler(struct connection* connection) {
pthread_t dataThreadId; pthread_t dataThreadId;
void dataHandler(int signo) { void dataHandler(int signo) {
pthread_t self = pthread_self();
debug("networking: data handler got called."); debug("networking: data handler got called.");
for(link_t* link = linked_first(&connectionList); link != NULL; link = linked_next(link)) { for(link_t* link = linked_first(&connectionList); link != NULL; link = linked_next(link)) {
@ -704,6 +706,15 @@ void dataHandler(int signo) {
connection->inUse++; connection->inUse++;
pthread_mutex_unlock(&(connection->lock)); pthread_mutex_unlock(&(connection->lock));
// if the connection is persistent there could be still
// unjoined threads -> join them
if (connection->threads.response != PTHREAD_NULL) {
stopThread(self, &(connection->threads.response), false);
}
if (connection->threads.encoder != PTHREAD_NULL) {
stopThread(self, &(connection->threads.encoder), false);
}
int tmp; int tmp;
char c; char c;
char buffer[BUFFER_LENGTH]; char buffer[BUFFER_LENGTH];