setup

libptsocket/ptserver.cpp

@@ -1,6 +1,12 @@
 #include "ptserver.h"
 
-PTServer::PTServer(QObject *parent) :
-	QObject(parent)
+PTServer::PTServer(QObject *parent) : QTcpServer(parent)
 {
+	connect(this, SIGNAL(newConnection()), this, SLOT(m_newConnection()));
+}
+
+void PTServer::m_newConnection()
+{
+	PTSocket* client = dynamic_cast<PTSocket*>(nextPendingConnection());
+	m_tempClients.append(client);
 }

libptsocket/ptserver.h

@@ -3,16 +3,28 @@
 
 #include "libptsocket_global.h"
 #include <QObject>
+#include <QTcpServer>
+#include <QTcpSocket>
+#include <QHostAddress>
+#include "ptsocket.h"
 
-class LIBPTSOCKETSHARED_EXPORT PTServer : public QObject
+class LIBPTSOCKETSHARED_EXPORT PTServer : public QTcpServer
 {
 	Q_OBJECT
 public:
 	explicit PTServer(QObject *parent = 0);
-	
+
 signals:
+	void newClient(PTSocket*);
 	
 public slots:
+
+private slots:
+	void m_newConnection();
+
+private:
+	QList<PTSocket*> m_tempClients;
+	QList<PTSocket*> m_clients;
 	
 };
 

libptsocket/ptsocket.cpp

@@ -1,6 +1,57 @@
 #include "ptsocket.h"
 
 
-PTSocket::PTSocket()
+PTSocket::PTSocket(QObject* p) : QTcpSocket(p)
 {
+	m_hasHandshaked = false;
+	m_timeout = 5000;
+	connect(&m_timeoutTimer, SIGNAL(timeout()), this, SLOT(m_handshakeError()));
+	connect(this, SIGNAL(readyRead()), this, SLOT(m_readyRead()));
+}
+
+int PTSocket::getTimeout() const
+{
+	return m_timeout;
+}
+
+QByteArray PTSocket::handshakeData() const
+{
+	return "LibPTSocket";
+}
+
+void PTSocket::handshake()
+{
+	write(handshakeData());
+}
+
+void PTSocket::setTimeout(int t)
+{
+	m_timeout = t;
+}
+
+void PTSocket::m_readyRead()
+{
+	if(m_hasHandshaked)
+	{
+
+	}
+	else
+	{
+		QByteArray handshake = handshakeData();
+		if(bytesAvailable() >= handshake.size())
+		{
+			QByteArray data = read(handshake.size());
+			if(data == handshake)
+			{
+				m_hasHandshaked = true;
+			}
+			else
+				m_handshakeError();
+		}
+	}
+}
+
+void PTSocket::m_handshakeError()
+{
+
 }

libptsocket/ptsocket.h

@@ -3,12 +3,30 @@
 
 #include "libptsocket_global.h"
 #include <QObject>
+#include <QTcpSocket>
+#include <QTimer>
 
-class LIBPTSOCKETSHARED_EXPORT PTSocket : public QObject
+class LIBPTSOCKETSHARED_EXPORT PTSocket : public QTcpSocket
 {
 	Q_OBJECT
 public:
-	PTSocket();
+	PTSocket(QObject* p);
+	int getTimeout() const;
+
+	static QByteArray handshakeData() const;
+
+public slots:
+	void handshake();
+	void setTimeout(int t);
+
+private slots:
+	void m_readyRead();
+	void m_handshakeError();
+
+private:
+	bool m_hasHandshaked;
+	QTimer m_timeoutTimer;
+	int m_timeout;
 };
 
 #endif // PTSOCKET_H

tests/main.cpp

@@ -1,8 +1,13 @@
 #include <QCoreApplication>
 
+#include "test.h"
+
 int main(int argc, char *argv[])
 {
 	QCoreApplication a(argc, argv);
+	Test t;
+	t.testListen(6950);
+	t.testNewConnection();
 	
 	return a.exec();
 }

tests/test.cpp

@@ -0,0 +1,31 @@
+#include "test.h"
+
+Test::Test(QObject *parent) : QObject(parent)
+{
+	m_serv = new PTServer(this);
+	connect(m_serv, SIGNAL(newConnection()), this, SLOT(m_newConnection()));
+	connect(m_serv, SIGNAL(newClient(PTSocket*)), this, SLOT(m_newClient(PTSocket*)));
+}
+
+void Test::testListen(quint16 p)
+{
+	Q_ASSERT(m_serv->listen(QHostAddress::Any, p));
+}
+
+void Test::testNewConnection()
+{
+	ASSERT_LISTEN;
+	PTSocket* sock = new PTSocket(this);
+	m_clients.append(sock);
+	sock->connectToHost("127.0.0.1", m_serv->serverPort());
+}
+
+void Test::m_newConnection()
+{
+	qDebug()<<"New socket";
+}
+
+void Test::m_newClient(PTSocket* s)
+{
+	qDebug()<<"New client:"<<s->peerAddress()<<s->peerPort();
+}

tests/test.h

@@ -0,0 +1,32 @@
+#ifndef TEST_H
+#define TEST_H
+
+#include <QObject>
+#include "ptserver.h"
+#include "ptsocket.h"
+#include <QDebug>
+
+#define ASSERT_LISTEN Q_ASSERT(m_serv->isListening())
+
+class Test : public QObject
+{
+	Q_OBJECT
+public:
+	explicit Test(QObject *parent = 0);
+	
+signals:
+	
+public slots:
+	void testListen(quint16 p);
+	void testNewConnection();
+
+private slots:
+	void m_newConnection();
+	void m_newClient(PTSocket* s);
+
+private:
+	PTServer* m_serv;
+	QList<PTSocket*> m_clients;
+};
+
+#endif // TEST_H

tests/tests.pro

@@ -4,7 +4,7 @@
 #
 #-------------------------------------------------
 
-QT       += core
+QT       += core network
 
 QT       -= gui
 
@@ -15,4 +15,15 @@ CONFIG   -= app_bundle
 TEMPLATE = app
 
 
-SOURCES += main.cpp
+SOURCES += main.cpp \
+    test.cpp
+
+win32:CONFIG(release, debug|release): LIBS += -L$$OUT_PWD/../libptsocket/release/ -llibptsocket
+else:win32:CONFIG(debug, debug|release): LIBS += -L$$OUT_PWD/../libptsocket/debug/ -llibptsocket
+else:unix:!macx: LIBS += -L$$OUT_PWD/../libptsocket/ -llibptsocket
+
+INCLUDEPATH += $$PWD/../libptsocket
+DEPENDPATH += $$PWD/../libptsocket
+
+HEADERS += \
+    test.h