WebSVN - Projects - Diff - Rev 259 and 263 - /QMK-Groundstation/trunk/Classes/cConnection.cpp

 /***************************************************************************
  *   Copyright (C) 2009 by Manuel Schrape                                  *
  *   manuel.schrape@gmx.de                                                 *
  *                                                                         *
  *   This program is free software; you can redistribute it and/or modify  *
  *   it under the terms of the GNU General Public License as published by  *
  *   the Free Software Foundation; either version 2 of the License.        *
  *                                                                         *
  *   This program is distributed in the hope that it will be useful,       *
  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  *   GNU General Public License for more details.                          *
  *                                                                         *
  *   You should have received a copy of the GNU General Public License     *
  *   along with this program; if not, write to the                         *
  *   Free Software Foundation, Inc.,                                       *
  *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
  ***************************************************************************/
 #include "cConnection.h"
 cConnection::cConnection()
+{
+    i_Type = 0;
     TTY = new ManageSerialPort();
+    TTY->setBaudRate(BAUD57600); //BaudRate
+    TTY->setDataBits(DATA_8); //DataBits
+    TTY->setParity(PAR_NONE); //Parity
+    TTY->setStopBits(STOP_1); //StopBits
+    TTY->setFlowControl(FLOW_OFF); //FlowControl
+    TTY->setTimeout(0, 10);
+    TTY->enableSending();
+    TTY->enableReceiving();
     b_isOpen = false;
+}
+void cConnection::new_Data(QString Data)
+{
+    while ((RxData.String.length() > 1) && (RxData.String.at(1) == '#'))
+    {
+        RxData.String.remove(0,1);
+    }
+    if (ToolBox::check_CRC(RxData.String))
+    {
+        RxData.Input = RxData.String.toLatin1().data();
+        emit(newData(RxData));
+    }
+    else
+    {
+        emit(showTerminal(2, RxData.String));
+    }
+}
 void cConnection::slot_newDataReceived(const QByteArray &dataReceived)
+{
     const char *RXt;
     RXt = dataReceived.data();
     int a = 0;
     while (RXt[a] != '\0')
+    {
         if (RXt[a] == '\r')
+        {
-            while ((RxData.String.length() > 1) && (RxData.String.at(1) == '#'))
-            {
-                RxData.String.remove(0,1);
+            new_Data(QString(""));
-            }
-            if (ToolBox::check_CRC(RxData.String))
-            {
-                RxData.Input = RxData.String.toLatin1().data();
-                emit(newData(RxData));
-//                emit(showTerminal(1, RxData.String));
-            }
-            else
-            {
-                emit(showTerminal(2, RxData.String));
-            }
             RxData.String = QString("");
+        }
         else
+        {
             RxData.String = RxData.String + QString(RXt[a]);
+        }
         a++;
+    }
+}
 bool cConnection::isOpen()
+{
     return b_isOpen;
+}
 bool cConnection::Close()
+{
+    switch(i_Type)
+    {
+        case C_TTY :
+        {
-    TTY->close();
+            TTY->close();
-    disconnect(TTY, SIGNAL(newDataReceived(const QByteArray &)), this, 0);
+            disconnect(TTY, SIGNAL(newDataReceived(const QByteArray &)), this, 0);
+            b_isOpen = false;
+        }
+        break;
+        case C_IP :
+        {
+            TcpSocket->disconnectFromHost();
+            disconnect(TcpSocket, SIGNAL(connected()), 0, 0);
+            disconnect(TcpSocket, SIGNAL(readyRead()), 0, 0);
+            disconnect(TcpSocket, SIGNAL(disconnected()), 0, 0);
+            b_isOpen = false;
+        }
         break;
     b_isOpen = false;
     return b_isOpen;
+}
-bool cConnection::Open(QString Address)
+bool cConnection::Open(int Typ, QString Address)
+{
+    switch(Typ)
+    {
+        case C_TTY :
-{
+        {
+            TTY->setPort(Address); //Port
-    TTY->setPort(Address); //Port
-    TTY->setBaudRate(BAUD57600); //BaudRate
-    TTY->setDataBits(DATA_8); //DataBits
+            TTY->open();
-    TTY->setParity(PAR_NONE); //Parity
-    TTY->setStopBits(STOP_1); //StopBits
-    TTY->setFlowControl(FLOW_OFF); //FlowControl
+            ToolBox::Wait(1000);
-    TTY->setTimeout(0, 10);
+            if (TTY->isOpen())
+            {
-    TTY->enableSending();
+                connect(TTY, SIGNAL(newDataReceived(const QByteArray &)), this, SLOT(slot_newDataReceived(const QByteArray &)));
+                TTY->receiveData();
-    TTY->enableReceiving();
+                b_isOpen = true;
+                i_Type = C_TTY;
-    TTY->open();
+            }
+        }
+        break;
-    ToolBox::Wait(1000);
+        case C_IP :
-    qDebug("Try Open");
+        {
+            QStringList Host = Address.split(":");
-    if (TTY->isOpen())
+            TcpSocket = new(QTcpSocket);
-    {
+            TcpSocket->connectToHost (Host[1], Host[2].toInt());
+            connect(TcpSocket, SIGNAL(connected()), this, SLOT(slot_IP_Connected()) );
-        qDebug("Opend");
+//            connect(TcpSocket, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(slot_Error(QAbstractSocket::SocketError)));
-        connect(TTY, SIGNAL(newDataReceived(const QByteArray &)), this, SLOT(slot_newDataReceived(const QByteArray &)));
+            b_isOpen = true;
             i_Type = C_IP;
         TTY->receiveData();
-        b_isOpen = true;
+        break;
+    }
     return b_isOpen;
+}
+void cConnection::slot_IP_Connected()
+{
+    connect(TcpSocket, SIGNAL(readyRead()), SLOT(slot_IP_ReadLine()));
+    connect(TcpSocket, SIGNAL(disconnected()),TcpSocket, SLOT(deleteLater()));
+    connect(TcpSocket, SIGNAL(disconnected()),this, SLOT(slot_IP_Disconnect()));
+//    emit sig_Connected();
+}
+void cConnection::slot_IP_Disconnect()
+{
+    disconnect(TcpSocket, SIGNAL(disconnected()), 0, 0);
+    disconnect(TcpSocket, SIGNAL(readyRead()), 0, 0);
+//    emit sig_Disconnected(1);
+}
+void cConnection::slot_IP_ReadLine()
+{
+    QString Input = QString(TcpSocket->readLine(TcpSocket->bytesAvailable())).remove(QChar(' '));
+    int Len = Input.length();
+    for (int z = 0; z < Len; z++)
+    {
+        if (Input[z] == '\r')
+        {
+            new_Data(QString(""));
+            RxData.String = QString("");
+        }
+        else
+        {
+            RxData.String = RxData.String + Input[z];
+        }
+    }
+}
 bool cConnection::send_Cmd(char CMD, int Address, char Data[150],unsigned int Length, bool Resend)
+{
     if (b_isOpen)
+    {
         QByteArray Temp;
         QString TX_Data;
         if (CMD != '#')
+        {
             TX_Data = ToolBox::Encode64(Data, Length);
             TX_Data = QString("#") + (QString('a' + Address)) + QString(CMD) + TX_Data;
             TX_Data = ToolBox::add_CRC(TX_Data) + '\r';
             if (Resend)
+            {
 //                LastSend = TX_Data;
 //                TickerEvent[0] = true;
+            }
             Temp = QByteArray(TX_Data.toUtf8());
+        }
         else
+        {
             for (unsigned int a = 0; a < Length; a++)
+            {
                 Temp[a] = Data[a];
+            }
+        }
+        switch(i_Type)
+        {
+            case C_TTY :
+            {
+                TTY->sendData(Temp);
+            }
+            break;
+            case C_IP :
+            {
+                TcpSocket->write(Temp);
+            }
+            break;
         TTY->sendData(Temp);
         emit(showTerminal(3, TX_Data));
+    }
     return true;
+}

Subversion Repositories Projects

(root)/QMK-Groundstation/trunk/Classes/cConnection.cpp - Rev 259 → 263