night0721/zsm
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Create threadpool before accept connection

Browse source
This commit is contained in:
Night Kaly 2024-09-21 15:38:06 +01:00
parent c0fe9b6edc
commit c67915a41c
Signed by: night0721
GPG key ID: 957D67B8DB7A119B
1 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/server/server.c
View file

@ -128,6 +128,7 @@ void *thread_worker(void *arg)
memcpy(to, pkt.data + MAX_NAME, MAX_NAME); memcpy(to, pkt.data + MAX_NAME, MAX_NAME);
if (to[0] != '\0') { if (to[0] != '\0') {
int fd = get_clientfd(to); int fd = get_clientfd(to);
/* TODO: Find via hashtable */
if (fd != -1) { if (fd != -1) {
error(0, "Relaying packet to %s", to); error(0, "Relaying packet to %s", to);
send_packet(&pkt, fd); send_packet(&pkt, fd);
@ -184,12 +185,6 @@ int main(int argc, char **argv)
error(1, "Error on bind"); error(1, "Error on bind");
} }
if (listen(serverfd, MAX_CONNECTION_QUEUE) < 0) {
close(serverfd);
error(1, "Error on listen");
}
/* Creating thread pool */ /* Creating thread pool */
for (int i = 0; i < MAX_THREADS; i++) { for (int i = 0; i < MAX_THREADS; i++) {
/* Create epoll instance for each thread */ /* Create epoll instance for each thread */
@ -208,6 +203,11 @@ int main(int argc, char **argv)
} }
} }
if (listen(serverfd, MAX_CONNECTION_QUEUE) < 0) {
close(serverfd);
error(1, "Error on listen");
}
error(0, "Listening on port %d", PORT); error(0, "Listening on port %d", PORT);
/* Server loop to accept clients and load balance */ /* Server loop to accept clients and load balance */
@ -220,6 +220,7 @@ int main(int argc, char **argv)
} }
/* Assign new client to a thread /* Assign new client to a thread
* TODO: Loop everythread to see which client is unintialised
* Clients distributed by a rotation(round-robin) * Clients distributed by a rotation(round-robin)
*/ */
thread_t *thread = &threads[num_thread]; thread_t *thread = &threads[num_thread];