Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for unbounded (0.15 sec)

  1. src/database/sql/sql.go

    func (ci *ColumnType) Name() string {
    	return ci.name
    }
    
    // Length returns the column type length for variable length column types such
    // as text and binary field types. If the type length is unbounded the value will
    // be [math.MaxInt64] (any database limits will still apply).
    // If the column type is not variable length, such as an int, or if not supported
    // by the driver ok is false.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:53 UTC 2024
    - 103.6K bytes
    - Viewed (0)
  2. src/runtime/proc.go

    			// starts running again when that timer expiration may
    			// cause Go code to run again).
    			//
    			// However, netbsd has a kernel bug that sometimes
    			// misses netpollBreak wake-ups, which can lead to
    			// unbounded delays servicing timers. If we detect this
    			// overrun, then startm to get something to handle the
    			// timer.
    			//
    			// See issue 42515 and
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  3. pkg/volume/util/operationexecutor/operation_generator.go

    			klog.V(2).InfoS("MountVolume.markDeviceErrorState leaving volume uncertain", "volumeName", volumeToMount.VolumeName)
    			return
    		}
    
    		// Only devices which were uncertain can be marked as unmounted
    		markDeviceUnmountError := actualStateOfWorld.MarkDeviceAsUnmounted(volumeToMount.VolumeName)
    		if markDeviceUnmountError != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  4. pkg/controller/job/job_controller_test.go

    		t.Run(name, func(t *testing.T) {
    			uncounted := newUncountedTerminatedPods(*tc.job.Status.UncountedTerminatedPods)
    			jobCtx := &syncJobCtx{job: &tc.job, pods: tc.pods, uncounted: uncounted, expectedRmFinalizers: tc.expectedRmFinalizers}
    			succeededPods, failedPods := getNewFinishedPods(jobCtx)
    			succeeded := int32(len(succeededPods)) + tc.job.Status.Succeeded + int32(len(uncounted.succeeded))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  5. pkg/scheduler/schedule_one_test.go

    		},
    		{
    			name: "unbound/no matches",
    			volumeBinderConfig: &volumebinding.FakeVolumeBinderConfig{
    				FindReasons: volumebinding.ConflictReasons{volumebinding.ErrReasonBindConflict},
    			},
    			eventReason: "FailedScheduling",
    			expectError: makePredicateError("1 node(s) didn't find available persistent volumes to bind"),
    		},
    		{
    			name: "bound and unbound unsatisfied",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet.go

    	kl.statusManager.SetPodStatus(pod, apiPodStatus)
    
    	// volumes are unmounted after the pod worker reports ShouldPodRuntimeBeRemoved (which is satisfied
    	// before syncTerminatedPod is invoked)
    	if err := kl.volumeManager.WaitForUnmount(ctx, pod); err != nil {
    		return err
    	}
    	klog.V(4).InfoS("Pod termination unmounted volumes", "pod", klog.KObj(pod), "podUID", pod.UID)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  7. pkg/apis/batch/validation/validation_test.go

    				{Type: field.ErrorTypeInvalid, Field: "status.ready"},
    				{Type: field.ErrorTypeInvalid, Field: "status.terminating"},
    			},
    		},
    		"empty and duplicated uncounted pods": {
    			old: batch.Job{
    				ObjectMeta: metav1.ObjectMeta{
    					Name:            "abc",
    					Namespace:       metav1.NamespaceDefault,
    					ResourceVersion: "5",
    				},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 124.3K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_test.go

    			if len(podVolumes) != 0 {
    				return false, nil
    			}
    
    			return true, nil
    		},
    	)
    
    	if err != nil {
    		return fmt.Errorf(
    			"Expected volumes to be unmounted. But some volumes are still mounted: %#v", podVolumes)
    	}
    
    	return nil
    }
    
    func waitForVolumeDetach(
    	volumeName v1.UniqueVolumeName,
    	volumeManager kubeletvolume.VolumeManager) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_pods.go

    	for uid, val := range cgroupPods {
    		// if the pod is in the running set, its not a candidate for cleanup
    		if _, ok := possiblyRunningPods[uid]; ok {
    			continue
    		}
    
    		// If volumes have not been unmounted/detached, do not delete the cgroup
    		// so any memory backed volumes don't have their charges propagated to the
    		// parent croup.  If the volumes still exist, reduce the cpu shares for any
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/tensorflow/transforms/tf_passes.td

        and sets the shape of these inputs to be dynamic shaped. This will ensure
        that the generated HLO program is correctly reflecting the dynamic shape.
      }];
    
      // Required for mhlo bounded shape extension.
      let dependentDialects = ["mhlo::MhloDialect"];
      let constructor = "TFTPU::CreateTPUAnnotateDynamicShapeInputsPass()";
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Jun 12 21:18:05 UTC 2024
    - 99.6K bytes
    - Viewed (0)
Back to top