1 files changed, 114 insertions, 0 deletions
diff --git a/src/modules/dcc/DccThread.cpp b/src/modules/dcc/DccThread.cpp
new file mode 100644
index 000000000..adc8dc1c2
--- /dev/null
+++ b/src/modules/dcc/DccThread.cpp
@@ -0,0 +1,114 @@
+//=============================================================================
+//
+//   File : DccThread.cpp
+//   Creation date : Tue Sep 20 09 2000 18:29:51 CEST Szymon Stefanek
+//
+//   This file is part of the KVIrc irc client distribution
+//   Copyright (C) 2000-2010 Szymon Stefanek (pragma at kvirc dot net)
+//
+//   This program is FREE software. You can redistribute it and/or
+//   modify it under the terms of the GNU General Public License
+//   as published by the Free Software Foundation; either version 2
+//   of the License, or (at your opinion) any later version.
+//
+//   This program is distributed in the HOPE that it will be USEFUL,
+//   but WITHOUT ANY WARRANTY; without even the implied warranty of
+//   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+//   See the GNU General Public License for more details.
+//
+//   You should have received a copy of the GNU General Public License
+//   along with this program. If not, write to the Free Software Foundation,
+//   Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+//
+//=============================================================================
+
+#include "DccThread.h"
+
+#include "kvi_debug.h"
+#include "KviWindow.h"
+#include "KviError.h"
+#include "KviMemory.h"
+#include "KviMemory.h"
+#include "KviNetUtils.h"
+#include "kvi_socket.h"
+
+#ifdef COMPILE_SSL_SUPPORT
+	#include "KviSSLMaster.h"
+#endif
+
+DccThread::DccThread(QObject * par,kvi_socket_t fd)
+: KviSensitiveThread()
+{
+	m_pParent     = par;
+	m_fd          = fd;
+	m_pMutex      = new KviMutex();
+#ifdef COMPILE_SSL_SUPPORT
+//	qDebug("CLEARING SSL IN DccThread constructor");
+	m_pSSL        = 0;
+#endif
+}
+
+DccThread::~DccThread()
+{
+#ifdef COMPILE_SSL_SUPPORT
+	if(m_pSSL)KviSSLMaster::freeSSL(m_pSSL);
+	m_pSSL = 0;
+#endif
+	if(m_fd != KVI_INVALID_SOCKET)kvi_socket_close(m_fd);
+	KVI_ASSERT(!m_pMutex->locked());
+	delete m_pMutex;
+}
+
+#ifdef COMPILE_SSL_SUPPORT
+void DccThread::setSSL(KviSSL * s)
+{
+	if(m_pSSL)KviSSLMaster::freeSSL(m_pSSL);
+	m_pSSL = s;
+}
+#endif
+
+bool DccThread::handleInvalidSocketRead(int readLen)
+{
+	KVI_ASSERT(readLen < 1);
+	if(readLen == 0)
+	{
+		// connection closed
+		postErrorEvent(KviError::RemoteEndClosedConnection);
+		return false;
+	} else {
+		// error ?
+		int err = kvi_socket_error();
+		if((err != EINTR) && (err != EAGAIN))
+		{
+			postErrorEvent(KviError::translateSystemError(err));
+			return false;
+		}
+	}
+	return true; // continue
+}
+
+#ifdef COMPILE_SSL_SUPPORT
+void DccThread::raiseSSLError()
+{
+	KviCString buffer;
+	while(m_pSSL->getLastErrorString(buffer))
+	{
+		KviCString msg(KviCString::Format,"[SSL ERROR]: %s",buffer.ptr());
+		postMessageEvent(msg.ptr());
+	}
+}
+#endif
+
+void DccThread::postErrorEvent(int err)
+{
+	KviThreadDataEvent<int> * e = new KviThreadDataEvent<int>(KVI_DCC_THREAD_EVENT_ERROR);
+	e->setData(new int(err));
+	postEvent(m_pParent,e);
+}
+
+void DccThread::postMessageEvent(const char * message)
+{
+	KviThreadDataEvent<KviCString> * e = new KviThreadDataEvent<KviCString>(KVI_DCC_THREAD_EVENT_MESSAGE);
+	e->setData(new KviCString(message));
+	postEvent(m_pParent,e);
+}