diff options
author | tpearson <tpearson@283d02a7-25f6-0310-bc7c-ecb5cbfe19da> | 2010-02-24 02:13:59 +0000 |
---|---|---|
committer | tpearson <tpearson@283d02a7-25f6-0310-bc7c-ecb5cbfe19da> | 2010-02-24 02:13:59 +0000 |
commit | a6d58bb6052ac8cb01805a48c4ad2f129126116f (patch) | |
tree | dd867a099fcbb263a8009a9fb22695b87855dad6 /src/modules/dcc/thread.cpp | |
download | kvirc-a6d58bb6052ac8cb01805a48c4ad2f129126116f.tar.gz kvirc-a6d58bb6052ac8cb01805a48c4ad2f129126116f.zip |
Added KDE3 version of kvirc
git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/applications/kvirc@1095341 283d02a7-25f6-0310-bc7c-ecb5cbfe19da
Diffstat (limited to 'src/modules/dcc/thread.cpp')
-rw-r--r-- | src/modules/dcc/thread.cpp | 111 |
1 files changed, 111 insertions, 0 deletions
diff --git a/src/modules/dcc/thread.cpp b/src/modules/dcc/thread.cpp new file mode 100644 index 00000000..7ae38bbe --- /dev/null +++ b/src/modules/dcc/thread.cpp @@ -0,0 +1,111 @@ +// +// File : thread.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) 1999-2000 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 "thread.h" +#define _KVI_DEBUG_CHECK_RANGE_ +#include "kvi_debug.h" +#include "kvi_window.h" +#include "kvi_error.h" +#include "kvi_memmove.h" +#include "kvi_malloc.h" +#include "kvi_netutils.h" +#include "kvi_socket.h" +#ifdef COMPILE_SSL_SUPPORT + #include "kvi_sslmaster.h" +#endif + +KviDccThread::KviDccThread(QObject * par,kvi_socket_t fd) +: KviSensitiveThread() +{ + m_pParent = par; + m_fd = fd; + m_pMutex = new KviMutex(); +#ifdef COMPILE_SSL_SUPPORT +// debug("CLEARING SSL IN KviDccThread constructor"); + m_pSSL = 0; +#endif +} + +KviDccThread::~KviDccThread() +{ +#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); + __range_invalid(m_pMutex->locked()); + delete m_pMutex; +} + +#ifdef COMPILE_SSL_SUPPORT +void KviDccThread::setSSL(KviSSL * s) +{ + if(m_pSSL)KviSSLMaster::freeSSL(m_pSSL); + m_pSSL = s; +} +#endif + +bool KviDccThread::handleInvalidSocketRead(int readLen) +{ + __range_valid(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 KviDccThread::raiseSSLError() +{ + KviStr buffer; + while(m_pSSL->getLastErrorString(buffer)) + { + KviStr msg(KviStr::Format,"[SSL ERROR]: %s",buffer.ptr()); + postMessageEvent(msg.ptr()); + } +} +#endif + +void KviDccThread::postErrorEvent(int err) +{ + KviThreadDataEvent<int> * e = new KviThreadDataEvent<int>(KVI_DCC_THREAD_EVENT_ERROR); + e->setData(new int(err)); + postEvent(m_pParent,e); +} + +void KviDccThread::postMessageEvent(const char * message) +{ + KviThreadDataEvent<KviStr> * e = new KviThreadDataEvent<KviStr>(KVI_DCC_THREAD_EVENT_MESSAGE); + e->setData(new KviStr(message)); + postEvent(m_pParent,e); +} |