Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for LastError (0.13 sec)

  1. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/TransformErrorHandler.java

            ClassNotFoundException lastError = getLastErrorAndClear();
            if (lastError != null) {
                throw new ClassNotFoundException(
                    "A pending instrumentation exception prevented loading a class " + className + " in " + classLoaderName, lastError);
            }
        }
    
        /**
         * Call this when an error occurs during class loading.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/phases/upgrade/health.go

    		if err != nil {
    			klog.V(2).Infof("Could not list Nodes with field selector %q: %v", fieldSelector, err)
    			lastError = err
    			return false, nil
    		}
    		return true, nil
    	})
    	if err != nil {
    		return errors.Wrap(lastError, "could not check if there is at least one Node that can schedule a test Pod")
    	}
    
    	if len(nodes.Items) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 09:18:02 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/apiclient/wait.go

    			if err != nil {
    				lastError = formatError(fmt.Sprintf("error: %v", err))
    				return false, err
    			}
    			resp, err := client.Do(req)
    			if err != nil {
    				lastError = formatError(fmt.Sprintf("error: %v", err))
    				return false, nil
    			}
    			defer func() {
    				_ = resp.Body.Close()
    			}()
    			if resp.StatusCode != http.StatusOK {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go

    		defer lock.RUnlock()
    
    		if clientErr != nil {
    			return clientErr
    		}
    		if limiter.Allow() == false {
    			return lastError.Load()
    		}
    		ctx, cancel := context.WithTimeout(context.Background(), timeout)
    		defer cancel()
    		now := time.Now()
    		err := prober.Probe(ctx)
    		lastError.Store(err, now)
    		return err
    	}, nil
    }
    
    func newETCD3ProberMonitor(c storagebackend.Config) (*etcd3ProberMonitor, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:56:39 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  5. internal/rest/client.go

    }
    
    // LastConn returns when the disk was (re-)connected
    func (c *Client) LastConn() time.Time {
    	return time.Unix(0, atomic.LoadInt64(&c.lastConn))
    }
    
    // LastError returns previous error
    func (c *Client) LastError() error {
    	c.RLock()
    	defer c.RUnlock()
    	return fmt.Errorf("[%s] %w", c.lastErrTime.Format(time.RFC3339), c.lastErr)
    }
    
    // computes the exponential backoff duration according to
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/phases/kubeconfig/kubeconfig.go

    					crbExists = true
    					return true, nil
    				} else {
    					// Retry on any other error type.
    					lastError = errors.Wrap(err, "unable to create ClusterRoleBinding")
    					return false, nil
    				}
    			}
    			crbExists = true
    			return true, nil
    		})
    	if err != nil {
    		return nil, lastError
    	}
    
    	// The CRB was created or already existed; return the admin.conf client.
    	if crbExists {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:04:18 UTC 2024
    - 27K bytes
    - Viewed (0)
Back to top