Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 1,020 for err (0.03 sec)

  1. src/archive/zip/register.go

    func (w *pooledFlateWriter) Write(p []byte) (n int, err error) {
    	w.mu.Lock()
    	defer w.mu.Unlock()
    	if w.fw == nil {
    		return 0, errors.New("Write after Close")
    	}
    	return w.fw.Write(p)
    }
    
    func (w *pooledFlateWriter) Close() error {
    	w.mu.Lock()
    	defer w.mu.Unlock()
    	var err error
    	if w.fw != nil {
    		err = w.fw.Close()
    		flateWriterPool.Put(w.fw)
    		w.fw = nil
    	}
    	return err
    }
    
    var flateReaderPool sync.Pool
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  2. cmd/postpolicyform_test.go

    		policyBytes, err := base64.StdEncoding.DecodeString(base64.StdEncoding.EncodeToString([]byte(pp.String())))
    		if err != nil {
    			t.Fatal(err)
    		}
    
    		postPolicyForm, err := parsePostPolicyForm(bytes.NewReader(policyBytes))
    		if err != nil {
    			t.Fatal(err)
    		}
    
    		err = checkPostPolicy(formValues, postPolicyForm)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 8.9K bytes
    - Viewed (0)
  3. istioctl/pkg/install/k8sversion/version.go

    func CheckKubernetesVersion(versionInfo *version.Info) (bool, error) {
    	v, err := extractKubernetesVersion(versionInfo)
    	if err != nil {
    		return false, err
    	}
    	return MinK8SVersion <= v, nil
    }
    
    // extractKubernetesVersion returns the Kubernetes minor version. For example, `v1.19.1` will return `19`
    func extractKubernetesVersion(versionInfo *version.Info) (int, error) {
    	ver, err := goversion.NewVersion(versionInfo.String())
    	if err != nil {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Wed Oct 30 21:50:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  4. cmd/metrics-realtime.go

    			}
    		}
    		cpuCount, err := c.Counts(true)
    		if err != nil {
    			m.Errors = append(m.Errors, fmt.Sprintf("%s: %v (cpuCount)", byHostName, err.Error()))
    		} else {
    			m.Aggregated.CPU.CPUCount = cpuCount
    		}
    
    		loadStat, err := load.Avg()
    		if err != nil {
    			m.Errors = append(m.Errors, fmt.Sprintf("%s: %v (loadStat)", byHostName, err.Error()))
    		} else {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. cmd/storage-errors.go

    // interpretation.
    func osErrToFileErr(err error) error {
    	if err == nil {
    		return nil
    	}
    	if osIsNotExist(err) {
    		return errFileNotFound
    	}
    	if osIsPermission(err) {
    		return errFileAccessDenied
    	}
    	if isSysErrNotDir(err) || isSysErrIsDir(err) {
    		return errFileNotFound
    	}
    	if isSysErrPathNotFound(err) {
    		return errFileNotFound
    	}
    	if isSysErrTooManyFiles(err) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    	if err := h.queueHealTask(healSource{bucket: bucket}, madmin.HealItemBucket); err != nil {
    		return err
    	}
    
    	if bucketsOnly {
    		return nil
    	}
    
    	if !h.settings.Recursive {
    		if h.object != "" {
    			if err := h.healObject(bucket, h.object, "", h.settings.ScanMode); err != nil {
    				return err
    			}
    		}
    
    		return nil
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  7. docs/debugging/pprofgoparser/main.go

    func main() {
    	flag.Parse()
    
    	if len(flag.Args()) == 0 {
    		log.Fatal(helpUsage)
    	}
    
    	var err error
    
    	goroutinesRE = regexp.MustCompile(`^goroutine [0-9]+ \[[^,]+(, ([0-9]+) minutes)?\]:$`)
    
    	if searchText != "" {
    		searchRE, err = regexp.Compile(searchText)
    		if err != nil {
    			log.Fatal(err)
    		}
    	}
    
    	for _, arg := range flag.Args() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Mar 06 11:43:16 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  8. cmd/ftp-server.go

    		PassivePorts:   portRange,
    		PublicIP:       publicIP,
    	})
    	if err != nil {
    		logger.Fatal(err, "unable to initialize FTP server")
    	}
    
    	logger.Info(fmt.Sprintf("%s listening on %s", name, net.JoinHostPort(publicIP, strconv.Itoa(port))))
    
    	if err = ftpServer.ListenAndServe(); err != nil {
    		logger.Fatal(err, "unable to start FTP server")
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Mar 09 03:07:08 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  9. docs/erasure/storage-class/README.md

    ```go
    s3Client, err := minio.New("localhost:9000", "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY", true)
    if err != nil {
     log.Fatalln(err)
    }
    
    object, err := os.Open("my-testfile")
    if err != nil {
     log.Fatalln(err)
    }
    defer object.Close()
    objectStat, err := object.Stat()
    if err != nil {
     log.Fatalln(err)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-utils_test.go

    			allVersionIDs = append(allVersionIDs, fi.VersionID)
    		}
    	}
    	buf, err := xl.AppendTo(nil)
    	if err != nil {
    		t.Fatalf("Failed to serialize xlmeta %v", err)
    	}
    	fivs, err := getFileInfoVersions(buf, basefi.Volume, basefi.Name, false)
    	if err != nil {
    		t.Fatalf("getFileInfoVersions failed: %v", err)
    	}
    	chkNumVersions := func(fis []FileInfo) bool {
    		for i := 0; i < len(fis)-1; i++ {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top