Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.

BUG:215923


git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdenetwork@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da

1 files changed, 331 insertions, 0 deletions

diff --git a/kget/slave.cpp b/kget/slave.cpp
new file mode 100644
index 00000000..944a7f37
--- /dev/null
+++ b/kget/slave.cpp
@@ -0,0 +1,331 @@
+/***************************************************************************
+*                                slave.cpp
+*                             -------------------
+*
+*    Revision     : $Id$
+*    begin        : Tue Jan 29 2002
+*    copyright    : (C) 2002 by Patrick Charbonnier
+*                 : Based On Caitoo v.0.7.3 (c) 1998 - 2000, Matej Koss
+*    email        : [email protected]
+*
+****************************************************************************/
+
+/***************************************************************************
+ *
+ *   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 option) 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.
+ *
+ ***************************************************************************/
+
+
+#include <kapplication.h>
+#include <kio/scheduler.h>
+
+#include "getfilejob.h"
+#include "slave.h"
+#include "slaveevent.h"
+#include "transfer.h"
+
+#include <assert.h>
+
+Slave::Slave(Transfer * _parent, const KURL & _src, const KURL & _dest)
+    : QObject(),
+      QThread()
+{
+    mDebug << ">>>>Entering" << endl;
+    copyjob = NULL;
+    m_src = _src;
+    m_dest = _dest;
+    m_parent = _parent;
+
+    nPendingCommand = 0;
+
+    mDebug << ">>>>Leaving" << endl;
+}
+
+Slave::~Slave()
+{}
+
+void Slave::Op(SlaveCommand _cmd)
+{
+    mDebugIn << " _cmd = " << _cmd << endl;
+
+    if ( !running() ) // start on demand
+        start();
+
+    mutex.lock();
+    stack.push(_cmd);
+    nPendingCommand++;
+    worker.wakeOne();
+    mutex.unlock();
+
+    mDebugOut << endl;
+}
+
+/** No descriptions */
+void Slave::PostMessage(SlaveResult _event, Q_ULLONG _data)
+{
+    SlaveEvent *e1 = new SlaveEvent(m_parent, _event, _data);
+
+    QApplication::postEvent(kapp->mainWidget(), (QEvent *) e1);
+}
+
+void Slave::PostMessage(SlaveResult _event, const QString & _msg)
+{
+    SlaveEvent *e1 = new SlaveEvent(m_parent, _event, _msg);
+
+    QApplication::postEvent(kapp->mainWidget(), (QEvent *) e1);
+    mDebug << "Msg:" << "_msg = " << _msg << endl;
+}
+
+void Slave::InfoMessage(const QString & _msg)
+{
+    SlaveEvent *e1 = new SlaveEvent(m_parent, SLV_INFO, _msg);
+
+    QApplication::postEvent(kapp->mainWidget(), (QEvent *) e1);
+    mDebug << "Infor Msg:" << "_msg = " << _msg << endl;
+}
+
+
+
+void Slave::run()
+{
+    mDebugIn << endl;
+
+    SlaveCommand cmd;
+    bool running = true;
+
+    while (running) 
+    {
+        if (!nPendingCommand)
+            worker.wait();
+        switch (cmd = fetch_cmd()) 
+        {
+            case RESTART:
+                if (copyjob) {
+                    copyjob->kill(true);
+                    copyjob = 0L;
+                }
+                // fall through
+            case RETR:
+                mDebug << " FETCHED COMMAND       RETR" << endl;
+                assert(!copyjob);
+                KIO::Scheduler::checkSlaveOnHold( true );
+                copyjob = new KIO::GetFileJob(m_src, m_dest);
+                Connect();
+                PostMessage(SLV_RESUMED);
+                break;
+
+            case RETR_CACHE:
+                mDebug << " FETCHED COMMAND       RETR_CACHE" << endl;
+                assert(!copyjob);
+                KIO::Scheduler::checkSlaveOnHold( true );
+                copyjob = new KIO::GetFileJob(m_src, m_dest);
+                copyjob->addMetaData("cache", "cacheonly");
+                Connect();
+                break;
+
+            case PAUSE:
+                mDebug << " FETCHED COMMAND       PAUSE" << endl;
+                if (copyjob) {
+                    copyjob->kill(true);
+                    copyjob = 0L;
+                }
+                PostMessage(SLV_PAUSED);
+                break;
+
+            case KILL:
+                mDebug << " FETCHED COMMAND      KILL" << endl;
+                running = false;
+                if (copyjob) {
+                    copyjob->kill(true);
+                    copyjob = 0L;
+                 }
+                // no message posted
+                break;
+            
+            case REMOVE:
+                mDebug << " FETCHED COMMAND       REMOVE" << endl;
+                running = false;
+                if (copyjob) {
+                    copyjob->kill(true);
+                    copyjob = 0L;
+                }
+                PostMessage(SLV_REMOVED);
+                break;
+
+            case SCHEDULE:
+                mDebug << " FETCHED COMMAND       SCHEDULE" << endl;
+                if (copyjob) {
+                    copyjob->kill(true);
+                    copyjob = 0L;
+                }
+                PostMessage(SLV_SCHEDULED);
+                break;
+
+            case DELAY:
+                mDebug << " FETCHED COMMAND       DELAY" << endl;
+                if (copyjob) {
+                    copyjob->kill(true);
+                    copyjob = 0L;
+                }
+                PostMessage(SLV_DELAYED);
+                break;
+
+            case NOOP:
+                mDebug << "FETCHED COMMAND        NOOP, i.e. empty stack" << endl;
+                if (copyjob) {
+                    copyjob->kill(true);
+                    copyjob = 0L;
+                }
+                running = false;
+                break;
+
+            default:
+                mDebug << " UNKNOWN COMMAND DIE...." << endl;
+                assert(0);
+        }
+    }
+
+    assert(!copyjob);
+    mDebugOut << endl;
+}
+
+
+Slave::SlaveCommand Slave::fetch_cmd()
+{
+    mutex.lock();
+    SlaveCommand cmd = NOOP;
+    if ( !stack.isEmpty() )
+    {
+        nPendingCommand--;
+        cmd = stack.pop();
+    }
+    mutex.unlock();
+    return cmd;
+}
+
+
+void Slave::Connect()
+{
+    mDebugIn << endl;
+
+
+    connect(copyjob, SIGNAL(canceled(KIO::Job *)), SLOT(slotCanceled(KIO::Job *)));
+    connect(copyjob, SIGNAL(connected(KIO::Job *)), SLOT(slotConnected(KIO::Job *)));
+    connect(copyjob, SIGNAL(result(KIO::Job *)), SLOT(slotResult(KIO::Job *)));
+
+    connect(copyjob, SIGNAL(totalSize(KIO::Job *, KIO::filesize_t)), SLOT(slotTotalSize(KIO::Job *, KIO::filesize_t)));
+
+    connect(copyjob, SIGNAL(processedSize(KIO::Job *, KIO::filesize_t)), SLOT(slotProcessedSize(KIO::Job *, KIO::filesize_t)));
+
+    connect(copyjob, SIGNAL(speed(KIO::Job *, unsigned long)), SLOT(slotSpeed(KIO::Job *, unsigned long)));
+
+    connect(copyjob, SIGNAL(infoMessage(KIO::Job *, const QString &)), SLOT(slotInfoMessage(KIO::Job *, const QString &)));
+
+    mDebugOut << endl;
+}
+
+
+void Slave::slotCanceled(KIO::Job *)
+{
+    mDebugIn << endl;
+
+
+    mDebugOut << endl;
+}
+
+void Slave::slotConnected(KIO::Job *)
+{
+    mDebugIn << endl;
+
+
+    mDebugOut << endl;
+}
+
+void Slave::slotResult(KIO::Job * job)
+{
+    mDebugIn << endl;
+    
+    assert(copyjob == job);
+    copyjob=0L;
+    KIO::Error error=KIO::Error(job->error());
+    if (!error) {
+        PostMessage(SLV_FINISHED);
+    }
+    else {
+        if (m_parent->getMode() == Transfer::MD_NEW)
+        {
+            PostMessage(SLV_NOTINCACHE);
+            return;
+        }
+        QString tmsg="<font color=\"red\"> <b>" + job->errorString() + \
+                "</b></font>";
+        InfoMessage(tmsg);
+        if (m_parent->retryOnError() && \
+            ((error==KIO::ERR_COULD_NOT_LOGIN) || (error==KIO::ERR_SERVER_TIMEOUT))) {
+            //Timeout or login error
+            PostMessage(SLV_ERROR);
+        }
+        else if (m_parent->retryOnBroken() && (error==KIO::ERR_CONNECTION_BROKEN)) {
+            // Connection Broken
+            PostMessage(SLV_BROKEN);
+        }
+        else {
+            job->showErrorDialog();
+            PostMessage(SLV_DELAYED);
+        }
+    }
+    mDebugOut << endl;
+}
+
+
+void Slave::slotSpeed(KIO::Job *, unsigned long lSpeed)
+{
+    // mDebugIn<<endl;
+    PostMessage(SLV_PROGRESS_SPEED, lSpeed);
+    // mDebugOut<<endl;
+
+}
+
+void Slave::slotTotalSize(KIO::Job *, KIO::filesize_t _total_size)
+{
+    mDebugIn << "= " << _total_size << endl;
+
+    if ((int)_total_size == 0)//shouldn't happen, but does
+        return;
+
+    if (m_parent->getMode() != Transfer::MD_NEW)
+    {
+    PostMessage(SLV_CAN_RESUME, copyjob->getCanResume());
+    PostMessage(SLV_CONNECTED);
+    }
+    else
+        InfoMessage("checking if file is in cache...yes");
+    PostMessage(SLV_TOTAL_SIZE, _total_size);
+    mDebugOut << endl;
+}
+
+void Slave::slotProcessedSize(KIO::Job *, KIO::filesize_t _processed_size)
+{
+    // mDebugIn<<endl;
+    PostMessage(SLV_PROGRESS_SIZE, _processed_size);
+
+    // mDebugOut<<endl;
+}
+
+void Slave::slotInfoMessage(KIO::Job *, const QString & _msg)
+{
+    mDebugIn << "MSG=" << _msg << endl;
+    InfoMessage(_msg);
+    mDebugOut << endl;
+}
+
+#include "slave.moc"