Home
last modified time | relevance | path

Searched refs:nodeUpdate (Results 1 – 25 of 69) sorted by relevance

123

/dports/devel/php-ice37/ice-3.7.2/cpp/test/IceGrid/update/
H A DAllTests.cpp651 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 DAllTests.cpp651 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 DAllTests.cpp651 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 Dtaint_manager.go202 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 DTestResourceManager.java134 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 DMockNM.java142 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 DSceneTreeView.cpp141 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 Ddispatcher.go112 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 Ddispatcher.go112 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 Ddispatcher.go111 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 Ddispatcher.go111 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 Ddispatcher.go101 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 Ddispatcher.go111 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 Ddispatcher.go111 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 Ddispatcher.go111 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 Ddispatcher.go111 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 Ddispatcher.go111 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 Ddispatcher.go111 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 Ddispatcher.go111 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 DAllTests.cpp24 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 DAllTests.cpp24 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 DAllTests.cpp24 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 Dindexing.go220 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 DAllTests.cpp145 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 DAllTests.cpp145 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()

123