scheduler.h

konqueror3 embedded版本, KDE环境下的当家浏览器的嵌入式版本源码包.

/*  This file is part of the KDE project
    Copyright (C) 2000-2001 Simon Hausmann <[e-mail]>
    Copyright (C) 2001 Dirk Mueller <[e-mail]>

    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Library General Public
    License as published by the Free Software Foundation; either
    version 2 of the License, or (at your option) any later version.

    This library 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
    Library General Public License for more details.

    You should have received a copy of the GNU Library General Public License
    along with this library; see the file COPYING.LIB.  If not, write to
    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
    Boston, MA 02110-1301, USA.
*/
#ifndef __kio_scheduler_h__
#define __kio_scheduler_h__

#include <qobject.h>
#include <qdict.h>
#include <qtimer.h>
#include <qptrlist.h>
#include <qcstring.h>

#define SAM_MAX_TASKS 6

namespace KIO
{
    class SimpleJob;
    class Slave;

    class Scheduler : public QObject
    {
        Q_OBJECT
    public:
        Scheduler();
        virtual ~Scheduler();

        bool doJob( SimpleJob *job );

        void releaseJob( SimpleJob *job, bool killSlave = false );

        // ### check if this is correct
        void _scheduleJob( SimpleJob * );
        static void scheduleJob(SimpleJob* );

        static Scheduler *self();

    private slots:
        void slotStep();

    private:
        struct JobInfo
        {
            JobInfo(SimpleJob* job);
            
            SimpleJob* m_job;
            // is this a job that has scheduleJob() been called on?
            bool m_scheduled;
        };
                
        struct ProtocolInfo
        {
            ProtocolInfo();
	    ~ProtocolInfo();

#if QT_VERSION < 300            
            QList<JobInfo> m_jobs;
#else            
            QPtrList<JobInfo> m_jobs;
#endif            
            bool m_running[SAM_MAX_TASKS];
            Slave *m_slaves[SAM_MAX_TASKS];
            QCString m_slavehost[SAM_MAX_TASKS];
	    int m_running_cnt;
        };

        void doStep( ProtocolInfo *nfo );
        static void debugInfo(ProtocolInfo* info);

        void startJobSlaveTask(ProtocolInfo* nfo, SimpleJob* job, int task);

        void killSlave( ProtocolInfo *nfo, int task = -1 );

        QTimer m_timer;
        QDict<ProtocolInfo> m_schedule;
        static Scheduler *s_self;
    };

}

#endif