Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 146 for Dispatch (0.08 sec)

  1. cmd/erasure-healing-common_test.go

    			t.Errorf("Drive erroneously filtered, driveIndex: %d", diskIndex)
    		}
    	}
    	partsMetadata[1] = partsMetadataBackup // Revert before going to the next test
    
    	// Test 4: key = disk index, value = part name with hash mismatch
    	erasureDisks = s.getDisks()
    	diskFailures := make(map[int]string)
    	diskFailures[0] = "part.1"
    	diskFailures[3] = "part.1"
    	diskFailures[15] = "part.1"
    
    	for diskIndex, partName := range diskFailures {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  2. cmd/object-api-putobject_test.go

    		// Valid object and bucket names but non-existent bucket.
    		5: {bucketName: "abc", objName: "def", inputData: []byte(""), expectedError: BucketNotFound{Bucket: "abc"}},
    
    		// Input to replicate Md5 mismatch.
    		6: {
    			bucketName: bucket, objName: object, inputData: []byte(""),
    			inputMeta:     map[string]string{"etag": "d41d8cd98f00b204e9800998ecf8427f"},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  3. cmd/metacache-entries.go

    func (e metaCacheEntry) hasPrefix(s string) bool {
    	return strings.HasPrefix(e.name, s)
    }
    
    // matches returns if the entries have the same versions.
    // If strict is false we allow signatures to mismatch.
    func (e *metaCacheEntry) matches(other *metaCacheEntry, strict bool) (prefer *metaCacheEntry, matches bool) {
    	if e == nil && other == nil {
    		return nil, true
    	}
    	if e == nil {
    		return other, false
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  4. cmd/api-errors.go

    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrSiteReplicationIAMConfigMismatch: {
    		Code:           "XMinioSiteReplicationIAMConfigMismatch",
    		Description:    "IAM configuration mismatch between sites",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrAdminRebalanceAlreadyStarted: {
    		Code:           "XMinioAdminRebalanceAlreadyStarted",
    		Description:    "Pool rebalance is already started",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 93K bytes
    - Viewed (1)
  5. cmd/site-replication.go

    		Cause: err,
    		Code:  ErrSiteReplicationConfigMissing,
    	}
    }
    
    func errSRIAMConfigMismatch(peer1, peer2 string, s1, s2 madmin.IDPSettings) SRError {
    	return SRError{
    		Cause: fmt.Errorf("IAM/IDP settings mismatch between %s and %s: %#v vs %#v", peer1, peer2, s1, s2),
    		Code:  ErrSiteReplicationIAMConfigMismatch,
    	}
    }
    
    var errSRObjectLayerNotReady = SRError{
    	Cause: fmt.Errorf("object layer not ready"),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  6. src/archive/zip/reader_test.go

    			rd, err := f.Open()
    			if err != nil {
    				t.Fatal(err)
    			}
    			defer rd.Close()
    
    			_, err = io.Copy(io.Discard, rd)
    			if err != ErrFormat {
    				t.Fatalf("Error mismatch\n\tGot:  %v\n\tWant: %v", err, ErrFormat)
    			}
    		})
    	}
    }
    
    func TestIssue54801(t *testing.T) {
    	for _, input := range []string{"testdata/readme.zip", "testdata/dd.zip"} {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Mar 11 22:19:38 UTC 2025
    - 56.6K bytes
    - Viewed (0)
  7. cmd/server_test.go

    	timeNow := time.Now().UTC()
    	c.Assert(creationTime.Before(timeNow), true)
    	c.Assert(timeNow.Sub(creationTime) < time.Minute*5, true)
    }
    
    // This tests validate if PUT handler can successfully detect signature mismatch.
    func (s *TestSuiteCommon) TestValidateSignature(c *check) {
    	// generate a random bucket name.
    	bucketName := getRandomBucketName()
    	// HTTP request to create the bucket.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118.1K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    		if opts.WantChecksum != nil && !opts.WantChecksum.Type.Is(checksumType) {
    			return oi, InvalidArgument{
    				Bucket: bucket,
    				Object: fi.Name,
    				Err:    fmt.Errorf("checksum type mismatch. got %q (%s) expected %q (%s)", checksumType.String(), checksumType.ObjType(), opts.WantChecksum.Type.String(), opts.WantChecksum.Type.ObjType()),
    			}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  9. cmd/object-api-utils.go

    	failOnErr(s2Reader.Skip(skip))
    	got, err := io.ReadAll(s2Reader)
    	failOnErr(err)
    	if !bytes.Equal(got, data[skip:]) {
    		logger.Fatal(errSelfTestFailure, "compress: self-test roundtrip mismatch.")
    	}
    }
    
    // getDiskInfos returns the disk information for the provided disks.
    // If a disk is nil or an error is returned the result will be nil as well.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  10. cmd/batch-handlers.go

    		pInfo, err = api.PutObjectPart(ctx, tgtBucket, tgtObject, res.UploadID, i+1, pReader, opts)
    		if err != nil {
    			return err
    		}
    		if pInfo.Size != objInfo.Size {
    			return fmt.Errorf("Part size mismatch: got %d, want %d", pInfo.Size, objInfo.Size)
    		}
    		uploadedParts = append(uploadedParts, CompletePart{
    			PartNumber: pInfo.PartNumber,
    			ETag:       pInfo.ETag,
    		})
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
Back to top