mirror of
				https://github.com/optim-enterprises-bv/kubernetes.git
				synced 2025-11-04 12:18:16 +00:00 
			
		
		
		
	@@ -525,7 +525,7 @@ func (dc *DeploymentController) getReplicaSetsForDeployment(d *apps.Deployment)
 | 
				
			|||||||
//
 | 
					//
 | 
				
			||||||
// It returns a map from ReplicaSet UID to a list of Pods controlled by that RS,
 | 
					// It returns a map from ReplicaSet UID to a list of Pods controlled by that RS,
 | 
				
			||||||
// according to the Pod's ControllerRef.
 | 
					// according to the Pod's ControllerRef.
 | 
				
			||||||
// NOTE: The pod pointers returned by this method point the the pod objects in the cache and thus
 | 
					// NOTE: The pod pointers returned by this method point the pod objects in the cache and thus
 | 
				
			||||||
// shouldn't be modified in any way.
 | 
					// shouldn't be modified in any way.
 | 
				
			||||||
func (dc *DeploymentController) getPodMapForDeployment(d *apps.Deployment, rsList []*apps.ReplicaSet) (map[types.UID][]*v1.Pod, error) {
 | 
					func (dc *DeploymentController) getPodMapForDeployment(d *apps.Deployment, rsList []*apps.ReplicaSet) (map[types.UID][]*v1.Pod, error) {
 | 
				
			||||||
	// Get all Pods that potentially belong to this Deployment.
 | 
						// Get all Pods that potentially belong to this Deployment.
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -131,7 +131,7 @@ func (dsw *desiredStateOfWorld) AddOrUpdatePlugin(socketPath string, foundInDepr
 | 
				
			|||||||
		klog.V(2).Infof("Plugin (Path %s) exists in actual state cache, timestamp will be updated", socketPath)
 | 
							klog.V(2).Infof("Plugin (Path %s) exists in actual state cache, timestamp will be updated", socketPath)
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	// Update the the PluginInfo object.
 | 
						// Update the PluginInfo object.
 | 
				
			||||||
	// Note that we only update the timestamp in the desired state of world, not the actual state of world
 | 
						// Note that we only update the timestamp in the desired state of world, not the actual state of world
 | 
				
			||||||
	// because in the reconciler, we need to check if the plugin in the actual state of world is the same
 | 
						// because in the reconciler, we need to check if the plugin in the actual state of world is the same
 | 
				
			||||||
	// version as the plugin in the desired state of world
 | 
						// version as the plugin in the desired state of world
 | 
				
			||||||
 
 | 
				
			|||||||
							
								
								
									
										2
									
								
								pkg/scheduler/internal/cache/cache.go
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										2
									
								
								pkg/scheduler/internal/cache/cache.go
									
									
									
									
										vendored
									
									
								
							@@ -208,7 +208,7 @@ func (cache *schedulerCache) UpdateNodeInfoSnapshot(nodeSnapshot *schedulernodei
 | 
				
			|||||||
	defer cache.mu.Unlock()
 | 
						defer cache.mu.Unlock()
 | 
				
			||||||
	balancedVolumesEnabled := utilfeature.DefaultFeatureGate.Enabled(features.BalanceAttachedNodeVolumes)
 | 
						balancedVolumesEnabled := utilfeature.DefaultFeatureGate.Enabled(features.BalanceAttachedNodeVolumes)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	// Get the last generation of the the snapshot.
 | 
						// Get the last generation of the snapshot.
 | 
				
			||||||
	snapshotGeneration := nodeSnapshot.Generation
 | 
						snapshotGeneration := nodeSnapshot.Generation
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	// Start from the head of the NodeInfo doubly linked list and update snapshot
 | 
						// Start from the head of the NodeInfo doubly linked list and update snapshot
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -1498,7 +1498,7 @@ type TopologyRequirement struct {
 | 
				
			|||||||
	//   {"region": "R1", "zone": "Z3"}
 | 
						//   {"region": "R1", "zone": "Z3"}
 | 
				
			||||||
	// preferred =
 | 
						// preferred =
 | 
				
			||||||
	//   {"region": "R1", "zone": "Z3"}
 | 
						//   {"region": "R1", "zone": "Z3"}
 | 
				
			||||||
	// then the the SP SHOULD first attempt to make the provisioned volume
 | 
						// then the SP SHOULD first attempt to make the provisioned volume
 | 
				
			||||||
	// available from "zone" "Z3" in the "region" "R1" and fall back to
 | 
						// available from "zone" "Z3" in the "region" "R1" and fall back to
 | 
				
			||||||
	// "zone" "Z2" in the "region" "R1" if that is not possible.
 | 
						// "zone" "Z2" in the "region" "R1" if that is not possible.
 | 
				
			||||||
	//
 | 
						//
 | 
				
			||||||
@@ -1512,7 +1512,7 @@ type TopologyRequirement struct {
 | 
				
			|||||||
	// preferred =
 | 
						// preferred =
 | 
				
			||||||
	//   {"region": "R1", "zone": "Z4"},
 | 
						//   {"region": "R1", "zone": "Z4"},
 | 
				
			||||||
	//   {"region": "R1", "zone": "Z2"}
 | 
						//   {"region": "R1", "zone": "Z2"}
 | 
				
			||||||
	// then the the SP SHOULD first attempt to make the provisioned volume
 | 
						// then the SP SHOULD first attempt to make the provisioned volume
 | 
				
			||||||
	// accessible from "zone" "Z4" in the "region" "R1" and fall back to
 | 
						// accessible from "zone" "Z4" in the "region" "R1" and fall back to
 | 
				
			||||||
	// "zone" "Z2" in the "region" "R1" if that is not possible. If that
 | 
						// "zone" "Z2" in the "region" "R1" if that is not possible. If that
 | 
				
			||||||
	// is not possible, the SP may choose between either the "zone"
 | 
						// is not possible, the SP may choose between either the "zone"
 | 
				
			||||||
@@ -1531,7 +1531,7 @@ type TopologyRequirement struct {
 | 
				
			|||||||
	// preferred =
 | 
						// preferred =
 | 
				
			||||||
	//   {"region": "R1", "zone": "Z5"},
 | 
						//   {"region": "R1", "zone": "Z5"},
 | 
				
			||||||
	//   {"region": "R1", "zone": "Z3"}
 | 
						//   {"region": "R1", "zone": "Z3"}
 | 
				
			||||||
	// then the the SP SHOULD first attempt to make the provisioned volume
 | 
						// then the SP SHOULD first attempt to make the provisioned volume
 | 
				
			||||||
	// accessible from the combination of the two "zones" "Z5" and "Z3" in
 | 
						// accessible from the combination of the two "zones" "Z5" and "Z3" in
 | 
				
			||||||
	// the "region" "R1". If that's not possible, it should fall back to
 | 
						// the "region" "R1". If that's not possible, it should fall back to
 | 
				
			||||||
	// a combination of "Z5" and other possibilities from the list of
 | 
						// a combination of "Z5" and other possibilities from the list of
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -83,7 +83,7 @@ Loop:
 | 
				
			|||||||
				s <- c.CurrentStatus
 | 
									s <- c.CurrentStatus
 | 
				
			||||||
			case svc.Stop, svc.Shutdown:
 | 
								case svc.Stop, svc.Shutdown:
 | 
				
			||||||
				klog.Infof("Service stopping")
 | 
									klog.Infof("Service stopping")
 | 
				
			||||||
				// We need to translate this request into a signal that can be handled by the the signal handler
 | 
									// We need to translate this request into a signal that can be handled by the signal handler
 | 
				
			||||||
				// handling shutdowns normally (currently apiserver/pkg/server/signal.go).
 | 
									// handling shutdowns normally (currently apiserver/pkg/server/signal.go).
 | 
				
			||||||
				// If we do not do this, our main threads won't be notified of the upcoming shutdown.
 | 
									// If we do not do this, our main threads won't be notified of the upcoming shutdown.
 | 
				
			||||||
				// Since Windows services do not use any console, we cannot simply generate a CTRL_BREAK_EVENT
 | 
									// Since Windows services do not use any console, we cannot simply generate a CTRL_BREAK_EVENT
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user