summaryrefslogtreecommitdiff
path: root/webproxyconn.cc
diff options
context:
space:
mode:
authorJavier <dev.git@javispedro.com>2015-12-14 01:52:17 +0100
committerJavier <dev.git@javispedro.com>2015-12-14 01:52:17 +0100
commit702e018ca9e780bb076033ce5d1d370d4eb7319e (patch)
tree2012493213c630d7281718aadd1a6fa9a2c92885 /webproxyconn.cc
parentce8a092a235c8d59f01631c80786f920eb6a777b (diff)
downloadsapd-702e018ca9e780bb076033ce5d1d370d4eb7319e.tar.gz
sapd-702e018ca9e780bb076033ce5d1d370d4eb7319e.zip
properly handle data frames with sequence numbers
Diffstat (limited to 'webproxyconn.cc')
-rw-r--r--webproxyconn.cc15
1 files changed, 5 insertions, 10 deletions
diff --git a/webproxyconn.cc b/webproxyconn.cc
index d4fe6c7..ae75e1a 100644
--- a/webproxyconn.cc
+++ b/webproxyconn.cc
@@ -5,12 +5,12 @@
#include "webproxyconn.h"
WebProxyConn::WebProxyConn(SAPConnection *conn, QObject *parent)
- : QObject(parent), _conn(conn), _socket(conn->getSocket(501))
+ : QObject(parent), _conn(conn),
+ _in(conn->getSocket(501)), _out(conn->getSocket(502))
{
connect(_conn, SIGNAL(disconnected()), SLOT(deleteLater()));
- Q_ASSERT(_socket);
- connect(_socket, SIGNAL(connected()), SLOT(handleConnected()));
- connect(_socket, SIGNAL(messageReceived()), SLOT(handleMessageReceived()));
+ Q_ASSERT(_in && _out);
+ connect(_in, SIGNAL(messageReceived()), SLOT(handleMessageReceived()));
}
WebProxyConn::RequestMessage WebProxyConn::unpackRequestMessage(const QByteArray &data)
@@ -32,14 +32,9 @@ WebProxyConn::RequestMessage WebProxyConn::unpackRequestMessage(const QByteArray
return msg;
}
-void WebProxyConn::handleConnected()
-{
- qDebug() << "WebProxy socket now connected!";
-}
-
void WebProxyConn::handleMessageReceived()
{
- QByteArray data = _socket->receive();
+ QByteArray data = _in->receive();
qDebug() << data.toHex();
RequestMessage req = unpackRequestMessage(data);
qDebug() << "End of data";