Bug fix for new stream protocol

diff --git a/mvpreceiver.c b/mvpreceiver.c
index fcc9caf0c4c3964e2167a9d4e3291ad017152da2..ae8c01b5344620421ce6bf1f1abe8b2350efa269 100755 (executable)
--- a/mvpreceiver.c
+++ b/mvpreceiver.c
@@ -102,14 +102,17 @@ void MVPReceiver::threadMethod()
     threadWaitForSignal();
     threadCheckExit();
     
-    pthread_mutex_lock(&processedRingLock);
-    amountReceived = processed.get(buffer+12, streamChunkSize);
-    pthread_mutex_unlock(&processedRingLock);
+    do
+    {
+      pthread_mutex_lock(&processedRingLock);
+      amountReceived = processed.get(buffer+12, streamChunkSize);
+      pthread_mutex_unlock(&processedRingLock);
     
-    *(ULONG*)&buffer[0] = htonl(2); // stream channel
-    *(ULONG*)&buffer[4] = htonl(streamID);
-    *(ULONG*)&buffer[8] = htonl(amountReceived);
-    tcp->sendPacket(buffer, amountReceived + 12);
+      *(ULONG*)&buffer[0] = htonl(2); // stream channel
+      *(ULONG*)&buffer[4] = htonl(streamID);
+      *(ULONG*)&buffer[8] = htonl(amountReceived);
+      tcp->sendPacket(buffer, amountReceived + 12);
+    } while(processed.getContent());
   }  
 }