Home
last modified time | relevance | path

Searched refs:queueNames (Results 1 – 25 of 67) sorted by relevance

123

/dports/misc/molequeue/molequeue-0.9.0/molequeue/app/testing/
H A Dqueuemanagertest.cpp105 QStringList queueNames = list.keys(); in testToQueueList() local
106 qSort(queueNames); in testToQueueList()
107 QCOMPARE(queueNames.size(), 2); in testToQueueList()
108 QCOMPARE(queueNames[0], QString("First Queue")); in testToQueueList()
109 QCOMPARE(queueNames[1], QString("Second Queue")); in testToQueueList()
/dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/testing/
H A Dqueuemanagertest.cpp105 QStringList queueNames = list.keys(); in testToQueueList() local
106 qSort(queueNames); in testToQueueList()
107 QCOMPARE(queueNames.size(), 2); in testToQueueList()
108 QCOMPARE(queueNames[0], QString("First Queue")); in testToQueueList()
109 QCOMPARE(queueNames[1], QString("Second Queue")); in testToQueueList()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/capacity-scheduler/src/java/org/apache/hadoop/mapred/
H A DCapacityTaskScheduler.java693 Set<String> queueNames = queueManager.getQueues(); in refresh() local
704 initializationPoller.reinit(queueNames); in refresh()
833 Set<String> queueNames = queueManager.getQueues(); in start() local
834 initialize(queueManager, parseQueues(queueNames, schedConf), in start()
843 jobQueuesManager, schedConf, queueNames, taskTrackerManager); in start()
845 initializationPoller.init(queueNames.size(), schedConf); in start()
858 LOG.info("Capacity scheduler initialized " + queueNames.size() + " queues"); in start()
903 parseQueues(Collection<String> queueNames, CapacitySchedulerConf schedConf) in parseQueues() argument
909 if (0 == queueNames.size()) { in parseQueues()
914 for (String queueName: queueNames) { in parseQueues()
H A DJobInitializationPoller.java348 Collection<String> queueNames = jobQueueManager.getAllQueues(); in assignThreadsToQueues() local
349 int countOfQueues = queueNames.size(); in assignThreadsToQueues()
350 String[] queues = (String[]) queueNames.toArray( in assignThreadsToQueues()
/dports/net/google-cloud-sdk-app-engine-go/platform/google_appengine/goroot-1.9/src/appengine/taskqueue/
H A Dtaskqueue.go450 func QueueStats(c appengine.Context, queueNames []string, maxTasks int) ([]QueueStatistics, error) {
452 QueueName: make([][]byte, len(queueNames)),
454 for i, q := range queueNames {
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go447 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
449 QueueName: make([][]byte, len(queueNames)),
451 for i, q := range queueNames {
/dports/misc/molequeue/molequeue-0.9.0/molequeue/app/
H A Dqueuemanager.h111 QStringList queueNames() const in queueNames() function
/dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/
H A Dqueuemanager.h111 QStringList queueNames() const in queueNames() function
/dports/net/gscloud/gscloud-0.11.0/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/devel/git-town/git-town-7.6.0/vendor/google.golang.org/appengine/appengine-1.6.6/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/deskutils/pet/pet-0.4.0/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/security/vault/vault-1.8.2/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/security/lego/lego-4.5.3/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/mail/aerc/aerc-0.4.0/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/www/pomerium/pomerium-0.8.3/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/google.golang.org/appengine/appengine-1.5.0/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/sysutils/chezmoi/chezmoi-2.9.3/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/audio/gonic/gonic-0.8.4/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/www/beehive/beehive-0.4.0/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/google.golang.org/appengine/taskqueue/
H A Dtaskqueue.go492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) {
494 QueueName: make([][]byte, len(queueNames)),
496 for i, q := range queueNames {

123