Fix handling multiple incoming messages at once

Signed-off-by: falkTX <[email protected]>
mod-audio · Jul 12, 2024 · 486955f · 486955f
1 parent b6dc4e0
commit 486955f
Showing 1 changed file with 21 additions and 4 deletions.
diff --git a/src/socket.c b/src/socket.c
@@ -391,10 +391,27 @@ void socket_run(int exit_on_failure)
                 msgbuffer = buffer;
             }
 
-            msg.sender_id = clientfd;
-            msg.data = msgbuffer;
-            msg.data_size = count;
-            if (g_receive_cb) g_receive_cb(&msg);
+            if (g_receive_cb)
+            {
+                msg.data = msgbuffer;
+
+                while (count != 0)
+                {
+                    if (*msg.data == '\0')
+                    {
+                        --count;
+                        ++msg.data;
+                        continue;
+                    }
+
+                    msg.sender_id = clientfd;
+                    msg.data_size = strlen(msg.data) + 1;
+                    g_receive_cb(&msg);
+
+                    count -= msg.data_size;
+                    msg.data += msg.data_size;
+                }
+            }
 
             if (msgbuffer != buffer)
                 free(msgbuffer);