Changeset View
Changeset View
Standalone View
Standalone View
src/core/scheduler.cpp
Show First 20 Lines • Show All 687 Lines • ▼ Show 20 Line(s) | 665 | public: | |||
---|---|---|---|---|---|
688 | Slave *m_slaveOnHold; | 688 | Slave *m_slaveOnHold; | ||
689 | QUrl m_urlOnHold; | 689 | QUrl m_urlOnHold; | ||
690 | bool m_checkOnHold; | 690 | bool m_checkOnHold; | ||
691 | bool m_ignoreConfigReparse; | 691 | bool m_ignoreConfigReparse; | ||
692 | 692 | | |||
693 | SessionData sessionData; | 693 | SessionData sessionData; | ||
694 | 694 | | |||
695 | void doJob(SimpleJob *job); | 695 | void doJob(SimpleJob *job); | ||
696 | #ifndef KIOCORE_NO_DEPRECATED | | |||
697 | void scheduleJob(SimpleJob *job); | 696 | void scheduleJob(SimpleJob *job); | ||
698 | #endif | | |||
699 | void setJobPriority(SimpleJob *job, int priority); | 697 | void setJobPriority(SimpleJob *job, int priority); | ||
700 | void cancelJob(SimpleJob *job); | 698 | void cancelJob(SimpleJob *job); | ||
701 | void jobFinished(KIO::SimpleJob *job, KIO::Slave *slave); | 699 | void jobFinished(KIO::SimpleJob *job, KIO::Slave *slave); | ||
702 | void putSlaveOnHold(KIO::SimpleJob *job, const QUrl &url); | 700 | void putSlaveOnHold(KIO::SimpleJob *job, const QUrl &url); | ||
703 | void removeSlaveOnHold(); | 701 | void removeSlaveOnHold(); | ||
704 | Slave *getConnectedSlave(const QUrl &url, const KIO::MetaData &metaData); | 702 | Slave *getConnectedSlave(const QUrl &url, const KIO::MetaData &metaData); | ||
705 | bool assignJobToSlave(KIO::Slave *slave, KIO::SimpleJob *job); | 703 | bool assignJobToSlave(KIO::Slave *slave, KIO::SimpleJob *job); | ||
706 | bool disconnectSlave(KIO::Slave *slave); | 704 | bool disconnectSlave(KIO::Slave *slave); | ||
▲ Show 20 Lines • Show All 96 Lines • ▼ Show 20 Line(s) | |||||
803 | { | 801 | { | ||
804 | } | 802 | } | ||
805 | 803 | | |||
806 | void Scheduler::doJob(SimpleJob *job) | 804 | void Scheduler::doJob(SimpleJob *job) | ||
807 | { | 805 | { | ||
808 | schedulerPrivate()->doJob(job); | 806 | schedulerPrivate()->doJob(job); | ||
809 | } | 807 | } | ||
810 | 808 | | |||
811 | #ifndef KIOCORE_NO_DEPRECATED | | |||
812 | void Scheduler::scheduleJob(SimpleJob *job) | 809 | void Scheduler::scheduleJob(SimpleJob *job) | ||
813 | { | 810 | { | ||
814 | schedulerPrivate()->scheduleJob(job); | 811 | schedulerPrivate()->scheduleJob(job); | ||
815 | } | 812 | } | ||
816 | #endif | | |||
817 | 813 | | |||
818 | void Scheduler::setJobPriority(SimpleJob *job, int priority) | 814 | void Scheduler::setJobPriority(SimpleJob *job, int priority) | ||
819 | { | 815 | { | ||
820 | schedulerPrivate()->setJobPriority(job, priority); | 816 | schedulerPrivate()->setJobPriority(job, priority); | ||
821 | } | 817 | } | ||
822 | 818 | | |||
823 | void Scheduler::cancelJob(SimpleJob *job) | 819 | void Scheduler::cancelJob(SimpleJob *job) | ||
824 | { | 820 | { | ||
▲ Show 20 Lines • Show All 149 Lines • ▼ Show 20 Line(s) | 969 | if (mayReturnContent(jobCommand(job), jobPriv->m_protocol)) { | |||
974 | jobPriv->m_checkOnHold = m_checkOnHold; | 970 | jobPriv->m_checkOnHold = m_checkOnHold; | ||
975 | m_checkOnHold = false; | 971 | m_checkOnHold = false; | ||
976 | } | 972 | } | ||
977 | 973 | | |||
978 | ProtoQueue *proto = protoQ(jobPriv->m_protocol, job->url().host()); | 974 | ProtoQueue *proto = protoQ(jobPriv->m_protocol, job->url().host()); | ||
979 | proto->queueJob(job); | 975 | proto->queueJob(job); | ||
980 | } | 976 | } | ||
981 | 977 | | |||
982 | #ifndef KIOCORE_NO_DEPRECATED | | |||
983 | void SchedulerPrivate::scheduleJob(SimpleJob *job) | 978 | void SchedulerPrivate::scheduleJob(SimpleJob *job) | ||
984 | { | 979 | { | ||
985 | //qDebug() << job; | 980 | //qDebug() << job; | ||
986 | setJobPriority(job, 1); | 981 | setJobPriority(job, 1); | ||
987 | } | 982 | } | ||
988 | #endif | | |||
989 | 983 | | |||
990 | void SchedulerPrivate::setJobPriority(SimpleJob *job, int priority) | 984 | void SchedulerPrivate::setJobPriority(SimpleJob *job, int priority) | ||
991 | { | 985 | { | ||
992 | //qDebug() << job << priority; | 986 | //qDebug() << job << priority; | ||
993 | const QString protocol = SimpleJobPrivate::get(job)->m_protocol; | 987 | const QString protocol = SimpleJobPrivate::get(job)->m_protocol; | ||
994 | if (!protocol.isEmpty()) { | 988 | if (!protocol.isEmpty()) { | ||
995 | ProtoQueue *proto = protoQ(SimpleJobPrivate::get(job)->m_protocol, job->url().host()); | 989 | ProtoQueue *proto = protoQ(SimpleJobPrivate::get(job)->m_protocol, job->url().host()); | ||
996 | proto->changeJobPriority(job, priority); | 990 | proto->changeJobPriority(job, priority); | ||
▲ Show 20 Lines • Show All 332 Lines • Show Last 20 Lines |