From 70208183bb7f28002988b523035d27b4d7250d9b Mon Sep 17 00:00:00 2001
From: 8nl <8nlight@disroot.org>
Date: Tue, 27 Feb 2024 16:16:46 +0000
Subject: [PATCH] Upload files to "/"

---
 README.txt |  9 +++++++++
 server.c   | 18 +++++++++---------
 2 files changed, 18 insertions(+), 9 deletions(-)
 create mode 100644 README.txt

diff --git a/README.txt b/README.txt
new file mode 100644
index 0000000..95fd013
--- /dev/null
+++ b/README.txt
@@ -0,0 +1,9 @@
+#Multiuser udp server for broadcasting music
+
+
+#Record audio in sterio
+arecord -D loopout -f S16_LE -t raw -r 41000 -c 2 | ./server
+
+
+#Geting raw pcm data and send to speaker
+echo "JOIN" | nc -u server_ip server_port | aplay -r 41000 -f S16_LE -c 2
diff --git a/server.c b/server.c
index 9da50ce..f1d7964 100644
--- a/server.c
+++ b/server.c
@@ -9,9 +9,9 @@
 #include <arpa/inet.h>
 #include <pthread.h>
 
-#define PORT 8888
-#define BUFF_SIZE 2048
-#define MAX_CLIENTS 45
+#define PORT 8889
+#define BUFF_SIZE 3024
+#define MAX_CLIENTS 25
 
 typedef struct {
 	int fd;
@@ -27,7 +27,8 @@ void *process_clients(void *p) {
 		if (ret <= 0)
 			continue;
 
-		socklen_t len = sizeof(data->clients[0]);
+		buf[ret - 1] = '\0';
+		socklen_t len = sizeof(struct sockaddr_in);
 		for (size_t i = 0; i < MAX_CLIENTS; i++)
 			sendto(data->fd, buf, ret, 0, (struct sockaddr *)&data->clients[i], len);
 	}
@@ -40,7 +41,7 @@ int main(void) {
 	if (fd < 0)
 		goto ERROR_WITHOUTCLOSE;
 
-	struct timeval tv = {.tv_sec = 1, .tv_usec = 0};
+	struct timeval tv = {.tv_sec = 0, .tv_usec = 512};
 	if (setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)) < 0)
 		goto ERROR;
 
@@ -65,14 +66,13 @@ int main(void) {
 	pthread_create(&td, NULL, process_clients, (void *)&data);
 
 	int last = 0;
-	char buf[25];
+	char buf[1];
 
-	socklen_t len = sizeof(data.clients[0]);
+	socklen_t len = sizeof(struct sockaddr_in);
 	while (1) {
 		if (last <= MAX_CLIENTS) {
 			if (recvfrom(fd, buf, sizeof(buf), 0, (struct sockaddr *)&data.clients[last], &len) > 0)
-				if (!strcmp(buf, "JOIN"))
-					last++;
+				last++;
 		}
 
 		else