Home
last modified time | relevance | path

Searched refs:getRunningJobs (Results 1 – 17 of 17) sorted by relevance

/dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.runtime/tests/org.eclipse.core.tests.runtime/src/org/eclipse/core/tests/runtime/jobs/
H A DAbstractJobManagerTest.java59 protected List<Job> getRunningJobs(Object family) { in getRunningJobs() method in AbstractJobManagerTest
73 return getRunningJobs(null); in getJobs()
77 j.addAll(getRunningJobs(family)); in getJobs()
/dports/net-mgmt/nagios-check_bacula11/bacula-11.0.5/src/qt-console/tray-monitor/
H A Dresdetails-ui-controller.h60 Q_PROPERTY(QList<QObject *> runningJobs READ getRunningJobs NOTIFY runningJobsChanged())
179 QList<QObject *> getRunningJobs() { in getRunningJobs() function
/dports/sysutils/bacula11-client/bacula-11.0.5/src/qt-console/tray-monitor/
H A Dresdetails-ui-controller.h60 Q_PROPERTY(QList<QObject *> runningJobs READ getRunningJobs NOTIFY runningJobsChanged())
179 QList<QObject *> getRunningJobs() { in getRunningJobs() function
/dports/sysutils/bacula11-client-static/bacula-11.0.5/src/qt-console/tray-monitor/
H A Dresdetails-ui-controller.h60 Q_PROPERTY(QList<QObject *> runningJobs READ getRunningJobs NOTIFY runningJobsChanged())
179 QList<QObject *> getRunningJobs() { in getRunningJobs() function
/dports/sysutils/bacula11-server/bacula-11.0.5/src/qt-console/tray-monitor/
H A Dresdetails-ui-controller.h60 Q_PROPERTY(QList<QObject *> runningJobs READ getRunningJobs NOTIFY runningJobsChanged())
179 QList<QObject *> getRunningJobs() { in getRunningJobs() function
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/jobcontrol/
H A DTestJobControl.java110 + theControl.getRunningJobs().size()); in doJobControlTest()
129 + theControl.getRunningJobs().size()); in doJobControlTest()
H A DTestLocalJobControl.java119 LOG.debug("Jobs in running state: " + theControl.getRunningJobs().size()); in testLocalJobControlDataCopy()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/jobcontrol/
H A DJobControl.java60 public ArrayList<Job> getRunningJobs() { in getRunningJobs() method in JobControl
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/jobcontrol/
H A DTestJobControl.java119 + theControl.getRunningJobs().size()); in doJobControlTest()
138 + theControl.getRunningJobs().size()); in doJobControlTest()
H A DTestLocalJobControl.java119 LOG.debug("Jobs in running state: " + theControl.getRunningJobs().size()); in testLocalJobControlDataCopy()
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/jobcontrol/
H A DJobControl.java95 public ArrayList<Job> getRunningJobs() { in getRunningJobs() method in JobControl
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/capacity-scheduler/src/java/org/apache/hadoop/mapred/
H A DCapacityTaskScheduler.java304 for (JobInProgress j : queue.getRunningJobs()) { in getTaskFromQueue()
460 Collection<JobInProgress> runJobs = queue.getRunningJobs(); in printQueues()
1195 Collection<JobInProgress> runningJobs = queue.getRunningJobs(); in getJobs()
H A DCapacitySchedulerQueue.java625 Collection<JobInProgress> jobs = getRunningJobs(); // Safe to iterate since in updateAll()
802 synchronized Collection<JobInProgress> getRunningJobs() { in getRunningJobs() method in CapacitySchedulerQueue
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/capacity-scheduler/src/test/org/apache/hadoop/mapred/
H A DTestCapacityScheduler.java926 Collection<JobInProgress> rqueue = queue.getRunningJobs(); in testJobRunStateChange()
1038 : scheduler.jobQueuesManager.getQueue("default").getRunningJobs(); in getJobsInQueue()
2866 queue.getRunningJobs().contains(job)); in testFailedJobInitalizations()
2890 queue.getRunningJobs().contains(job)); in checkRunningJobMovementAndCompletion()
2915 queue.getRunningJobs().contains(job)); in checkRunningJobMovementAndCompletion()
2929 queue.getRunningJobs().contains(job)); in checkFailedRunningJobMovement()
2935 queue.getRunningJobs().contains(job)); in checkFailedRunningJobMovement()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/fairscheduler/src/java/org/apache/hadoop/mapred/
H A DFairSchedulerServlet.java332 Collection<JobInProgress> runningJobs = jobTracker.getRunningJobs(); in getInitedJobs()
/dports/devel/hadoop/hadoop-1.2.1/src/benchmarks/gridmix2/src/java/org/apache/hadoop/mapred/
H A DGridMixRunner.java619 + gridmix.getRunningJobs().size()); in run()
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/
H A DJobTracker.java2561 public synchronized List<JobInProgress> getRunningJobs() { in getRunningJobs() method in JobTracker