Home
last modified time | relevance | path

Searched refs:activeNodes (Results 1 – 25 of 106) sorted by relevance

12345

/dports/biology/gatk/gatk-4.2.0.0/src/main/java/org/broadinstitute/hellbender/tools/walkers/haplotypecaller/graphs/
H A DJTBestHaplotype.java202 List<JunctionTreeLinkedDeBruijnGraph.ThreadingNode> activeNodes; field in JTBestHaplotype.JunctionTreeManager
206 activeNodes = new ArrayList<>(5); in JunctionTreeManager()
211 this.activeNodes = new ArrayList<>(toCopy.activeNodes); in JunctionTreeManager()
220 activeNodes.add(junctionTreeForNode.getRootNode()); in addJunctionTree()
228 activeNodes = activeNodes.stream() in traverseEdgeForAllTrees()
237 …activeNodes = activeNodes.stream().filter(node -> getTotalOutForBranch(node) > 0).collect(Collecto… in removeEmptyNodesAndReturnIterator()
238 return activeNodes; in removeEmptyNodesAndReturnIterator()
242 return activeNodes.get(i); in get()
246 return activeNodes == null ? 0 : activeNodes.size(); in size()
250 activeNodes.remove(0); in removeOldestTree()
[all …]
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/
H A DElectableGroupSizeOverrideTest.java74 RepEnvInfo[] activeNodes = in testMasterDownOverride() local
80 for (RepEnvInfo ri : activeNodes) { in testMasterDownOverride()
86 setMutableElectableGroupSize(simpleMajority-1, activeNodes); in testMasterDownOverride()
93 tryWrite(findMaster(activeNodes).getEnv(), "dbok"); in testMasterDownOverride()
100 setMutableElectableGroupSize(0, activeNodes); in testMasterDownOverride()
137 RepEnvInfo[] activeNodes = copyArray(repEnvInfo, 0, in testMasterUpOverride() local
145 tryWrite(findMaster(activeNodes).getEnv(), "dbfail"); in testMasterUpOverride()
152 setMutableElectableGroupSize(simpleMajority-1, activeNodes); in testMasterUpOverride()
155 tryWrite(findMaster(activeNodes).getEnv(), "dbok"); in testMasterUpOverride()
162 setMutableElectableGroupSize(0, activeNodes); in testMasterUpOverride()
[all …]
/dports/math/ogdf/OGDF/src/ogdf/graphalg/
H A DModifiedNibbleClusterer.cpp138 for (int i = 0; i < (int)activeNodes.size(); ++i) { in findBestCluster()
139 const node v = activeNodes.at(i); in findBestCluster()
164 node next = activeNodes.at(sortedPairs[run].item()); in findBestCluster()
229 node next = activeNodes.at(sortedPairs[run].item()); in findBestCluster()
267 std::vector<node> activeNodes; in modifiedNibble() local
268 activeNodes.push_back(m_startNode); in modifiedNibble()
279 spreadValues(isActive, activeNodes, probUpdate); in modifiedNibble()
283 if ((long)activeNodes.size() > m_maxActiveNodes) in modifiedNibble()
309 for(node v : activeNodes) { in spreadValues()
325 for(node v : activeNodes) { in spreadValues()
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/cli/cli-20.10.2/cli/command/service/
H A Dlist_test.go74 activeNodes: 0,
88 activeNodes: 3,
102 activeNodes: 3,
120 activeNodes: 0,
134 activeNodes: 3,
148 activeNodes: 3,
220 activeNodes uint64 member
246 if globalTasks > opts.activeNodes {
247 globalTasks = opts.activeNodes
284 desiredTasks = opts.activeNodes
[all …]
H A Dlist.go149 activeNodes, err := getActiveNodes(ctx, c)
165 …if _, nodeActive := activeNodes[task.NodeID]; nodeActive && task.Status.State == swarm.TaskStateRu…
183 activeNodes := make(map[string]struct{})
186 activeNodes[n.ID] = struct{}{}
189 return activeNodes, nil
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/cli/cli/command/service/
H A Dlist_test.go74 activeNodes: 0,
88 activeNodes: 3,
102 activeNodes: 3,
120 activeNodes: 0,
134 activeNodes: 3,
148 activeNodes: 3,
220 activeNodes uint64 member
246 if globalTasks > opts.activeNodes {
247 globalTasks = opts.activeNodes
284 desiredTasks = opts.activeNodes
[all …]
H A Dlist.go149 activeNodes, err := getActiveNodes(ctx, c)
165 …if _, nodeActive := activeNodes[task.NodeID]; nodeActive && task.Status.State == swarm.TaskStateRu…
183 activeNodes := make(map[string]struct{})
186 activeNodes[n.ID] = struct{}{}
189 return activeNodes, nil
/dports/java/berkeley-db/je-6.2.31/test/com/sleepycat/je/rep/elections/
H A DElectionsTest.java237 int activeNodes,
242 startReplicationNodes(activeNodes, groupSize);
245 (activeNodes)));
246 return runElection(qpolicy, activeNodes);
252 activeNodes,
253 activeNodes);
259 activeNodes,
263 private Elections runElection(QuorumPolicy qpolicy, int activeNodes)
268 listenerLatch = new CountDownLatch(activeNodes);
278 private Elections runElection(int activeNodes)
[all …]
/dports/net-mgmt/semaphore/semaphore-2.6.8/api/tasks/
H A Dpool.go15 activeNodes map[string]*task member
23 activeNodes: make(map[string]*task),
56 p.activeNodes[node] = t
68 delete(p.activeNodes, node)
124 if p.activeNodes[node] != nil {
/dports/sysutils/docker/docker-ce-18.09.5/components/cli/cli/command/service/progress/
H A Dprogress.go51 …update(service swarm.Service, tasks []swarm.Task, activeNodes map[string]struct{}, rollback bool) …
157 activeNodes, err := getActiveNodes(ctx, client)
162 converged, err = updater.update(service, tasks, activeNodes, rollback)
213 activeNodes := make(map[string]struct{})
216 activeNodes[n.ID] = struct{}{}
219 return activeNodes, nil
293 tasksBySlot := u.tasksBySlot(tasks, activeNodes)
332 func (u *replicatedProgressUpdater) tasksBySlot(tasks []swarm.Task, activeNodes map[string]struct{}…
354 if _, nodeActive := activeNodes[task.NodeID]; !nodeActive {
395 func (u *globalProgressUpdater) update(service swarm.Service, tasks []swarm.Task, activeNodes map[s…
[all …]
H A Dprogress_test.go32 activeNodes map[string]struct{} member
39 converged, err := u.updater.update(u.service, tasks, u.activeNodes, u.rollback)
65 activeNodes: map[string]struct{}{"a": {}, "b": {}},
175 activeNodes: map[string]struct{}{"a": {}, "b": {}},
230 activeNodes: map[string]struct{}{"a": {}, "b": {}},
337 activeNodes: map[string]struct{}{},
342 updaterTester.activeNodes[strconv.Itoa(i)] = struct{}{}
/dports/graphics/krita/krita-4.4.8/plugins/impex/ora/
H A Dora_converter.cpp68 m_activeNodes = orslv.activeNodes(); in buildImage()
79 vKisNodeSP OraConverter::activeNodes() in activeNodes() function in OraConverter
84 …ortExportErrorCode OraConverter::buildFile(QIODevice *io, KisImageSP image, vKisNodeSP activeNodes) in buildFile() argument
95 KisOpenRasterStackSaveVisitor orssv(&osc, activeNodes); in buildFile()
H A Dkis_open_raster_stack_save_visitor.cpp43 vKisNodeSP activeNodes; member
46 …sitor::KisOpenRasterStackSaveVisitor(KisOpenRasterSaveContext* saveContext, vKisNodeSP activeNodes) in KisOpenRasterStackSaveVisitor() argument
50 d->activeNodes = activeNodes; in KisOpenRasterStackSaveVisitor()
80 if (d->activeNodes.contains(layer)) { in saveLayerInfo()
H A Dora_import.cc45 if (oraConverter.activeNodes().size() > 0) { in convert()
46 document->setPreActivatedNode(oraConverter.activeNodes()[0]); in convert()
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/integration/rpctest/
H A Dutils.go158 activeNodes := make([]*Harness, 0, len(testInstances))
160 activeNodes = append(activeNodes, harness)
163 return activeNodes
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/integration/rpctest/
H A Dutils.go158 activeNodes := make([]*Harness, 0, len(testInstances))
160 activeNodes = append(activeNodes, harness)
163 return activeNodes
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/integration/rpctest/
H A Dutils.go158 activeNodes := make([]*Harness, 0, len(testInstances))
160 activeNodes = append(activeNodes, harness)
163 return activeNodes
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/integration/rpctest/
H A Dutils.go158 activeNodes := make([]*Harness, 0, len(testInstances))
160 activeNodes = append(activeNodes, harness)
163 return activeNodes
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/btcsuite/btcd/integration/rpctest/
H A Dutils.go158 activeNodes := make([]*Harness, 0, len(testInstances))
160 activeNodes = append(activeNodes, harness)
163 return activeNodes
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/btcsuite/btcd/integration/rpctest/
H A Dutils.go158 activeNodes := make([]*Harness, 0, len(testInstances))
160 activeNodes = append(activeNodes, harness)
163 return activeNodes
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/cli/cli-20.10.2/cli/command/service/progress/
H A Dprogress.go53 …update(service swarm.Service, tasks []swarm.Task, activeNodes map[string]struct{}, rollback bool) …
161 activeNodes, err := getActiveNodes(ctx, client)
166 converged, err = updater.update(service, tasks, activeNodes, rollback)
229 activeNodes := make(map[string]struct{})
232 activeNodes[n.ID] = struct{}{}
235 return activeNodes, nil
317 tasksBySlot := u.tasksBySlot(tasks, activeNodes)
356 func (u *replicatedProgressUpdater) tasksBySlot(tasks []swarm.Task, activeNodes map[string]struct{}…
378 if _, nodeActive := activeNodes[task.NodeID]; !nodeActive {
457 if _, nodeActive := activeNodes[task.NodeID]; nodeActive {
[all …]
H A Dprogress_test.go32 activeNodes map[string]struct{} member
79 activeNodes: map[string]struct{}{"a": {}, "b": {}},
189 activeNodes: map[string]struct{}{"a": {}, "b": {}},
244 activeNodes: map[string]struct{}{"a": {}, "b": {}},
351 activeNodes: map[string]struct{}{},
414 activeNodes: map[string]struct{}{"a": {}, "b": {}},
637 activeNodes: map[string]struct{}{"a": {}, "b": {}},
852 activeNodes := map[string]struct{}{}
854 activeNodes[fmt.Sprintf("node%v", i)] = struct{}{}
864 activeNodes: activeNodes,
[all …]
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/cli/cli/command/service/progress/
H A Dprogress.go53 …update(service swarm.Service, tasks []swarm.Task, activeNodes map[string]struct{}, rollback bool) …
161 activeNodes, err := getActiveNodes(ctx, client)
166 converged, err = updater.update(service, tasks, activeNodes, rollback)
229 activeNodes := make(map[string]struct{})
232 activeNodes[n.ID] = struct{}{}
235 return activeNodes, nil
317 tasksBySlot := u.tasksBySlot(tasks, activeNodes)
356 func (u *replicatedProgressUpdater) tasksBySlot(tasks []swarm.Task, activeNodes map[string]struct{}…
378 if _, nodeActive := activeNodes[task.NodeID]; !nodeActive {
457 if _, nodeActive := activeNodes[task.NodeID]; nodeActive {
[all …]
H A Dprogress_test.go32 activeNodes map[string]struct{} member
79 activeNodes: map[string]struct{}{"a": {}, "b": {}},
189 activeNodes: map[string]struct{}{"a": {}, "b": {}},
244 activeNodes: map[string]struct{}{"a": {}, "b": {}},
351 activeNodes: map[string]struct{}{},
414 activeNodes: map[string]struct{}{"a": {}, "b": {}},
637 activeNodes: map[string]struct{}{"a": {}, "b": {}},
852 activeNodes := map[string]struct{}{}
854 activeNodes[fmt.Sprintf("node%v", i)] = struct{}{}
864 activeNodes: activeNodes,
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/
H A DClusterMetricsInfo.java59 protected int activeNodes; field in ClusterMetricsInfo
90 this.activeNodes = clusterMetrics.getNumActiveNMs(); in ClusterMetricsInfo()
95 this.totalNodes = activeNodes + lostNodes + decommissionedNodes in ClusterMetricsInfo()
172 return this.activeNodes; in getActiveNodes()

12345