Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for lastErr (0.12 sec)

  1. pkg/controlplane/apiserver/config.go

    	lastErr error,
    ) {
    	genericConfig = genericapiserver.NewConfig(legacyscheme.Codecs)
    	genericConfig.MergedResourceConfig = resourceConfig
    
    	if lastErr = s.GenericServerRunOptions.ApplyTo(genericConfig); lastErr != nil {
    		return
    	}
    
    	if lastErr = s.SecureServing.ApplyTo(&genericConfig.SecureServing, &genericConfig.LoopbackClientConfig); lastErr != nil {
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/util/apiclient/wait.go

    		true, func(_ context.Context) (bool, error) {
    			hash, err := getStaticPodSingleHash(w.client, nodeName, component)
    			if err != nil {
    				lastErr = err
    				return false, nil
    			}
    			// Set lastErr to nil to be able to later distinguish between getStaticPodSingleHash() and timeout errors
    			lastErr = nil
    			// We should continue polling until the UID changes
    			if hash == previousHash {
    				return false, nil
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/runtime/runtime.go

    			if err := runtime.impl.RemovePodSandbox(ctx, runtime.runtimeService, container); err != nil {
    				lastErr = errors.Wrapf(err, "failed to remove pod %s", container)
    				cancel()
    				continue
    			}
    			cancel()
    
    			lastErr = nil
    			break
    		}
    
    		if lastErr != nil {
    			errs = append(errs, lastErr)
    		}
    	}
    	return errorsutil.NewAggregate(errs)
    }
    
    // PullImage pulls the image
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 06:33:22 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    			}
    			// Unmount runs in a go routine, wait for its finish
    			var lastErr error
    			err = retryWithExponentialBackOff(testOperationBackOffDuration, func() (bool, error) {
    				if err := verifyTearDownCalls(fakePlugin, tc.expectedUnmounts); err != nil {
    					lastErr = err
    					return false, nil
    				}
    				return true, nil
    			})
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  5. pkg/volume/util/atomic_writer.go

    	ps := string(os.PathSeparator)
    	var lasterr error
    	for p := range paths {
    		// only remove symlinks from the volume root directory (i.e. items that don't contain '/')
    		if strings.Contains(p, ps) {
    			continue
    		}
    		if err := os.Remove(filepath.Join(w.targetDir, p)); err != nil {
    			klog.Errorf("%s: error pruning old user-visible path %s: %v", w.logContext, p, err)
    			lasterr = err
    		}
    	}
    
    	return lasterr
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  6. pkg/volume/util/util.go

    func GetReliableMountRefs(mounter mount.Interface, mountPath string) ([]string, error) {
    	var paths []string
    	var lastErr error
    	err := wait.PollImmediate(10*time.Millisecond, time.Minute, func() (bool, error) {
    		var err error
    		paths, err = mounter.GetMountRefs(mountPath)
    		if io.IsInconsistentReadError(err) {
    			lastErr = err
    			return false, nil
    		}
    		if err != nil {
    			return false, err
    		}
    		return true, nil
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/sys/windows/zsyscall_windows.go

    	r0, _, _ := syscall.Syscall(procGetLargePageMinimum.Addr(), 0, 0, 0, 0)
    	size = uintptr(r0)
    	return
    }
    
    func GetLastError() (lasterr error) {
    	r0, _, _ := syscall.Syscall(procGetLastError.Addr(), 0, 0, 0, 0)
    	if r0 != 0 {
    		lasterr = syscall.Errno(r0)
    	}
    	return
    }
    
    func GetLogicalDriveStrings(bufferLength uint32, buffer *uint16) (n uint32, err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 195.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    		expectedEvent   *watch.Event
    	}{
    		{
    			name:            "RV-1",
    			resourceVersion: lastRV - 1,
    			expectedEvent:   &watch.Event{Type: watch.Error, Object: &expectedResourceExpiredError},
    		},
    		{
    			name:            "RV",
    			resourceVersion: lastRV,
    		},
    		{
    			name:            "RV+1",
    			resourceVersion: lastRV + 1,
    		},
    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  9. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KaFirResolver.kt

            fir: FirFunctionCall,
            arrayAccessExpression: KtArrayAccessExpression,
            incDecPrecedence: KaCompoundAccess.IncOrDecOperation.Precedence,
        ): CompoundArrayAccessPartiallyAppliedSymbols? {
            val lastArg = fir.arguments.lastOrNull() ?: return null
            val setPartiallyAppliedSymbol = fir.toPartiallyAppliedSymbol(arrayAccessExpression.arrayExpression) ?: return null
            return when (incDecPrecedence) {
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Tue Jun 11 15:45:42 UTC 2024
    - 73K bytes
    - Viewed (0)
Back to top