- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 336 for aloop (0.06 sec)
-
src/image/jpeg/reader_test.go
// to return an error. The Start Of Frame marker gives the image dimensions // as 8192 wide and 8192 high, so even if an unreadByteStuffedByte bug // doesn't technically lead to an infinite loop, such a bug can still cause // an unreasonably long loop for such a short input. const input = "" + "\xff\xd8\xff\xe0\x00\x10\x4a\x46\x49\x46\x00\x01\x01\x00\x00\x01" + "\x00\x01\x00\x00\xff\xdb\x00\x43\x00\x10\x0b\x0c\x0e\x0c\x0a\x10" +
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 25 00:46:29 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
"k8s.io/kubernetes/pkg/kubelet/pluginmanager/operationexecutor" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher" ) const ( // reconcilerLoopSleepDuration is the amount of time the reconciler loop // waits between successive executions reconcilerLoopSleepDuration time.Duration = 1 * time.Nanosecond ) var ( socketDir string supportedVersions = []string{"v1beta1", "v1beta2"} )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi.go
// This function is not idempotent by design. We want the data to be refreshed periodically. // The internal sync interval of kubelet will drive the refresh of data. // TODO: Add volume specific ticker and refresh loop func (b *downwardAPIVolumeMounter) SetUp(mounterArgs volume.MounterArgs) error { return b.SetUpAt(b.GetPath(), mounterArgs) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
src/cmd/compile/internal/types2/decl.go
obj.typ = Typ[Invalid] } case *TypeName: if !check.validCycle(obj) { // break cycle // (without this, calling underlying() // below may lead to an endless loop // if we have a cycle for a defined // (*Named) type) obj.typ = Typ[Invalid] } case *Func: if !check.validCycle(obj) { // Don't set obj.typ to Typ[Invalid] here
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 29.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
return err } span.AddEvent("Encode succeeded", attribute.Int("len", len(data))) if !origState.stale && bytes.Equal(data, origState.data) { // if we skipped the original Get in this loop, we must refresh from // etcd in order to be sure the data in the store is equivalent to // our desired serialization if !origStateIsCurrent { origState, err = getCurrentState() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
return lifecycle.PodAdmitResult{ Admit: false, Reason: Reason, Message: fmt.Sprintf(nodeConditionMessageFmt, m.nodeConditions), } } // Start starts the control loop to observe and response to low compute resources. func (m *managerImpl) Start(diskInfoProvider DiskInfoProvider, podFunc ActivePodsFunc, podCleanedUpFunc PodCleanedUpFunc, monitoringInterval time.Duration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0) -
pkg/volume/local/local.go
klog.Errorf("IsNotMountPoint check failed: %v", mntErr) return err } if !notMnt { // This is very odd, we don't expect it. We'll try again next sync loop. klog.Errorf("%s is still mounted, despite call to unmount(). Will try again next sync loop.", dir) return err } } if rmErr := os.Remove(dir); rmErr != nil { klog.Warningf("failed to remove %s: %v", dir, rmErr) } return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/compile.go
{name: "flagalloc", fn: flagalloc, required: true}, // allocate flags register {name: "regalloc", fn: regalloc, required: true}, // allocate int & float registers + stack slots {name: "loop rotate", fn: loopRotate}, {name: "trim", fn: trim}, // remove empty blocks } // Double-check phase ordering constraints. // This code is intended to document the ordering requirements
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:55:18 UTC 2024 - 18.6K bytes - Viewed (0) -
hack/golangci.yaml
exclude-use-default: false exclude: # staticcheck: Developers tend to write in C-style with an explicit 'break' in a 'switch', so it's ok to ignore - ineffective break statement. Did you mean to break out of the outer loop # Excluding configuration per-path, per-linter, per-text and per-source exclude-rules: # exclude ineffassign linter for generated files for conversion - path: conversion\.go linters:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 12:10:09 UTC 2024 - 9.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
return } // doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, ctx.Done()) <-ctx.Done() } // // RunOnce runs a single sync loop func (c *RequestHeaderAuthRequestController) RunOnce(ctx context.Context) error { configMap, err := c.client.CoreV1().ConfigMaps(c.configmapNamespace).Get(ctx, c.configmapName, metav1.GetOptions{}) switch {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0)