Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 859 for err (0.02 sec)

  1. cmd/dummy-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Validate if bucket exists, before proceeding further...
    	_, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrNoSuchWebsiteConfiguration), r.URL)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  2. cmd/background-newdisks-heal-ops.go

    	}
    	diskID, err := disk.GetDiskID()
    	if err != nil {
    		return nil, err
    	}
    	b, err := disk.ReadAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename))
    	if err != nil {
    		return nil, err
    	}
    	var h healingTracker
    	_, err = h.UnmarshalMsg(b)
    	if err != nil {
    		return nil, err
    	}
    	if h.ID != diskID && h.ID != "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. cmd/acl-handlers.go

    	// Before proceeding validate if bucket exists.
    	_, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	aclHeader := r.Header.Get(xhttp.AmzACL)
    	if aclHeader == "" {
    		acl := &accessControlPolicy{}
    		if err = xmlDecoder(r.Body, acl, r.ContentLength); err != nil {
    			if terr, ok := err.(*xml.SyntaxError); ok && terr.Msg == io.EOF.Error() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. internal/config/scanner/scanner.go

    	}
    	cfg.MaxWait, err = time.ParseDuration(maxWait)
    	if err != nil {
    		return err
    	}
    	cycle := env.Get(EnvCycle, kvs.GetWithDefault(Cycle, DefaultKVS))
    	if cycle == "" {
    		cycle = "1m"
    	}
    	cfg.Cycle, err = time.ParseDuration(cycle)
    	if err != nil {
    		return err
    	}
    	return nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. internal/mountinfo/mountinfo_linux_test.go

    		`
    	var err error
    	dir := t.TempDir()
    	mountsPath := filepath.Join(dir, "mounts")
    	if err = os.WriteFile(mountsPath, []byte(successCase), 0o666); err != nil {
    		t.Fatal(err)
    	}
    	mounts, err := readProcMounts(mountsPath)
    	if err != nil {
    		t.Fatal(err)
    	}
    	// Failure case where we detected successfully cross device mounts.
    	{
    		if err = mounts.checkCrossMounts("/path/to/1"); err == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2.go

    	var tHdr, tMeta []byte // Zero copy bytes
    	for i := 0; i < versions; i++ {
    		tHdr, buf, err = msgp.ReadBytesZC(buf)
    		if err != nil {
    			return err
    		}
    		tMeta, buf, err = msgp.ReadBytesZC(buf)
    		if err != nil {
    			return err
    		}
    		if err = fn(i, tHdr, tMeta); err != nil {
    			if err == errDoneForNow {
    				err = nil
    			}
    			return err
    		}
    	}
    	return nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common_test.go

    		},
    	}
    
    	bucket := "bucket"
    	err = obj.MakeBucket(ctx, "bucket", MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("Failed to make a bucket %v", err)
    	}
    
    	object := "object"
    	data := bytes.Repeat([]byte("a"), smallFileThreshold*32)
    	z := obj.(*erasureServerPools)
    
    	erasureDisks, err := z.GetDisks(0, 0)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for i, test := range testCases {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. internal/dsync/dsync-client_test.go

    	buf, err := args.MarshalMsg(nil)
    	if err != nil {
    		return false, err
    	}
    	body := bytes.NewReader(buf)
    	respBody, err := restClient.rest.Call(context.Background(), method,
    		url.Values{}, body, body.Size())
    	defer xhttp.DrainBody(respBody)
    
    	switch toLockError(err) {
    	case nil:
    		return true, nil
    	case errLockConflict, errLockNotFound:
    		return false, nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  9. internal/etag/etag_test.go

    }
    
    func TestEqual(t *testing.T) {
    	for i, test := range equalTests {
    		A, err := Parse(test.A)
    		if err != nil {
    			t.Fatalf("Test %d: %v", i, err)
    		}
    		B, err := Parse(test.B)
    		if err != nil {
    			t.Fatalf("Test %d: %v", i, err)
    		}
    		if equal := Equal(A, B); equal != test.Equal {
    			t.Fatalf("Test %d: got %v - want %v", i, equal, test.Equal)
    		}
    	}
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  10. docs/debugging/s3-check-md5/main.go

    		}
    	}
    
    	u, err := url.Parse(endpoint)
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	secure := strings.EqualFold(u.Scheme, "https")
    	transport, err := minio.DefaultTransport(secure)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	if insecure {
    		// skip TLS verification
    		transport.TLSClientConfig.InsecureSkipVerify = true
    	}
    
    	s3Client, err := minio.New(u.Host, &minio.Options{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
Back to top