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