/dports/devel/php-ice37/ice-3.7.2/cpp/test/IceGrid/update/ |
H A D | AllTests.cpp | 651 nodeUpdate.name = "node2"; in allTests() 673 nodeUpdate.name = "node2"; in allTests() 788 nodeUpdate.name = "node1"; in allTests() 812 nodeUpdate.name = "node1"; in allTests() 837 nodeUpdate.name = "node1"; in allTests() 855 nodeUpdate.name = "node1"; in allTests() 993 nodeUpdate.name = "node1"; in allTests() 1001 nodeUpdate.name = "node1"; in allTests() 1209 nodeUpdate.name = "node-1"; in allTests() 1212 nodeUpdate.name = "node-2"; in allTests() [all …]
|
/dports/devel/ice37/ice-3.7.2/cpp/test/IceGrid/update/ |
H A D | AllTests.cpp | 651 nodeUpdate.name = "node2"; in allTests() 673 nodeUpdate.name = "node2"; in allTests() 788 nodeUpdate.name = "node1"; in allTests() 812 nodeUpdate.name = "node1"; in allTests() 837 nodeUpdate.name = "node1"; in allTests() 855 nodeUpdate.name = "node1"; in allTests() 993 nodeUpdate.name = "node1"; in allTests() 1001 nodeUpdate.name = "node1"; in allTests() 1209 nodeUpdate.name = "node-1"; in allTests() 1212 nodeUpdate.name = "node-2"; in allTests() [all …]
|
/dports/devel/py-ice37/ice-3.7.2/cpp/test/IceGrid/update/ |
H A D | AllTests.cpp | 651 nodeUpdate.name = "node2"; in allTests() 673 nodeUpdate.name = "node2"; in allTests() 788 nodeUpdate.name = "node1"; in allTests() 812 nodeUpdate.name = "node1"; in allTests() 837 nodeUpdate.name = "node1"; in allTests() 855 nodeUpdate.name = "node1"; in allTests() 993 nodeUpdate.name = "node1"; in allTests() 1001 nodeUpdate.name = "node1"; in allTests() 1209 nodeUpdate.name = "node-1"; in allTests() 1212 nodeUpdate.name = "node-2"; in allTests() [all …]
|
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/nodelifecycle/scheduler/ |
H A D | taint_manager.go | 202 nodeUpdate := item.(nodeUpdateItem) 203 hash := hash(nodeUpdate.nodeName, UpdateWorkerSize) 208 case tc.nodeUpdateChannels[hash] <- nodeUpdate: 255 case nodeUpdate := <-tc.nodeUpdateChannels[worker]: 256 tc.handleNodeUpdate(nodeUpdate) 257 tc.nodeUpdateQueue.Done(nodeUpdate) 263 case nodeUpdate := <-tc.nodeUpdateChannels[worker]: 264 tc.handleNodeUpdate(nodeUpdate) 265 tc.nodeUpdateQueue.Done(nodeUpdate) 420 node, err := tc.getNode(nodeUpdate.nodeName) [all …]
|
/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 | TestResourceManager.java | 134 nodeUpdate(nm1); in testResourceAllocation() 154 nodeUpdate(nm2); in testResourceAllocation() 155 nodeUpdate(nm2); in testResourceAllocation() 156 nodeUpdate(nm1); in testResourceAllocation() 157 nodeUpdate(nm1); in testResourceAllocation() 182 private void nodeUpdate( in nodeUpdate() method in TestResourceManager 186 NodeUpdateSchedulerEvent nodeUpdate = new NodeUpdateSchedulerEvent(node); in nodeUpdate() local 187 resourceManager.getResourceScheduler().handle(nodeUpdate); in nodeUpdate()
|
H A D | MockNM.java | 142 HashMap<ApplicationId, List<ContainerStatus>> nodeUpdate = in nodeHeartbeat() local 151 nodeUpdate.put(attemptId.getApplicationId(), containerStatusList); in nodeHeartbeat() 152 return nodeHeartbeat(nodeUpdate, true); in nodeHeartbeat()
|
/dports/graphics/wdune/wdune-1.926/src/ |
H A D | SceneTreeView.cpp | 141 NodeUpdate *nodeUpdate; in OnUpdate() local 183 nodeUpdate = (NodeUpdate *) hint; in OnUpdate() 184 UpdateAddNode(swTreeGetRootItem(m_tree), nodeUpdate->node, in OnUpdate() 185 nodeUpdate->parent, nodeUpdate->field); in OnUpdate() 189 nodeUpdate = (NodeUpdate *) hint; in OnUpdate() 190 if ((nodeUpdate->node == NULL) || (nodeUpdate->field == -1)) in OnUpdate() 192 UpdateRemoveNode(swTreeGetRootItem(m_tree), nodeUpdate->node, in OnUpdate() 193 nodeUpdate->parent, nodeUpdate->field, in OnUpdate() 194 nodeUpdate->parent); in OnUpdate() 199 nodeUpdate = (NodeUpdate *) hint; in OnUpdate() [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 112 type nodeUpdate struct { struct 203 d.nodeUpdates = make(map[string]nodeUpdate) 421 d.nodeUpdates[nodeID] = nodeUpdate{ 598 nodeUpdates map[string]nodeUpdate 610 d.nodeUpdates = make(map[string]nodeUpdate) 671 for nodeID, nodeUpdate := range nodeUpdates { 680 if nodeUpdate.status != nil { 683 if nodeUpdate.status.Addr != "" { 684 node.Status.Addr = nodeUpdate.status.Addr 687 if nodeUpdate.description != nil { [all …]
|
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 112 type nodeUpdate struct { struct 203 d.nodeUpdates = make(map[string]nodeUpdate) 421 d.nodeUpdates[nodeID] = nodeUpdate{ 598 nodeUpdates map[string]nodeUpdate 610 d.nodeUpdates = make(map[string]nodeUpdate) 671 for nodeID, nodeUpdate := range nodeUpdates { 680 if nodeUpdate.status != nil { 683 if nodeUpdate.status.Addr != "" { 684 node.Status.Addr = nodeUpdate.status.Addr 687 if nodeUpdate.description != nil { [all …]
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 491 d.nodeUpdates[nodeID] = nodeUpdate{ 673 nodeUpdates map[string]nodeUpdate 685 d.nodeUpdates = make(map[string]nodeUpdate) 747 for nodeID, nodeUpdate := range nodeUpdates { 756 if nodeUpdate.status != nil { 759 if nodeUpdate.status.Addr != "" { 760 node.Status.Addr = nodeUpdate.status.Addr 763 if nodeUpdate.description != nil { [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 491 d.nodeUpdates[nodeID] = nodeUpdate{ 673 nodeUpdates map[string]nodeUpdate 685 d.nodeUpdates = make(map[string]nodeUpdate) 747 for nodeID, nodeUpdate := range nodeUpdates { 756 if nodeUpdate.status != nil { 759 if nodeUpdate.status.Addr != "" { 760 node.Status.Addr = nodeUpdate.status.Addr 763 if nodeUpdate.description != nil { [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 101 type nodeUpdate struct { struct 382 d.nodeUpdates[nodeID] = nodeUpdate{ 554 nodeUpdates map[string]nodeUpdate 566 d.nodeUpdates = make(map[string]nodeUpdate) 613 for nodeID, nodeUpdate := range nodeUpdates { 622 if nodeUpdate.status != nil { 623 node.Status.State = nodeUpdate.status.State 625 if nodeUpdate.status.Addr != "" { 626 node.Status.Addr = nodeUpdate.status.Addr 629 if nodeUpdate.description != nil { [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 491 d.nodeUpdates[nodeID] = nodeUpdate{ 673 nodeUpdates map[string]nodeUpdate 685 d.nodeUpdates = make(map[string]nodeUpdate) 747 for nodeID, nodeUpdate := range nodeUpdates { 756 if nodeUpdate.status != nil { 759 if nodeUpdate.status.Addr != "" { 760 node.Status.Addr = nodeUpdate.status.Addr 763 if nodeUpdate.description != nil { [all …]
|
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 491 d.nodeUpdates[nodeID] = nodeUpdate{ 673 nodeUpdates map[string]nodeUpdate 685 d.nodeUpdates = make(map[string]nodeUpdate) 747 for nodeID, nodeUpdate := range nodeUpdates { 756 if nodeUpdate.status != nil { 759 if nodeUpdate.status.Addr != "" { 760 node.Status.Addr = nodeUpdate.status.Addr 763 if nodeUpdate.description != nil { [all …]
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 465 d.nodeUpdates[nodeID] = nodeUpdate{ 647 nodeUpdates map[string]nodeUpdate 659 d.nodeUpdates = make(map[string]nodeUpdate) 721 for nodeID, nodeUpdate := range nodeUpdates { 730 if nodeUpdate.status != nil { 733 if nodeUpdate.status.Addr != "" { 734 node.Status.Addr = nodeUpdate.status.Addr 737 if nodeUpdate.description != nil { [all …]
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 491 d.nodeUpdates[nodeID] = nodeUpdate{ 673 nodeUpdates map[string]nodeUpdate 685 d.nodeUpdates = make(map[string]nodeUpdate) 747 for nodeID, nodeUpdate := range nodeUpdates { 756 if nodeUpdate.status != nil { 759 if nodeUpdate.status.Addr != "" { 760 node.Status.Addr = nodeUpdate.status.Addr 763 if nodeUpdate.description != nil { [all …]
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 491 d.nodeUpdates[nodeID] = nodeUpdate{ 673 nodeUpdates map[string]nodeUpdate 685 d.nodeUpdates = make(map[string]nodeUpdate) 747 for nodeID, nodeUpdate := range nodeUpdates { 756 if nodeUpdate.status != nil { 759 if nodeUpdate.status.Addr != "" { 760 node.Status.Addr = nodeUpdate.status.Addr 763 if nodeUpdate.description != nil { [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 491 d.nodeUpdates[nodeID] = nodeUpdate{ 673 nodeUpdates map[string]nodeUpdate 685 d.nodeUpdates = make(map[string]nodeUpdate) 747 for nodeID, nodeUpdate := range nodeUpdates { 756 if nodeUpdate.status != nil { 759 if nodeUpdate.status.Addr != "" { 760 node.Status.Addr = nodeUpdate.status.Addr 763 if nodeUpdate.description != nil { [all …]
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 111 type nodeUpdate struct { struct 223 d.nodeUpdates = make(map[string]nodeUpdate) 458 d.nodeUpdates[nodeID] = nodeUpdate{ 640 nodeUpdates map[string]nodeUpdate 652 d.nodeUpdates = make(map[string]nodeUpdate) 714 for nodeID, nodeUpdate := range nodeUpdates { 723 if nodeUpdate.status != nil { 726 if nodeUpdate.status.Addr != "" { 727 node.Status.Addr = nodeUpdate.status.Addr 730 if nodeUpdate.description != nil { [all …]
|
/dports/devel/php-ice37/ice-3.7.2/cpp/test/IceGrid/replicaGroup/ |
H A D | AllTests.cpp | 24 NodeUpdateDescriptor nodeUpdate; in instantiateServer() local 25 nodeUpdate.name = node; in instantiateServer() 26 nodeUpdate.serverInstances.push_back(desc); in instantiateServer() 29 update.nodes.push_back(nodeUpdate); in instantiateServer() 85 NodeUpdateDescriptor nodeUpdate; in removeServer() local 86 nodeUpdate.name = info.node; in removeServer() 87 nodeUpdate.removeServers.push_back(id); in removeServer() 90 update.nodes.push_back(nodeUpdate); in removeServer()
|
/dports/devel/ice37/ice-3.7.2/cpp/test/IceGrid/replicaGroup/ |
H A D | AllTests.cpp | 24 NodeUpdateDescriptor nodeUpdate; in instantiateServer() local 25 nodeUpdate.name = node; in instantiateServer() 26 nodeUpdate.serverInstances.push_back(desc); in instantiateServer() 29 update.nodes.push_back(nodeUpdate); in instantiateServer() 85 NodeUpdateDescriptor nodeUpdate; in removeServer() local 86 nodeUpdate.name = info.node; in removeServer() 87 nodeUpdate.removeServers.push_back(id); in removeServer() 90 update.nodes.push_back(nodeUpdate); in removeServer()
|
/dports/devel/py-ice37/ice-3.7.2/cpp/test/IceGrid/replicaGroup/ |
H A D | AllTests.cpp | 24 NodeUpdateDescriptor nodeUpdate; in instantiateServer() local 25 nodeUpdate.name = node; in instantiateServer() 26 nodeUpdate.serverInstances.push_back(desc); in instantiateServer() 29 update.nodes.push_back(nodeUpdate); in instantiateServer() 85 NodeUpdateDescriptor nodeUpdate; in removeServer() local 86 nodeUpdate.name = info.node; in removeServer() 87 nodeUpdate.removeServers.push_back(id); in removeServer() 90 update.nodes.push_back(nodeUpdate); in removeServer()
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/graph/kv/ |
H A D | indexing.go | 220 type nodeUpdate struct { struct 226 func (qs *QuadStore) incNodesCnt(ctx context.Context, tx BucketTx, deltas []nodeUpdate) ([]int, err… argument 269 ins []nodeUpdate 270 upd = make([]nodeUpdate, 0, len(deltas)) 276 ins = append(ins, nodeUpdate{Ind: i, NodeUpdate: deltas[i]}) 279 upd = append(upd, nodeUpdate{Ind: i, ID: id, NodeUpdate: deltas[i]}) 314 upds := make([]nodeUpdate, 0, len(deltas)) 320 upds = append(upds, nodeUpdate{Ind: i, ID: id, NodeUpdate: d})
|
/dports/devel/php-ice37/ice-3.7.2/cpp/test/IceGrid/replication/ |
H A D | AllTests.cpp | 145 NodeUpdateDescriptor nodeUpdate; in instantiateServer() local 146 nodeUpdate.name = "localnode"; in instantiateServer() 147 nodeUpdate.serverInstances.push_back(desc); in instantiateServer() 150 update.nodes.push_back(nodeUpdate); in instantiateServer() 186 NodeUpdateDescriptor nodeUpdate; in removeServer() local 187 nodeUpdate.name = "localnode"; in removeServer() 188 nodeUpdate.removeServers.push_back(id); in removeServer() 191 update.nodes.push_back(nodeUpdate); in removeServer()
|
/dports/devel/ice37/ice-3.7.2/cpp/test/IceGrid/replication/ |
H A D | AllTests.cpp | 145 NodeUpdateDescriptor nodeUpdate; in instantiateServer() local 146 nodeUpdate.name = "localnode"; in instantiateServer() 147 nodeUpdate.serverInstances.push_back(desc); in instantiateServer() 150 update.nodes.push_back(nodeUpdate); in instantiateServer() 186 NodeUpdateDescriptor nodeUpdate; in removeServer() local 187 nodeUpdate.name = "localnode"; in removeServer() 188 nodeUpdate.removeServers.push_back(id); in removeServer() 191 update.nodes.push_back(nodeUpdate); in removeServer()
|