| /dports/astro/marble/marble-21.12.3/src/lib/marble/ |
| H A D | HttpDownloadManager.cpp | 130 DownloadQueueSet * const queueSet = new DownloadQueueSet( policy, this ); in addDownloadPolicy() local
131 d->connectQueueSet( queueSet ); in addDownloadPolicy()
133 ( queueSet->downloadPolicy().key(), queueSet )); in addDownloadPolicy()
144 DownloadQueueSet * const queueSet = d->findQueues( sourceUrl.host(), usage ); in addJob() local
145 if ( queueSet->canAcceptJob( sourceUrl, destFileName )) { in addJob()
150 queueSet->addJob( job ); in addJob()
195 void HttpDownloadManager::Private::connectQueueSet( DownloadQueueSet * queueSet ) in connectQueueSet() argument
197 connect( queueSet, SIGNAL(jobFinished(QByteArray,QString,QString)), in connectQueueSet()
200 connect( queueSet, SIGNAL(jobRedirected(QUrl,QString,QString,DownloadUsage)), in connectQueueSet()
203 connect( queueSet, SIGNAL(jobAdded()), m_downloadManager, SIGNAL(jobAdded())); in connectQueueSet()
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/ |
| H A D | queueset.go | 53 theSet *queueSet
67 type queueSet struct { struct
150 qs = &queueSet{
369 func (qs *queueSet) IsIdle() bool { argument
375 func (qs *queueSet) isIdleLocked() bool { argument
382 func (qs *queueSet) lockAndSyncTime() { argument
391 func (qs *queueSet) syncTimeLocked() { argument
584 func (qs *queueSet) dispatchLocked() bool { argument
618 func (qs *queueSet) cancelWait(req *request) { argument
767 func (qs *queueSet) goroutineDoneOrBlocked() { argument
[all …]
|
| H A D | types.go | 34 qs *queueSet
|
| H A D | queueset_test.go | 736 queue, ok := qs.(*queueSet)
738 t.Fatalf("expected a QueueSet of type: %T but got: %T", &queueSet{}, qs)
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/ |
| H A D | queueset.go | 52 theSet *queueSet
66 type queueSet struct { struct
153 qs = &queueSet{
383 func (qs *queueSet) IsIdle() bool { argument
389 func (qs *queueSet) isIdleLocked() bool { argument
396 func (qs *queueSet) lockAndSyncTime() { argument
405 func (qs *queueSet) syncTimeLocked() { argument
613 func (qs *queueSet) dispatchLocked() bool { argument
652 func (qs *queueSet) cancelWait(req *request) { argument
865 func (qs *queueSet) goroutineDoneOrBlocked() { argument
[all …]
|
| H A D | types.go | 35 qs *queueSet
|
| H A D | queueset_test.go | 750 queue, ok := qs.(*queueSet)
752 t.Fatalf("expected a QueueSet of type: %T but got: %T", &queueSet{}, qs)
802 beforeSelectQueueLocked func(attempt int, qs *queueSet)
911 beforeSelectQueueLocked: func(attempt int, qs *queueSet) {
924 qs := &queueSet{
|
| /dports/science/dakota/dakota-6.13.0-release-public.src-UI/packages/external/acro/packages/scolib/src/libs/ |
| H A D | MultiStatePS.cpp | 280 queueSet(ps->new_pseudo_queue_set()), in FirstImproving_PatternInfo()
281 improving_queue(ps->new_pseudo_queue(queueSet)), in FirstImproving_PatternInfo()
282 secondary_queue(ps->new_pseudo_queue(queueSet)) in FirstImproving_PatternInfo()
288 msps->set_pseudo_queue_alloc(queueSet, alloc); in FirstImproving_PatternInfo()
292 msps->release_pseudo_queue_set(queueSet); in ~FirstImproving_PatternInfo()
298 queueSet_t queueSet; member
539 queueSet(ps->new_pseudo_queue_set()), in BestImproving_PatternInfo()
547 msps->set_pseudo_queue_alloc(queueSet, alloc); in BestImproving_PatternInfo()
551 msps->release_pseudo_queue_set(queueSet); in ~BestImproving_PatternInfo()
557 queueSet_t queueSet; member
[all …]
|
| /dports/science/dakota/dakota-6.13.0-release-public.src-UI/packages/external/acro/packages/scolib/src/scolib/ |
| H A D | MultiStatePS.h | 203 void release_pseudo_queue_set(queueSet_t queueSet);
213 pseudoQueue_t new_pseudo_queue(queueSet_t queueSet);
216 void release_pseudo_queue(queueSet_t queueSet, pseudoQueue_t queue);
219 void get_pseudo_queue_alloc( queueSet_t queueSet,
223 void set_pseudo_queue_alloc( queueSet_t queueSet,
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/ |
| H A D | ResourceSchedulerWrapper.java | 153 private Set<String> queueSet; field in ResourceSchedulerWrapper
767 this.queueSet = queues; in setQueueSet()
771 return this.queueSet; in getQueueSet()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/ |
| H A D | TestClientRMService.java | 995 Set<String> queueSet = new HashSet<String>(); in testGetApplications() local
996 request.setQueues(queueSet); in testGetApplications()
998 queueSet.add(queues[0]); in testGetApplications()
1004 queueSet.add(queues[1]); in testGetApplications()
|
| /dports/x11-wm/chamfer/chamferwm-d0916ee/src/ |
| H A D | compositor.cpp | 434 std::set<uint> queueSet; in InitializeRenderEngine() local
438 queueSet.insert(queueFamilyIndex[i]); in InitializeRenderEngine()
446 for(uint queueFamilyIndex1 : queueSet){ in InitializeRenderEngine()
|
| /dports/net-mgmt/observium/observium/mibs/zte/ |
| H A D | ZXR10-EPON-MIB | 1286 "DBA queueSet"
|