From 7d547a29164cf9318a7eca918705bbc30e93b81d Mon Sep 17 00:00:00 2001
From: deva <deva>
Date: Wed, 24 May 2006 09:15:57 +0000
Subject: *** empty log message ***

---
 client/decoder.cc | 26 +++++++++++++++++++++++++-
 1 file changed, 25 insertions(+), 1 deletion(-)

(limited to 'client/decoder.cc')

diff --git a/client/decoder.cc b/client/decoder.cc
index 0ed2032..c5b2876 100644
--- a/client/decoder.cc
+++ b/client/decoder.cc
@@ -85,8 +85,19 @@ void Decoder::run()
         sender->start();
         newconnection = false;
       }
-      senders.front()->pushFrame(frame, false, false);
+      senders.back()->pushFrame(frame, false, false);
     } else {
+      // Remove idle senders
+      QLinkedList<NetworkSender*>::iterator i;
+      for (i = senders.begin(); i != senders.end(); i++) {
+        NetworkSender *ns = *i;
+        if(ns->queueSize() == 0) {
+          i = senders.erase(i);
+          ns->stop();
+          delete ns;
+        }
+      }
+
       free(frame);
       newconnection = true;
     }
@@ -129,3 +140,16 @@ bool Decoder::eventFilter(QObject *o, QEvent *e)
   // standard event processing
   return false;
 }
+
+Status Decoder::status()
+{
+  Status s;
+
+  QLinkedList<NetworkSender*>::iterator i;
+  for(i = senders.begin(); i != senders.end(); i++) {
+    NetworkSender *ns = *i;
+    s.queue_sizes.push_back(ns->queueSize());
+  }
+  
+  return s;
+}
-- 
cgit v1.2.3