6 files changed, 92 insertions, 0 deletions

diff --git a/c++-qt/src/gatsstream.cpp b/c++-qt/src/gatsstream.cpp
index ae53d0d..3874de2 100644
--- a/c++-qt/src/gatsstream.cpp
+++ b/c++-qt/src/gatsstream.cpp
@@ -62,6 +62,9 @@ Gats::Object *Gats::GatsStream::readObject()
         rTmp.open( QIODevice::ReadOnly );
         rTmp.seek( 5 );
         Gats::Object *pObj = Gats::Object::read( rTmp );
+        qbRead.clear();
+
+        emit objectRead( pObj );
 
         return pObj;
 }
diff --git a/c++-qt/src/gatsstream.h b/c++-qt/src/gatsstream.h
index 3cf1081..f1c0625 100644
--- a/c++-qt/src/gatsstream.h
+++ b/c++-qt/src/gatsstream.h
@@ -15,6 +15,7 @@ namespace Gats
                 GatsStream( QIODevice &rStream );
                 virtual ~GatsStream();
 
+        public slots:
                 /**
                  * Read an object packet from the assosiated stream.  This will make
                  * every effort to only read exactly enough data to describe one packet,
@@ -32,6 +33,7 @@ namespace Gats
                  */
                 Gats::Object *readObject();
 
+        public:
                 /**
                  * Write an object 
                  */
@@ -45,6 +47,11 @@ namespace Gats
                 bool hasReadBuffer() { return qbRead.size() > 0; }
                 int getReadBufferSize() { return qbRead.size(); }
 
+                QIODevice &getIODevice() { return rStream; }
+
+        signals:
+                void objectRead( Gats::Object *pObj );
+
         private:
                 bool skipReadNulls();
 
diff --git a/c++-qt/tests/echo/echo.pro b/c++-qt/tests/echo/echo.pro
new file mode 100644
index 0000000..63c741a
--- /dev/null
+++ b/c++-qt/tests/echo/echo.pro
@@ -0,0 +1,15 @@
+######################################################################
+# Automatically generated by qmake (2.01a) Fri Apr 6 00:45:00 2012
+######################################################################
+
+TEMPLATE = app
+TARGET = 
+DEPENDPATH += .
+INCLUDEPATH += . ../..
+QT += network
+
+LIBS += -L../.. -lgats-qt
+
+# Input
+SOURCES += main.cpp mainwnd.cpp
+HEADERS += mainwnd.h
diff --git a/c++-qt/tests/echo/main.cpp b/c++-qt/tests/echo/main.cpp
new file mode 100644
index 0000000..43ceae4
--- /dev/null
+++ b/c++-qt/tests/echo/main.cpp
@@ -0,0 +1,14 @@
+#include <QApplication>
+
+#include "mainwnd.h"
+
+int main( int argc, char *argv[] )
+{
+        QApplication app( argc, argv );
+
+        MainWnd wnd;
+        wnd.show();
+
+        return app.exec();
+}
+
diff --git a/c++-qt/tests/echo/mainwnd.cpp b/c++-qt/tests/echo/mainwnd.cpp
new file mode 100644
index 0000000..4b90421
--- /dev/null
+++ b/c++-qt/tests/echo/mainwnd.cpp
@@ -0,0 +1,30 @@
+#include "mainwnd.h"
+
+MainWnd::MainWnd()
+{
+        pSrv = new QTcpServer( this );
+        connect( pSrv, SIGNAL(newConnection()), this, SLOT(newConnection()));
+        pSrv->listen( QHostAddress::Any, 7317 );
+}
+
+MainWnd::~MainWnd()
+{
+}
+
+void MainWnd::newConnection()
+{
+        while( pSrv->hasPendingConnections() )
+        {
+                QTcpSocket *pSock = pSrv->nextPendingConnection();
+                Gats::GatsStream *pGats = new Gats::GatsStream( *pSock );
+                connect( pSock, SIGNAL(readyRead()), pGats, SLOT(readObject()) );
+                connect( pGats, SIGNAL(objectRead( Gats::Object * )),
+                        this, SLOT(objectRead( Gats::Object * )));
+        }
+}
+
+void MainWnd::objectRead( Gats::Object *pObj )
+{
+        ((Gats::GatsStream *)sender())->writeObject( pObj );
+        delete pObj;
+}
diff --git a/c++-qt/tests/echo/mainwnd.h b/c++-qt/tests/echo/mainwnd.h
new file mode 100644
index 0000000..0afbd6a
--- /dev/null
+++ b/c++-qt/tests/echo/mainwnd.h
@@ -0,0 +1,23 @@
+
+#include <QTcpServer>
+#include <QTcpSocket>
+#include <QMainWindow>
+
+#include "gats-qt/gatsstream.h"
+#include "gats-qt/types.h"
+
+class MainWnd : public QMainWindow
+{
+        Q_OBJECT;
+public:
+        QTcpServer *pSrv;
+
+        MainWnd();
+        virtual ~MainWnd();
+
+public slots:
+        void newConnection();
+        void objectRead( Gats::Object *pObj );
+
+signals:
+};