Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 186 for Equal (0.02 seconds)

  1. cmd/bucket-replication-utils.go

    	ResetStatusesMap           map[string]string                 // map of ARN-> stringified reset id and timestamp for all the targets
    }
    
    // Equal returns true if replication state is identical for version purge statuses and (replica)tion statuses.
    func (rs *ReplicationState) Equal(o ReplicationState) bool {
    	return rs.ReplicaStatus == o.ReplicaStatus &&
    		rs.ReplicationStatusInternal == o.ReplicationStatusInternal &&
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  2. cmd/erasure-healing_test.go

    	nfi, err := getLatestFileInfo(ctx, fileInfos, er.defaultParityCount, errs)
    	if err != nil {
    		t.Fatalf("Failed to getLatestFileInfo - %v", err)
    	}
    
    	if !reflect.DeepEqual(fi, nfi) {
    		t.Fatalf("FileInfo not equal after healing: %v != %v", fi, nfi)
    	}
    
    	err = firstDisk.Delete(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 48.5K bytes
    - Click Count (0)
  3. internal/s3select/sql/timestampfuncs_test.go

    	}
    	for i, tc := range cases {
    		tval, err := parseSQLTimestamp(tc.s)
    		if err != nil {
    			t.Errorf("Case %d: Unexpected error: %v", i+1, err)
    			continue
    		}
    		if !tval.Equal(tc.t) {
    			t.Errorf("Case %d: Expected %v got %v", i+1, tc.t, tval)
    			continue
    		}
    
    		tstr := FormatSQLTimestamp(tc.t)
    		if tstr != tc.s {
    			t.Errorf("Case %d: Expected %s got %s", i+1, tc.s, tstr)
    			continue
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.2K bytes
    - Click Count (0)
  4. cmd/xl-storage-format-v2_test.go

    	failOnErr(err)
    	if len(list) != 2 {
    		t.Fatalf("want 1 entry, got %d", len(list))
    	}
    
    	if !bytes.Equal(xl2.data.find("756100c6-b393-4981-928a-d49bbc164741"), data) {
    		t.Fatal("Find data returned", xl2.data.find("756100c6-b393-4981-928a-d49bbc164741"))
    	}
    	if !bytes.Equal(xl2.data.find(fi.VersionID), data2) {
    		t.Fatal("Find data returned", xl2.data.find(fi.VersionID))
    	}
    
    	// Remove entry
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37.8K bytes
    - Click Count (0)
  5. cmd/data-usage_test.go

    		}
    	}
    }
    
    // equalAsJSON returns whether the values are equal when encoded as JSON.
    func equalAsJSON(a, b any) bool {
    	aj, err := json.Marshal(a)
    	if err != nil {
    		panic(err)
    	}
    	bj, err := json.Marshal(b)
    	if err != nil {
    		panic(err)
    	}
    	return bytes.Equal(aj, bj)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  6. cmd/signature-v4.go

    		return doesPolicySignatureV2Match(formValues)
    	}
    	return doesPolicySignatureV4Match(formValues)
    }
    
    // compareSignatureV4 returns true if and only if both signatures
    // are equal. The signatures are expected to be HEX encoded strings
    // according to the AWS S3 signature V4 spec.
    func compareSignatureV4(sig1, sig2 string) bool {
    	// The CTC using []byte(str) works because the hex encoding
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Dec 13 22:19:12 GMT 2024
    - 12.4K bytes
    - Click Count (0)
  7. cmd/xl-storage-free-version.go

    func (j xlMetaV2Object) InitFreeVersion(fi FileInfo) (xlMetaV2Version, bool) {
    	if fi.SkipTierFreeVersion() {
    		return xlMetaV2Version{}, false
    	}
    	if status, ok := j.MetaSys[ReservedMetadataPrefixLower+TransitionStatus]; ok && bytes.Equal(status, []byte(lifecycle.TransitionComplete)) {
    		vID, err := uuid.Parse(fi.TierFreeVersionID())
    		if err != nil {
    			panic(fmt.Errorf("Invalid Tier Object delete marker versionId %s %v", fi.TierFreeVersionID(), err))
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 3.4K bytes
    - Click Count (0)
  8. internal/config/crypto_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to decrypt stream: %v", i, err)
    		}
    		data, err = io.ReadAll(plaintext)
    		if err != nil {
    			t.Fatalf("Test %d: failed to decrypt stream: %v", i, err)
    		}
    
    		if !bytes.Equal(data, test.Data) {
    			t.Fatalf("Test %d: decrypted data does not match original data", i)
    		}
    	}
    }
    
    func BenchmarkEncrypt(b *testing.B) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  9. docs/debugging/xl-meta/main.go

    	if len(buf) <= 8 {
    		return payload, 0, 0, fmt.Errorf("xlMeta: no data")
    	}
    
    	if !bytes.Equal(buf[:4], xlHeader[:]) {
    		return payload, 0, 0, fmt.Errorf("xlMeta: unknown XLv2 header, expected %v, got %v", xlHeader[:4], buf[:4])
    	}
    
    	if bytes.Equal(buf[4:8], []byte("1   ")) {
    		// Set as 1,0.
    		major, minor = 1, 0
    	} else {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.4K bytes
    - Click Count (0)
  10. src/bufio/bufio_test.go

    	l := NewReaderSize(buf, minReadBufferSize)
    	line, isPrefix, err := l.ReadLine()
    	if !isPrefix || !bytes.Equal(line, data[:minReadBufferSize]) || err != nil {
    		t.Errorf("bad result for first line: got %q want %q %v", line, data[:minReadBufferSize], err)
    	}
    	data = data[len(line):]
    	line, isPrefix, err = l.ReadLine()
    	if !isPrefix || !bytes.Equal(line, data[:minReadBufferSize]) || err != nil {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
Back to Top