Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 43 for consistent (0.2 sec)

  1. operator/cmd/mesh/profile-dump_test.go

    			got, err := runProfileDump(inPath, tt.configPath, snapshotCharts, "")
    			if err != nil {
    				t.Fatal(err)
    			}
    			// installPackagePath may change, we will remove it for consistent output
    			got = installPackagePathRegex.ReplaceAllString(got, "")
    
    			if refreshGoldenFiles() {
    				t.Logf("Refreshing golden file for %s", outPath)
    				if err := os.WriteFile(outPath, []byte(got), 0o644); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jan 20 11:44:25 GMT 2022
    - 3.7K bytes
    - Viewed (0)
  2. cmd/erasure-sets_test.go

    		{"SHØRT", 49},
    		{"There are far too many object names, and far too few bucket names!", 8},
    		{"a/b/c/", 159},
    		{"/a/b/c", 96},
    		{string([]byte{0xff, 0xfe, 0xfd}), 147},
    	}
    
    	// Tests hashing order to be consistent.
    	for i, testCase := range testCases {
    		if sipHashElement := hashKey("SIPMOD", testCase.objectName, 200, testUUID); sipHashElement != testCase.sipHash {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 07:21:56 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  3. docs/debugging/hash-set/main.go

    	sum64 := siphash.Hash(k0, k1, []byte(key))
    	return int(sum64 % uint64(cardinality))
    }
    
    // hashOrder - hashes input key to return consistent
    // hashed integer slice. Returned integer order is salted
    // with an input key. This results in consistent order.
    // NOTE: collisions are fine, we are not looking for uniqueness
    // in the slices returned.
    func hashOrder(key string, cardinality int) []int {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.7K bytes
    - Viewed (0)
  4. cmd/erasure-healing-common_test.go

    			t.Errorf("Test case %d, expect to pass but failed. Wanted modTime: %s, got modTime: %s\n", i+1, testCase.time, ctime)
    		}
    	}
    }
    
    // TestListOnlineDisks - checks if listOnlineDisks and outDatedDisks
    // are consistent with each other.
    func TestListOnlineDisks(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, disks, err := prepareErasure16(ctx)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
  5. internal/s3select/csv/reader.go

    		ret.FieldsPerRecord = -1
    		// If LazyQuotes is true, a quote may appear in an unquoted field and a
    		// non-doubled quote may appear in a quoted field.
    		ret.LazyQuotes = true
    		// We do not trim leading space to keep consistent with s3.
    		ret.TrimLeadingSpace = false
    		ret.ReuseRecord = true
    		return ret
    	}
    
    	return r, r.startReaders(newCsvReader)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  6. cmd/peer-s3-client.go

    		if err == nil {
    			return healBucketResults[i], nil
    		}
    	}
    
    	return madmin.HealResultItem{}, toObjectErr(errVolumeNotFound, bucket)
    }
    
    // ListBuckets lists buckets across all nodes and returns a consistent view:
    //   - Return an error when a pool cannot return N/2+1 valid bucket information
    //   - For each pool, check if the bucket exists in N/2+1 nodes before including it in the final result
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    	case strings.Contains(err.Error(), "server closed idle connection"):
    		return true
    	}
    
    	return false
    }
    
    // Converts network error to storageErr. This function is
    // written so that the storageAPI errors are consistent
    // across network disks.
    func toStorageErr(err error) error {
    	if err == nil {
    		return nil
    	}
    
    	if isNetworkError(err) {
    		return errDiskNotFound
    	}
    
    	switch err.Error() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  8. cmd/site-replication.go

    	if !ok {
    		return nil, errors.New("site replication service account not found")
    	}
    	return &u.Credentials, nil
    }
    
    // listBuckets returns a consistent common view of latest unique buckets across
    // sites, this is used for replication.
    func (c *SiteReplicationSys) listBuckets(ctx context.Context) ([]BucketInfo, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  9. src/cmd/cgo/internal/test/issue26430.go

    // Copyright 2018 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    //go:build cgo
    
    // Issue 26430: incomplete typedef leads to inconsistent typedefs error.
    // No runtime test; just make sure it compiles.
    
    package cgotest
    
    Go
    - Registered: Tue Mar 26 11:13:08 GMT 2024
    - Last Modified: Fri May 12 12:00:02 GMT 2023
    - 359 bytes
    - Viewed (1)
  10. cmd/erasure-healing-common.go

    				// number of items than number of online disks.
    				inconsistent++
    				continue
    			}
    			if meta.Erasure.Distribution[i] != meta.Erasure.Index {
    				// Mismatch indexes with distribution order
    				inconsistent++
    			}
    		}
    	}
    
    	erasureDistributionReliable := true
    	if inconsistent > len(partsMetadata)/2 {
    		// If there are too many inconsistent files, then we can't trust erasure.Distribution (most likely
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.8K bytes
    - Viewed (0)
Back to top