diff options
author | Javier <dev.git@javispedro.com> | 2015-12-14 01:52:17 +0100 |
---|---|---|
committer | Javier <dev.git@javispedro.com> | 2015-12-14 01:52:17 +0100 |
commit | 702e018ca9e780bb076033ce5d1d370d4eb7319e (patch) | |
tree | 2012493213c630d7281718aadd1a6fa9a2c92885 /webproxyconn.cc | |
parent | ce8a092a235c8d59f01631c80786f920eb6a777b (diff) | |
download | sapd-702e018ca9e780bb076033ce5d1d370d4eb7319e.tar.gz sapd-702e018ca9e780bb076033ce5d1d370d4eb7319e.zip |
properly handle data frames with sequence numbers
Diffstat (limited to 'webproxyconn.cc')
-rw-r--r-- | webproxyconn.cc | 15 |
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"; |