1 files changed, 84 insertions, 0 deletions
diff --git a/examples/network/remotecontrol/ipcserver.cpp b/examples/network/remotecontrol/ipcserver.cpp
new file mode 100644
index 000000000..35595673f
--- /dev/null
+++ b/examples/network/remotecontrol/ipcserver.cpp
@@ -0,0 +1,84 @@
+#include "ipcserver.h"
+
+#include <qsocket.h>
+#include <qvariant.h>
+#include <qimage.h>
+#include <qpalette.h>
+#include <qapplication.h>
+
+class IpcSocket : public TQSocket
+{
+    Q_OBJECT
+
+public:
+    IpcSocket( TQObject *parent) : TQSocket( parent )
+    {
+	packetSize = 0;
+	connect( this, SIGNAL(readyRead()), SLOT(read()) );
+    }
+
+signals:
+    void receivedText( const TQString& );
+    void receivedPixmap( const TQPixmap& );
+
+private slots:
+    void read()
+    {
+	Q_ULONG bytesAvail = bytesAvailable();
+	for ( ;; ) {
+	    if ( packetSize == 0 ) {
+		TQDataStream ds( this );
+		if ( bytesAvail < 4 )
+		    return;
+		ds >> packetSize;
+		bytesAvail -= 4;
+	    } else {
+		if ( bytesAvail < packetSize )
+		    return;
+		// read the packet in a byte array to be sure that you don't
+		// read too much or too less
+		TQByteArray ba( packetSize );
+		readBlock( ba.data(), packetSize );
+		bytesAvail -= packetSize;
+		packetSize = 0;
+
+		TQVariant variant;
+		TQDataStream ds( ba, IO_ReadOnly );
+		ds >> variant;
+		switch ( variant.type() ) {
+		    case TQVariant::String:
+			emit receivedText( variant.toString() );
+			break;
+		    case TQVariant::Image:
+			emit receivedPixmap( TQPixmap(variant.toImage()) );
+			break;
+		    case TQVariant::Palette:
+			TQApplication::setPalette( variant.toPalette(), TRUE );
+			break;
+		    default:
+			break;
+		}
+	    }
+	}
+    }
+
+private:
+    Q_UINT32 packetSize;
+};
+
+IpcServer::IpcServer( Q_UINT16 port, TQObject *parent ) :
+    TQServerSocket( 0x7f000001, port, 1, parent )
+{
+}
+
+void IpcServer::newConnection( int socket )
+{
+    IpcSocket *s = new IpcSocket( this );
+    s->setSocket( socket );
+    connect( s, SIGNAL(receivedText(const TQString&)),
+	    SIGNAL(receivedText(const TQString&)) );
+    connect( s, SIGNAL(receivedPixmap(const TQPixmap&)),
+	    SIGNAL(receivedPixmap(const TQPixmap&)) );
+}
+
+#include "ipcserver.moc"