Many changes: tabconv'd the C++ code, added a license, BSD, and docs.

1 files changed, 60 insertions, 53 deletions

diff --git a/c++-libbu++/src/gatscon/proxythread.cpp b/c++-libbu++/src/gatscon/proxythread.cpp
index 574b56b..733af7f 100644
--- a/c++-libbu++/src/gatscon/proxythread.cpp
+++ b/c++-libbu++/src/gatscon/proxythread.cpp
@@ -1,3 +1,10 @@
+/*
+ * Copyright (C) 2007-2012 Xagasoft, All rights reserved.
+ *
+ * This file is part of the libgats library and is released under the
+ * terms of the license contained in the file LICENSE.
+ */
+
 #include "proxythread.h"
 
 #include <gats/types.h>
@@ -10,15 +17,15 @@
 using namespace Bu;
 
 ProxyThread::ProxyThread( QObject *pParent, int iPortIn,
-                const QByteArray &baHostOut, int iPortOut ) :
-        QThread( pParent ),
-        pHost( NULL ),
-        iPortIn( iPortIn ),
-        baHostOut( baHostOut ),
-        iPortOut( iPortOut ),
-        gsCli( ssCli )
+        const QByteArray &baHostOut, int iPortOut ) :
+    QThread( pParent ),
+    pHost( NULL ),
+    iPortIn( iPortIn ),
+    baHostOut( baHostOut ),
+    iPortOut( iPortOut ),
+    gsCli( ssCli )
 {
-        pHost = new ProxyHostThread( pParent, this );
+    pHost = new ProxyHostThread( pParent, this );
 }
 
 ProxyThread::~ProxyThread()
@@ -27,52 +34,52 @@ ProxyThread::~ProxyThread()
 
 void ProxyThread::send( Gats::Object *pObj )
 {
-        MemBuf bg;
-        Gats::GatsStream gs( bg );
-        gs.writeObject( pObj );
-        ssCli.write( bg.getString().getStr(), bg.getString().getSize() );
+    MemBuf bg;
+    Gats::GatsStream gs( bg );
+    gs.writeObject( pObj );
+    ssCli.write( bg.getString().getStr(), bg.getString().getSize() );
 }
 
 void ProxyThread::run()
 {
-        int iSockIn;
+    int iSockIn;
 
-        {
-                TcpServerSocket tsIn( iPortIn );
-                do
-                {
-                        iSockIn = tsIn.accept( 5 );
-                } while( iSockIn < 0 );
-        }
+    {
+        TcpServerSocket tsIn( iPortIn );
+        do
+        {
+            iSockIn = tsIn.accept( 5 );
+        } while( iSockIn < 0 );
+    }
 
-        emit gotConnection();
+    emit gotConnection();
 
-        ssCli.setStream( new TcpSocket( iSockIn ) );
-        ssCli.setBlocking( true );
+    ssCli.setStream( new TcpSocket( iSockIn ) );
+    ssCli.setBlocking( true );
 
-        pHost->setStream(
-                new TcpSocket( baHostOut.constData(), iPortOut )
-                );
+    pHost->setStream(
+        new TcpSocket( baHostOut.constData(), iPortOut )
+        );
 
-        pHost->start();
+    pHost->start();
 
-        while( !ssCli.isEos() )
-        {
-                Gats::Object *pObj = gsCli.readObject();
-                if( pObj == NULL )
-                        continue;
+    while( !ssCli.isEos() )
+    {
+        Gats::Object *pObj = gsCli.readObject();
+        if( pObj == NULL )
+            continue;
 
-                pHost->send( pObj );
-                emit recv( pObj );
-        }
+        pHost->send( pObj );
+        emit recv( pObj );
+    }
 
 }
 
 ProxyHostThread::ProxyHostThread( QObject *pParent, ProxyThread *pClient ) :
-        QThread( pParent ),
-        pClient( pClient ),
-        ssHst(),
-        gsHst( ssHst )
+    QThread( pParent ),
+    pClient( pClient ),
+    ssHst(),
+    gsHst( ssHst )
 {
 }
 
@@ -82,27 +89,27 @@ ProxyHostThread::~ProxyHostThread()
 
 void ProxyHostThread::send( Gats::Object *pObj )
 {
-        MemBuf bg;
-        Gats::GatsStream gs( bg );
-        gs.writeObject( pObj );
-        ssHst.write( bg.getString().getStr(), bg.getString().getSize() );
+    MemBuf bg;
+    Gats::GatsStream gs( bg );
+    gs.writeObject( pObj );
+    ssHst.write( bg.getString().getStr(), bg.getString().getSize() );
 }
 
 void ProxyHostThread::setStream( Bu::Stream *pStr )
 {
-        ssHst.setStream( pStr );
+    ssHst.setStream( pStr );
 }
 
 void ProxyHostThread::run()
 {
-        while( !ssHst.isEos() )
-        {
-                Gats::Object *pObj = gsHst.readObject();
-                if( pObj == NULL )
-                        continue;
-
-                pClient->send( pObj );
-                emit recv( pObj );
-        }
+    while( !ssHst.isEos() )
+    {
+        Gats::Object *pObj = gsHst.readObject();
+        if( pObj == NULL )
+            continue;
+
+        pClient->send( pObj );
+        emit recv( pObj );
+    }
 }