Search Options

Results per page
Sort
Preferred Languages
Advance

Results 541 - 550 of 859 for err (0.04 sec)

  1. cmd/copy-part-range.go

    // for full details. This function treats an empty rangeString as
    // referring to the whole resource.
    func parseCopyPartRangeSpec(rangeString string) (hrange *HTTPRangeSpec, err error) {
    	hrange, err = parseRequestRangeSpec(rangeString)
    	if err != nil {
    		return nil, err
    	}
    	if hrange.IsSuffixLength || hrange.Start < 0 || hrange.End < 0 {
    		return nil, errInvalidRange
    	}
    	return hrange, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 18 03:27:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  2. cmd/copy-part-range_test.go

    		if _, err := parseCopyPartRangeSpec(rangeString); err == nil {
    			t.Fatalf("expected: an error, got: <nil> for range %s", rangeString)
    		}
    	}
    
    	// Test error range strings.
    	errorRangeString := []string{
    		"bytes=10-10",
    		"bytes=20-30",
    	}
    	for _, rangeString := range errorRangeString {
    		rs, err := parseCopyPartRangeSpec(rangeString)
    		if err == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  3. finisher_api.go

    // returned to the connection pool.
    func (db *DB) Connection(fc func(tx *DB) error) (err error) {
    	if db.Error != nil {
    		return db.Error
    	}
    
    	tx := db.getInstance()
    	sqlDB, err := tx.DB()
    	if err != nil {
    		return
    	}
    
    	conn, err := sqlDB.Conn(tx.Statement.Context)
    	if err != nil {
    		return
    	}
    
    	defer conn.Close()
    	tx.Statement.ConnPool = conn
    	return fc(tx)
    }
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  4. docs/debugging/inspect/utils.go

    	}
    	// Try base 64
    	dst := make([]byte, base64.StdEncoding.DecodedLen(len(priv)))
    	if n, err := base64.StdEncoding.Decode(dst, priv); err == nil {
    		return x509.ParsePKCS1PrivateKey(dst[:n])
    	}
    	// Try Raw, return error
    	return x509.ParsePKCS1PrivateKey(priv)
    }
    
    func fatalErr(err error) {
    	if err == nil {
    		return
    	}
    	log.Fatalln(err)
    }
    
    func fatalIf(b bool, msg string, v ...interface{}) {
    	if !b {
    		return
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Nov 02 20:36:38 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  5. internal/bucket/lifecycle/tag.go

    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			var s string
    			if err = d.DecodeElement(&s, &se); err != nil {
    				return err
    			}
    			switch se.Name.Local {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  6. internal/ioutil/append-file_windows.go

    func AppendFile(dst string, src string, osync bool) error {
    	appendFile, err := lock.Open(dst, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0o666)
    	if err != nil {
    		return err
    	}
    	defer appendFile.Close()
    
    	srcFile, err := lock.Open(src, os.O_RDONLY, 0o666)
    	if err != nil {
    		return err
    	}
    	defer srcFile.Close()
    	_, err = io.Copy(appendFile, srcFile)
    	return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 1.2K bytes
    - Viewed (0)
  7. docs/site-replication/gen-oidc-sts-cred.go

    		ProviderURL:  "http://127.0.0.1:5556/dex",
    		RedirectURL:  "http://127.0.0.1:10000/oauth_callback",
    	}
    
    	oidcToken, err := cmd.MockOpenIDTestUserInteraction(ctx, appParams, "******@****.***", "dillon")
    	if err != nil {
    		log.Fatalf("Failed to generate OIDC token: %v", err)
    	}
    
    	roleARN := os.Getenv("ROLE_ARN")
    	webID := cr.STSWebIdentity{
    		Client:      &http.Client{},
    		STSEndpoint: endpoint,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 29 01:27:09 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  8. cmd/post-policy_test.go

    	if !corruptedMultipart {
    		var writer io.Writer
    		var err error
    		if noFilename {
    			writer, err = w.CreateFormField("file")
    		} else {
    			writer, err = w.CreateFormFile("file", "upload.txt")
    		}
    		if err != nil {
    			// return nil, err
    			return nil, err
    		}
    		writer.Write(objData)
    		// Close before creating the new request.
    		w.Close()
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. 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)
  10. internal/bucket/lifecycle/transition.go

    	var dateStr string
    	err := d.DecodeElement(&dateStr, &startElement)
    	if err != nil {
    		return err
    	}
    	// While AWS documentation mentions that the date specified
    	// must be present in ISO 8601 format, in reality they allow
    	// users to provide RFC 3339 compliant dates.
    	trnDate, err := time.Parse(time.RFC3339, dateStr)
    	if err != nil {
    		return errTransitionInvalidDate
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jan 10 17:07:49 UTC 2022
    - 5.1K bytes
    - Viewed (0)
Back to top