/dports/misc/molequeue/molequeue-0.9.0/molequeue/app/testing/ |
H A D | queuemanagertest.cpp | 105 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 D | queuemanagertest.cpp | 105 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 D | CapacityTaskScheduler.java | 693 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 D | JobInitializationPoller.java | 348 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 D | taskqueue.go | 450 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 D | taskqueue.go | 447 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 D | queuemanager.h | 111 QStringList queueNames() const in queueNames() function
|
/dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/ |
H A D | queuemanager.h | 111 QStringList queueNames() const in queueNames() function
|
/dports/net/gscloud/gscloud-0.11.0/vendor/google.golang.org/appengine/taskqueue/ |
H A D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 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 D | taskqueue.go | 492 func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) { 494 QueueName: make([][]byte, len(queueNames)), 496 for i, q := range queueNames {
|