ENGO150/WHY2
Template
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Activity

sending received message to all clients

Browse Source
This commit is contained in:
Václav Šmejkal 2023-02-22 12:07:26 +01:00
parent 58d5c7ede8
commit 0a331e97a8
Signed by: ENGO150
GPG Key ID: F6D6DF86242C5A59
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/chat/misc.c
View File

@ -107,6 +107,22 @@ node_t *get_node(int connection)
return buffer; return buffer;
} }
void *send_to_all(void *message)
{
if (head == NULL) return NULL;
node_t *node_buffer = head;
do //SEND TO ALL CONNECTIONS
{
why2_send_socket(*((char**) message), node_buffer -> connection); //SEND TO CLIENT
node_buffer = node_buffer -> next;
} while (node_buffer -> next != NULL);
return NULL;
}
//GLOBAL //GLOBAL
void why2_send_socket(char *text, int socket) void why2_send_socket(char *text, int socket)
{ {
@ -138,6 +154,7 @@ void *why2_communicate_thread(void *arg)
const time_t startTime = time(NULL); const time_t startTime = time(NULL);
char *received = NULL; char *received = NULL;
pthread_t thread_buffer;
while (time(NULL) - startTime < 86400) //KEEP COMMUNICATION ALIVE FOR 24 HOURS while (time(NULL) - startTime < 86400) //KEEP COMMUNICATION ALIVE FOR 24 HOURS
{ {
@ -149,6 +166,8 @@ void *why2_communicate_thread(void *arg)
printf("Received:\n%s\n\n", received); printf("Received:\n%s\n\n", received);
pthread_create(&thread_buffer, NULL, send_to_all, &received);
why2_deallocate(received); why2_deallocate(received);
} }