Add progress indication to McastSender and McastReceiver

4 files changed, 9 insertions, 0 deletions

diff --git a/src/net/mcast/McastReceiver.cpp b/src/net/mcast/McastReceiver.cpp
index 7480ac2..6070208 100644
--- a/src/net/mcast/McastReceiver.cpp
+++ b/src/net/mcast/McastReceiver.cpp
@@ -121,6 +121,8 @@ void McastReceiver::receivedPacket(QByteArray const& bytes)
     _hash.addData(contents);
 
     _iodev->write(contents);
+
+    emit progress(_curoffs);
 }
 
 void McastReceiver::connectionReset()
diff --git a/src/net/mcast/McastReceiver.h b/src/net/mcast/McastReceiver.h
index 38e1219..48ff7c5 100644
--- a/src/net/mcast/McastReceiver.h
+++ b/src/net/mcast/McastReceiver.h
@@ -54,6 +54,7 @@ public:
 
 signals:
     void finished(int result);
+    void progress(quint64 offset);
 
 public slots:
     void start();
diff --git a/src/net/mcast/McastSender.cpp b/src/net/mcast/McastSender.cpp
index f49c0df..294fc55 100644
--- a/src/net/mcast/McastSender.cpp
+++ b/src/net/mcast/McastSender.cpp
@@ -67,6 +67,8 @@ void McastSender::readyToSend()
         _finished = true;
 
         _iodev->close();
+
+        emit allSent();
     }
     else
     {
@@ -89,6 +91,8 @@ void McastSender::readyToSend()
 		_curoffs += len_read;
 
 		_socket->sendPacket(pdu);
+
+		emit progress(_curoffs);
     }
 }
 
diff --git a/src/net/mcast/McastSender.h b/src/net/mcast/McastSender.h
index 5c62fad..eaaf216 100644
--- a/src/net/mcast/McastSender.h
+++ b/src/net/mcast/McastSender.h
@@ -48,6 +48,8 @@ public:
 
 signals:
 	void finished();
+	void progress(quint64 offset);
+	void allSent();
 
 public slots:
     void start();