*** empty log message ***

9 files changed, 111 insertions, 36 deletions

diff --git a/client/control.cc b/client/control.cc
index b6495d2..d634039 100644
--- a/client/control.cc
+++ b/client/control.cc
@@ -46,11 +46,13 @@ void Control::setCpr(QString cpr)
   mutex.unlock();
 }
 
-void Control::getCpr(QString *cpr)
+QString Control::getCpr()
 {
+  QString cpr;
   mutex.lock();
-  *cpr = Control::cpr;
+  cpr = Control::cpr;
   mutex.unlock();
+  return cpr;
 }
 
 void Control::freeze()
diff --git a/client/control.h b/client/control.h
index f6b4599..cdc8bc4 100644
--- a/client/control.h
+++ b/client/control.h
@@ -39,7 +39,7 @@ public:
   ~Control();
 
   void setCpr(QString cpr);
-  void getCpr(QString *cpr);
+  QString getCpr();
 
   void freeze();
   void unfreeze();
diff --git a/client/decoder.cc b/client/decoder.cc
index 5421e16..0ed2032 100644
--- a/client/decoder.cc
+++ b/client/decoder.cc
@@ -44,9 +44,8 @@
 
 #include "libdv_wrapper.h"
 
-Decoder::Decoder(NetworkSender *ns): closesem(1)
+Decoder::Decoder()
 {
-  sender = ns;
   running = true;
   memset(pframe, 0, sizeof(pframe)); // Init an empty frame
   qApp->installEventFilter(this);
@@ -58,7 +57,9 @@ Decoder::~Decoder()
 
 void Decoder::run()
 {
-  closesem.acquire(); // Lock the shutdown process
+  bool newconnection = true;
+
+  //  closesem.acquire(); // Lock the shutdown process
 
 #ifdef READ_DV_FROM_FILE
   dvfile reader;
@@ -77,9 +78,20 @@ void Decoder::run()
       pmutex.unlock();
     }
 
-    free(frame);
+    if(MIaV::control.isRecording()) {
+      if(newconnection) {
+        NetworkSender *sender = new NetworkSender(MIaV::control.getCpr());
+        senders.push_back(sender);
+        sender->start();
+        newconnection = false;
+      }
+      senders.front()->pushFrame(frame, false, false);
+    } else {
+      free(frame);
+      newconnection = true;
+    }
   }
-  closesem.release(); // Unlock the shutdown process
+  //  closesem.release(); // Unlock the shutdown process
 }
 
 char *Decoder::pframeAcquire()
diff --git a/client/decoder.h b/client/decoder.h
index a8fb4f9..26d86d7 100644
--- a/client/decoder.h
+++ b/client/decoder.h
@@ -31,6 +31,8 @@
 #include <QSemaphore>
 #include <QMutex>
 
+#include <QList>
+
 #include "dv.h"
 #include "networksender.h"
 
@@ -38,7 +40,7 @@ class Decoder : public QThread
 {
 Q_OBJECT
 public:
-  Decoder(NetworkSender *sender);
+  Decoder();
   ~Decoder();
 
   char *getFrame();
@@ -62,7 +64,7 @@ private:
 
   QMutex mutex;
 
-  NetworkSender *sender;
+  QList<NetworkSender *> senders;
 };
 
 #endif/*__MIAV_DECODER_H__*/
diff --git a/client/mainwindow.cc b/client/mainwindow.cc
index 3680afc..da2785b 100644
--- a/client/mainwindow.cc
+++ b/client/mainwindow.cc
@@ -34,15 +34,12 @@
 
 #include "historywidget.h"
 
-#include <QStatusBar>
-
 #include "control.h"
 
 #include "icons.h"
 
 QPushButton *MainWindow::createButton(QPixmap *pixmap)
 {
-  //  QPixmap p = loadIcon(icon);
   QPushButton *btn = new QPushButton();
   btn->setIconSize(QSize(pixmap->width(), pixmap->height()));
   btn->setIcon(*pixmap);
@@ -83,35 +80,58 @@ MainWindow::MainWindow(Decoder *d)
 
   // Create the control buttons
   btn_cpr = createButton(Icons::cpr);
-  layout->addWidget(btn_cpr, 1,3, 1,1);
+  layout->addWidget(btn_cpr, 1,3, 2,1);
   connect(btn_cpr, SIGNAL(clicked()), this, SLOT(cpr_clicked()));
 
   btn_record = createButton(Icons::record);
-  layout->addWidget(btn_record, 2,0, 1,1);
+  layout->addWidget(btn_record, 3,0, 1,1);
   connect(btn_record, SIGNAL(clicked()), this, SLOT(record_clicked()));
 
   btn_snapshot = createButton(Icons::snapshot);
-  layout->addWidget(btn_snapshot, 2,1, 1,1);
+  layout->addWidget(btn_snapshot, 3,1, 1,1);
   connect(btn_snapshot, SIGNAL(clicked()), this, SLOT(snapshot_clicked()));
 
   btn_freeze = createButton(Icons::freeze);
-  layout->addWidget(btn_freeze, 2,2, 1,1);
+  layout->addWidget(btn_freeze, 3,2, 1,1);
   connect(btn_freeze, SIGNAL(clicked()), this, SLOT(freeze_clicked()));
 
   btn_mute = createButton(Icons::mute);
-  layout->addWidget(btn_mute, 2,3, 1,1);
+  layout->addWidget(btn_mute, 3,3, 1,1);
   connect(btn_mute, SIGNAL(clicked()), this, SLOT(mute_clicked()));
 
   btn_clear = createButton(Icons::clear);
-  layout->addWidget(btn_clear, 2,4, 1,1);
+  layout->addWidget(btn_clear, 3,4, 1,1);
   connect(btn_clear, SIGNAL(clicked()), this, SLOT(clear_clicked()));
 
+  // Create the labels
+  lbl_cpr = new QLabel();
+  QFont font = lbl_cpr->font();
+  font.setPointSize(font.pointSize() * 2);
+  font.setBold(true);
+  lbl_cpr->setFont(font);
+  lbl_cpr->setText("CPR");
+  layout->addWidget(lbl_cpr, 1,0, 1,3);
+
+  lbl_name = new QLabel();
+  font = lbl_name->font();
+  font.setPointSize(font.pointSize() * 3);
+  font.setBold(true);
+  lbl_name->setFont(font);
+  lbl_name->setText("Name");
+  layout->addWidget(lbl_name, 2,0, 1,3);
+
+  // Stretch the layout
+  layout->setRowStretch(0, 100);
+  layout->setRowStretch(1, 1);
+  layout->setRowStretch(2, 1);
+  layout->setRowStretch(3, 1);
+
   // Create history bar
   history = new HistoryFrame();
-  layout->addWidget(history, 0,4, 2,1);
+  layout->addWidget(history, 0,4, 3,1);
 
   // Create statusbar
-  QStatusBar *statusbar = new QStatusBar(this);
+  statusbar = new QStatusBar(this);
   outerlayout->addWidget(statusbar, 1,0, 1,1);
   statusbar->showMessage("Ready!");
 
diff --git a/client/mainwindow.h b/client/mainwindow.h
index 742351d..b94f5c5 100644
--- a/client/mainwindow.h
+++ b/client/mainwindow.h
@@ -30,6 +30,9 @@
 #include <QWidget>
 
 #include <QPushButton>
+#include <QLabel>
+#include <QStatusBar>
+
 #include "historyframe.h"
 #include "videowidget.h"
 
@@ -68,6 +71,13 @@ private:
   QPushButton *btn_freeze;
   QPushButton *btn_mute;
   QPushButton *btn_clear;
+
+  // Labels
+  QLabel *lbl_cpr;
+  QLabel *lbl_name;
+
+  // Statusbar
+  QStatusBar *statusbar;
 };
 
 #endif/*__MIAV_MAINWINDOW_H__*/
diff --git a/client/miav_client.cc b/client/miav_client.cc
index 38b8894..f004f83 100644
--- a/client/miav_client.cc
+++ b/client/miav_client.cc
@@ -45,8 +45,7 @@ int main(int argc, char *argv[])
   InfoGui info(MIaV::config);
   MIaV::initInfo(&info);
 
-  NetworkSender sender;
-  Decoder decoder(&sender);
+  Decoder decoder;
   MainWindow mainwindow(&decoder);
   Player player(mainwindow.getVideoWidget(), &decoder);
 
@@ -54,7 +53,6 @@ int main(int argc, char *argv[])
 
   decoder.start();
   player.start(1000 / fps);
-  sender.start();
 
   return app.exec();
 }
diff --git a/client/networksender.cc b/client/networksender.cc
index 21c107c..675bdb9 100644
--- a/client/networksender.cc
+++ b/client/networksender.cc
@@ -28,28 +28,46 @@
 
 #include "info.h"
 
-NetworkSender::NetworkSender()
+NetworkSender::NetworkSender(QString cpr)
 {
   ip = "192.168.0.10";
   port = 6666;
+
+  // Connect
 }
 
 NetworkSender::~NetworkSender()
-{}
-
-void NetworkSender::newConnection(char *cpr)
 {
+  // Disconnect
 }
 
-void NetworkSender::pushFrame(char* frame, bool freeze, bool snapshot)
+void NetworkSender::pushFrame(char* framedata, bool freeze, bool snapshot)
 {
-}
+  Frame *frame = new Frame((unsigned char*)framedata);
+  frame->freeze = freeze;
+  frame->shoot = snapshot;
 
-void NetworkSender::endConnection()
-{
+  mutex.lock();
+  framelist.push_back(frame);
+  mutex.unlock();
+
+  semaphore.release();
 }
 
 void NetworkSender::run()
 {
-  //  MIaV::info->info("The NetworkSender thread is running.");
+  while(running) {
+    semaphore.acquire();
+
+    Frame *frame = NULL;
+    mutex.lock();
+    if(framelist.isEmpty() == false) frame = framelist.takeLast();
+    mutex.unlock();
+
+    if(frame) {
+      // TODO: Send it over the network
+      
+      delete frame;
+    }
+  }
 }
diff --git a/client/networksender.h b/client/networksender.h
index 89c522a..43bb797 100644
--- a/client/networksender.h
+++ b/client/networksender.h
@@ -28,22 +28,35 @@
 #define __MIAV_NETWORKSENDER_H__
 
 #include <QThread>
+#include <QLinkedList>
+#include <QString>
+#include <QMutex>
+#include <QSemaphore>
+
+#include <frame.h>
 
 class NetworkSender : public QThread
 {
 public:
-  NetworkSender();
+  NetworkSender(QString cpr);
   ~NetworkSender();
 
-  void newConnection(char *cpr);
+  void newConnection(QString cpr);
   void pushFrame(char* frame, bool freeze, bool snapshot);
   void endConnection();
 
   void run();
 
 private:
-  std::string ip;
+  QString ip;
   unsigned short port;
+
+  volatile bool running;
+
+  QMutex mutex;
+  QSemaphore semaphore;
+  QLinkedList<Frame*> framelist;
+
 };
 
 #endif/*__MIAV_NETWORKSENDER_H__*/