summaryrefslogtreecommitdiffstats
path: root/kftpgrabber/src/engine/thread.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'kftpgrabber/src/engine/thread.cpp')
-rw-r--r--kftpgrabber/src/engine/thread.cpp70
1 files changed, 35 insertions, 35 deletions
diff --git a/kftpgrabber/src/engine/thread.cpp b/kftpgrabber/src/engine/thread.cpp
index 3e151b5..500d7bf 100644
--- a/kftpgrabber/src/engine/thread.cpp
+++ b/kftpgrabber/src/engine/thread.cpp
@@ -37,12 +37,12 @@
#include "ftpsocket.h"
#include "sftpsocket.h"
-#include <qapplication.h>
+#include <ntqapplication.h>
namespace KFTPEngine {
Thread::Thread()
- : QThread(),
+ : TQThread(),
m_eventHandler(new EventHandler(this)),
m_socket(0),
m_wakeupEvent(0),
@@ -76,7 +76,7 @@ Thread::~Thread()
void Thread::run()
{
while (!m_abortLoop) {
- QThread::usleep(100);
+ TQThread::usleep(100);
// "Poll" the socket
m_socket->poll();
@@ -96,8 +96,8 @@ void Thread::run()
if (!m_commandQueue.empty()) {
m_queueMutex.lock();
- QValueList<Commands::Type>::iterator queueEnd = m_commandQueue.end();
- for (QValueList<Commands::Type>::iterator i = m_commandQueue.begin(); i != queueEnd; ++i) {
+ TQValueList<Commands::Type>::iterator queueEnd = m_commandQueue.end();
+ for (TQValueList<Commands::Type>::iterator i = m_commandQueue.begin(); i != queueEnd; ++i) {
Commands::Type cmdType = *i;
// Execute the command
@@ -179,7 +179,7 @@ void Thread::run()
void Thread::wakeup(WakeupEvent *event)
{
- QMutexLocker locker(&m_wakeupMutex);
+ TQMutexLocker locker(&m_wakeupMutex);
m_wakeupEvent = event;
m_wakeUpPending = true;
@@ -189,7 +189,7 @@ void Thread::abort()
{
// Clear any pending wakeup events
if (m_wakeUpPending) {
- QMutexLocker locker(&m_wakeupMutex);
+ TQMutexLocker locker(&m_wakeupMutex);
m_wakeupEvent = 0;
m_wakeUpPending = false;
@@ -198,11 +198,11 @@ void Thread::abort()
m_socket->protoAbort();
}
-void Thread::event(Event::Type type, QValueList<EventParameter> params)
+void Thread::event(Event::Type type, TQValueList<EventParameter> params)
{
if (m_eventHandler) {
Event *e = new Event(type, params);
- qApp->postEvent(m_eventHandler, e);
+ tqApp->postEvent(m_eventHandler, e);
}
}
@@ -219,7 +219,7 @@ void Thread::selectSocketForProtocol(const KURL &url)
EventParameter Thread::nextCommandParameter()
{
- QMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker locker(&m_paramsMutex);
EventParameter param = m_commandParams.front();
m_commandParams.pop_front();
@@ -228,8 +228,8 @@ EventParameter Thread::nextCommandParameter()
void Thread::connect(const KURL &url)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
// Setup the correct socket to use for connection
selectSocketForProtocol(url);
@@ -240,16 +240,16 @@ void Thread::connect(const KURL &url)
void Thread::disconnect()
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdDisconnect);
}
void Thread::list(const KURL &url)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdList);
m_commandParams.append(EventParameter(url));
@@ -257,8 +257,8 @@ void Thread::list(const KURL &url)
void Thread::scan(const KURL &url)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdScan);
m_commandParams.append(EventParameter(url));
@@ -266,8 +266,8 @@ void Thread::scan(const KURL &url)
void Thread::get(const KURL &source, const KURL &destination)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdGet);
m_commandParams.append(EventParameter(destination));
@@ -276,8 +276,8 @@ void Thread::get(const KURL &source, const KURL &destination)
void Thread::put(const KURL &source, const KURL &destination)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdPut);
m_commandParams.append(EventParameter(destination));
@@ -286,8 +286,8 @@ void Thread::put(const KURL &source, const KURL &destination)
void Thread::remove(const KURL &url)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdDelete);
m_commandParams.append(EventParameter(url));
@@ -295,8 +295,8 @@ void Thread::remove(const KURL &url)
void Thread::rename(const KURL &source, const KURL &destination)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdRename);
m_commandParams.append(EventParameter(destination));
@@ -305,8 +305,8 @@ void Thread::rename(const KURL &source, const KURL &destination)
void Thread::chmod(const KURL &url, int mode, bool recursive)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdChmod);
m_commandParams.append(EventParameter(recursive));
@@ -316,17 +316,17 @@ void Thread::chmod(const KURL &url, int mode, bool recursive)
void Thread::mkdir(const KURL &url)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdMkdir);
m_commandParams.append(EventParameter(url));
}
-void Thread::raw(const QString &raw)
+void Thread::raw(const TQString &raw)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdRaw);
m_commandParams.append(EventParameter(raw));
@@ -334,8 +334,8 @@ void Thread::raw(const QString &raw)
void Thread::siteToSite(Thread *thread, const KURL &source, const KURL &destination)
{
- QMutexLocker locker(&m_paramsMutex);
- QMutexLocker lockerq(&m_queueMutex);
+ TQMutexLocker locker(&m_paramsMutex);
+ TQMutexLocker lockerq(&m_queueMutex);
m_commandQueue.append(Commands::CmdFxp);
m_commandParams.append(EventParameter(destination));
generated by cgit v1.2.1 (git 2.18.0) at 2024-05-30 14:23:20 +0000