- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for because3 (0.16 sec)
-
pkg/scheduler/internal/queue/scheduling_queue_test.go
initialPods: []*v1.Pod{pod}, actions: []action{ // This Pod shouldn't be added to inFlightPods because SchedulingQueueHint is disabled. {podPopped: pod}, // This event shouldn't be added to inFlightEvents because SchedulingQueueHint is disabled. {eventHappens: &PvAdd}, }, wantInFlightPods: nil, wantInFlightEvents: nil,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
src/runtime/proc.go
func allGsSnapshot() []*g { assertWorldStoppedOrLockHeld(&allglock) // Because the world is stopped or allglock is held, allgadd // cannot happen concurrently with this. allgs grows // monotonically and existing entries never change, so we can // simply return a copy of the slice header. For added safety, // we trim everything past len because that can still change. return allgs[:len(allgs):len(allgs)] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
manager.thresholdNotifiers = []ThresholdNotifier{thresholdNotifier} // The UpdateThreshold method should be called because at least notifierRefreshInterval time has passed. // The Description method should be called because UpdateThreshold returned an error fakeClock.Step(2 * notifierRefreshInterval) _, err = manager.synchronize(diskInfoProvider, activePodsFunc) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
OperationFunc: volumesAreAttachedFunc, CompleteFunc: util.OperationCompleteHook(util.GetFullQualifiedPluginNameForVolume("<n/a>", nil), "verify_volumes_are_attached_per_node"), EventRecorderFunc: nil, // nil because we do not want to generate event on error }, nil } func (og *operationGenerator) GenerateAttachVolumeFunc( logger klog.Logger, volumeToAttach VolumeToAttach,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
lastStatusReportTime time.Time // syncNodeStatusMux is a lock on updating the node status, because this path is not thread-safe. // This lock is used by Kubelet.syncNodeStatus and Kubelet.fastNodeStatusUpdate functions and shouldn't be used anywhere else. syncNodeStatusMux sync.Mutex // updatePodCIDRMux is a lock on updating pod CIDR, because this path is not thread-safe.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// One common case this prevents is a kubelet restart reading pods before services and some pod not having the // KUBERNETES_SERVICE_HOST injected because we didn't wait a short time for services to sync before proceeding. // The KUBERNETES_SERVICE_HOST link is special because it is unconditionally injected into pods and is read by the // in-cluster-config for pod clients if !kubetypes.IsStaticPod(pod) && !kl.serviceHasSynced() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
// Makes testing simpler. func matchPodName(names ...string) storage.SelectionPredicate { // Note: even if pod name is a field, we have to use labels, // because field selector doesn't support "IN" operator. l, err := labels.NewRequirement("name", selection.In, names) if err != nil { panic("Labels requirement must validate successfully") } return storage.SelectionPredicate{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
src/reflect/value.go
// (as opposed to a zero value received because the channel is closed). // Select supports a maximum of 65536 cases. func Select(cases []SelectCase) (chosen int, recv Value, recvOK bool) { if len(cases) > 65536 { panic("reflect.Select: too many cases (max 65536)") } // NOTE: Do not trust that caller is not modifying cases data underfoot. // The range is safe because the caller cannot modify our copy of the len
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 119.9K bytes - Viewed (0) -
src/cmd/go/internal/load/pkg.go
// even IgnoredGoFiles, because some subcommands consider them. // The go/build package filtered others out (like foo_wrongGOARCH.s) // and that's OK. func (p *Package) AllFiles() []string { files := str.StringList( p.GoFiles, p.CgoFiles, // no p.CompiledGoFiles, because they are from GoFiles or generated by us p.IgnoredGoFiles, // no p.InvalidGoFiles, because they are from GoFiles p.IgnoredOtherFiles,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 28 17:00:51 UTC 2024 - 120K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Maps.java
// independent of the initial capacity, except that it won't be lower than the threshold // computed from that capacity. Because the internal table is only allocated on the first // write, we won't see copying because of the new threshold. So it is always OK to use the // calculation here. return (int) Math.ceil(expectedSize / 0.75); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 159.5K bytes - Viewed (0)