Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 349 for pound (0.06 sec)

  1. pkg/controller/volume/persistentvolume/pv_controller.go

    					return err
    				}
    				// OBSERVATION: pvc is "Bound", pv is "Bound"
    				return nil
    			} else if storagehelpers.IsVolumeBoundToClaim(volume, claim) {
    				// User asked for a PV that is claimed by this PVC
    				// OBSERVATION: pvc is "Pending", pv is "Bound"
    				logger.V(4).Info("Synchronizing unbound PersistentVolumeClaim, volume already bound, finishing the binding", "PVC", klog.KObj(claim))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go

    			dswp.hasAddedPods = tc.hasAddedPods
    			// Action
    			dswp.findAndAddNewPods()
    
    			// Verify
    			podsInDSW := dswp.desiredStateOfWorld.GetPods()
    			found := false
    			if podsInDSW[types.UniquePodName(pod.UID)] {
    				found = true
    			}
    
    			if found != tc.expectedFound {
    				t.Fatalf(
    					"Pod with uid %v has expectedFound value %v in pods in DSW %v",
    					pod.UID, tc.expectedFound, podsInDSW)
    			}
    		})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  3. plugin/pkg/admission/noderestriction/admission_test.go

    			podsGetter: existingPods,
    			attributes: admission.NewAttributesRecord(unnamedEviction, nil, evictionKind, coremymirrorpod.Namespace, coremymirrorpod.Name, podResource, "eviction", admission.Create, &metav1.CreateOptions{}, false, mynode),
    			err:        "",
    		},
    
    		// Mirror pods bound to another node
    		{
    			name:       "forbid creating a mirror pod bound to another",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 73.2K bytes
    - Viewed (0)
  4. src/internal/trace/order.go

    	// thread it was bound to. Since this status is Running -> Running and Running is binding,
    	// we need to make sure we emit it in the right context: the context to which it is bound.
    	// Find it, and set our current context to it.
    	if status == go122.ProcSyscallAbandoned && oldState == ProcRunning {
    		// N.B. This is slow but it should be fairly rare.
    		found := false
    		for mid, ms := range o.mStates {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 52.4K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    	boundPVC            = makeTestPVC("bound-pvc", "1G", "", pvcBound, "pv-bound", "1", &waitClass)
    	boundPVCNode1a      = makeTestPVC("unbound-pvc", "1G", "", pvcBound, "pv-node1a", "1", &waitClass)
    	immediateUnboundPVC = makeTestPVC("immediate-unbound-pvc", "1G", "", pvcUnbound, "", "1", &immediateClass)
    	immediateBoundPVC   = makeTestPVC("immediate-bound-pvc", "1G", "", pvcBound, "pv-bound-immediate", "1", &immediateClass)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/patch.go

    		}
    		// If there is an item present in the patch but not in the retainKeys list,
    		// the patch is invalid.
    		if _, found := m[k]; !found {
    			return mergepatch.ErrBadPatchFormatForRetainKeys
    		}
    	}
    
    	// clear not present fields
    	for k := range original {
    		if _, found := m[k]; !found {
    			delete(original, k)
    		}
    	}
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 23:34:23 UTC 2023
    - 75.5K bytes
    - Viewed (0)
  7. cmd/iam-store.go

    		defer func() {
    			cache.updatedAt = time.Now()
    			store.unlock()
    		}()
    
    		_, found := cache.iamUsersMap[accessKey]
    
    		// Check for regular user access key
    		if !found {
    			err = store.loadUser(ctx, accessKey, regUser, cache.iamUsersMap)
    			if _, found = cache.iamUsersMap[accessKey]; found {
    				// load mapped policies
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  8. pkg/controller/volume/persistentvolume/binder_test.go

    			errors:          noerrors,
    			test:            testSyncClaim,
    		},
    		{
    			// syncClaim with claim bound to bound volume. Check that the
    			// controller does not do anything. Also check that Pending phase is
    			// set to Bound
    			name:            "3-5 - bound claim with bound volume",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 65.8K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/listener_test.go

    						listeners := buildListeners(t, proxy, port)
    						found := hasListenerOrFilterChainForPort(listeners, port)
    						if tc.expectListener {
    							if !found {
    								t.Fatalf("expected listener on port %d, but not found", port)
    							}
    						} else {
    							if found {
    								t.Fatalf("expected no listener on port %d, but found found one", port)
    							}
    						}
    					}
    				})
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
  10. src/time/time.go

    }
    
    // Round returns the result of rounding d to the nearest multiple of m.
    // The rounding behavior for halfway values is to round away from zero.
    // If the result exceeds the maximum (or minimum)
    // value that can be stored in a [Duration],
    // Round returns the maximum (or minimum) duration.
    // If m <= 0, Round returns d unchanged.
    func (d Duration) Round(m Duration) Duration {
    	if m <= 0 {
    		return d
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 50.7K bytes
    - Viewed (0)
Back to top