git initHEAD0.6.16master

1 files changed, 226 insertions, 0 deletions

diff --git a/plasma/comthread.cc b/plasma/comthread.cc
new file mode 100644
index 0000000..52ef1b8
--- /dev/null
+++ b/plasma/comthread.cc
@@ -0,0 +1,226 @@
+//***************************************************************************
+// Group VDR/GraphTFT
+// File comthread.cc
+// Date 28.10.06 - Jörg Wendel
+// This code is distributed under the terms and conditions of the
+// GNU GENERAL PUBLIC LICENSE. See the file COPYING for details.
+//--------------------------------------------------------------------------
+// Class ComThread
+//***************************************************************************
+
+#include <arpa/inet.h>
+
+#include "comthread.hpp"
+
+//***************************************************************************
+// Object
+//***************************************************************************
+
+ComThread::ComThread()
+   : QThread()
+{
+   line = new TcpChannel();
+
+   bufferSize = maxBuffer;
+
+   buffer = new char[bufferSize+1];
+   header = new TcpChannel::Header;
+
+   timeout = 1;
+   port = -1;
+   *host = 0;
+}
+
+ComThread::~ComThread()
+{
+   if (line->isConnected())
+   {
+      tell(eloAlways, "Logout from server, closing tcp connection");
+      line->write(cGraphTftComService::cmdLogout);
+      line->close();
+   }
+
+   delete line;
+   delete header;
+   delete[] buffer;
+}
+
+//***************************************************************************
+// Run
+//***************************************************************************
+
+void ComThread::run()
+{
+   const int checkTimeout = 2;
+
+   int status;
+   time_t lastCheck = time(0);
+
+   running = true;
+
+   while (running)
+   {
+      if (!line->isConnected())
+      {
+         tell(eloAlways, "Trying connecting to '%s' at port (%d)", host, port);
+
+         if (line->open(host, port) == success)
+            tell(eloAlways, "Connection to '%s' established", host);
+         else
+            tell(eloAlways, "Connecting to '%s' failed", host);
+      }
+
+      while (line->isConnected() && running)
+      {
+         if (lastCheck+checkTimeout < time(0))
+         {
+            line->write(cGraphTftComService::cmdCheck);
+            lastCheck = time(0);
+         }
+
+         if ((status = line->look(1)) != success)
+         {
+            if (status != TcpChannel::wrnNoEventPending)
+            {
+               line->close();
+               tell(eloAlways, "Error: Communication problems, "
+                    "look failed, status was (%d)", status);
+
+               break;
+            }
+            
+            continue;
+         }
+         
+         if ((status = read()) != success)
+         {
+            line->close();
+            tell(eloAlways, "Error: Communication problems, "
+                 "read failed, status was (%d)", status);
+
+            break;
+         }
+      }
+
+      if (!running) break;
+
+      tell(eloAlways, "Retrying in %ld seconds", timeout);
+
+      for (int i = 0; i < timeout && running; i++)
+         sleep(1);
+   }
+}
+
+//***************************************************************************
+// Transmit events
+//***************************************************************************
+
+int ComThread::mouseEvent(int x, int y, int button, int flag, int data)
+{
+   GraphTftTouchEvent m;
+
+   m.x = x;
+   m.y = y;
+   m.button = button;
+   m.flag = flag;
+   m.data = data;
+   line->write(cGraphTftComService::cmdMouseEvent, (char*)&m, sizeof(GraphTftTouchEvent));
+
+   return 0;
+}
+
+//***************************************************************************
+// ...
+//***************************************************************************
+
+int ComThread::keyEvent(int key, int flag)
+{
+   GraphTftTouchEvent m;
+
+   m.x = 0;
+   m.y = 0;
+   m.button = key;
+   m.flag = flag | efKeyboard;
+   line->write(cGraphTftComService::cmdMouseEvent, (char*)&m, sizeof(GraphTftTouchEvent));
+
+   return 0;
+}
+
+//***************************************************************************
+// Read
+//***************************************************************************
+
+int ComThread::read()
+{
+   int status;
+   TcpChannel::Header tmp;
+
+   // es stehen Daten an, erst einmal den Header abholen ..
+
+   if ((status = line->read((char*)&tmp, sizeof(TcpChannel::Header))) == 0)
+   {
+      header->command = ntohl(tmp.command);
+      header->size = ntohl(tmp.size);
+
+      switch (header->command)
+      {
+         case cGraphTftComService::cmdWelcome:
+         {
+            tell(eloAlways, "Got welcome");
+
+            break;
+         }
+
+         case cGraphTftComService::cmdLogout:
+         {
+            tell(eloAlways, "Got logout from client, closing line");
+            line->close();
+
+            break;
+         }
+
+         case cGraphTftComService::cmdData:
+         {
+            tell(eloDebug, "Debug: Received %d bytes", header->size);
+          
+            bufferLock.lockForWrite();
+            status = line->read(buffer, header->size);
+            bufferLock.unlock();
+
+            if (status == success) 
+               update((unsigned char*)buffer, header->size);
+            
+            break;
+         }
+
+         case cGraphTftComService::cmdMouseEvent:
+         {
+            GraphTftTouchEvent ev;
+
+            status = line->read((char*)&ev, header->size);
+            tell(eloAlways, "Got mouse event, button (%d) at (%d/%d)", ev.button, ev.x, ev.y); 
+
+            break;
+         }
+
+         default:
+         {
+            tell(eloAlways, "Got unexpected protocol (%d), aborting", header->command); 
+            status = -1;
+
+            break;
+         }
+      }
+   }   
+
+   return status;
+}
+
+//***************************************************************************
+// Update Image
+//***************************************************************************
+
+void ComThread::update(unsigned char* buffer, int size)
+{
+   emit updateImage(buffer, size);
+}