NVIDIA
diff --git a/Collapse file
‎ais/bucketmeta_internal_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎ais/bucketmeta_internal_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎ais/emd_internal_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎ais/emd_internal_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎ais/metasync_internal_test.go‎
Copy file name to clipboard
+9-9Lines changed: 9 additions & 9 deletions b/Collapse file
‎ais/metasync_internal_test.go‎
Copy file name to clipboard
+9-9Lines changed: 9 additions & 9 deletions
diff --git a/Collapse file
‎ais/multiproxy_internal_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎ais/multiproxy_internal_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎ais/test/bucket_test.go‎
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions b/Collapse file
‎ais/test/bucket_test.go‎
Copy file name to clipboard
+4-4Lines changed: 4 additions & 4 deletions
diff --git a/Collapse file
‎ais/test/cp_multiobj_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎ais/test/cp_multiobj_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎ais/test/etl_tar2tf_test.go‎
Copy file name to clipboard
+2-2Lines changed: 2 additions & 2 deletions b/Collapse file
‎ais/test/etl_tar2tf_test.go‎
Copy file name to clipboard
+2-2Lines changed: 2 additions & 2 deletions
diff --git a/Collapse file
‎ais/test/etl_test.go‎
Copy file name to clipboard
+2-2Lines changed: 2 additions & 2 deletions b/Collapse file
‎ais/test/etl_test.go‎
Copy file name to clipboard
+2-2Lines changed: 2 additions & 2 deletions
diff --git a/Collapse file
‎ais/test/maintain_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎ais/test/maintain_test.go‎
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎ais/test/object_test.go‎
Copy file name to clipboard
+10-10Lines changed: 10 additions & 10 deletions b/Collapse file
‎ais/test/object_test.go‎
Copy file name to clipboard
+10-10Lines changed: 10 additions & 10 deletions
@@ -33,7 +33,7 @@ var _ = Describe("BMD marshal and unmarshal", func() {
 		// Set path for proxy (it uses ConfigDir)
 		config := cmn.GCO.BeginUpdate()
 		config.ConfigDir = mpath
-		config.Cksum.Type = cos.ChecksumXXHash
+		config.Cksum.Type = cos.ChecksumOneXxh
 		config.Space = cmn.SpaceConf{
 			LowWM: 75, HighWM: 90, OOS: 95,
 		}
 
@@ -52,7 +52,7 @@ var _ = Describe("EtlMD marshal and unmarshal", func() {
 		// Set path for proxy (it uses ConfigDir)
 		config := cmn.GCO.BeginUpdate()
 		config.ConfigDir = mpath
-		config.Cksum.Type = cos.ChecksumXXHash
+		config.Cksum.Type = cos.ChecksumOneXxh
 		config.Space = cmn.SpaceConf{
 			LowWM: 75, HighWM: 90, OOS: 95,
 		}
 
@@ -87,7 +87,7 @@ func newPrimary() *proxy {
 	config.Timeout.MaxKeepalive = cos.Duration(4 * time.Second)
 	config.Client.Timeout = cos.Duration(10 * time.Second)
 	config.Client.TimeoutLong = cos.Duration(10 * time.Second)
-	config.Cksum.Type = cos.ChecksumXXHash
+	config.Cksum.Type = cos.ChecksumOneXxh
 	cmn.GCO.CommitUpdate(config)
 	cmn.GCO.SetInitialGconfPath("/tmp/ais-tests/ais.config")
 
@@ -123,7 +123,7 @@ func newSecondary(name string) *proxy {
 	config.Keepalive.Proxy.Interval = cos.Duration(3 * time.Second)
 	config.Timeout.CplaneOperation = cos.Duration(2 * time.Second)
 	config.Timeout.MaxKeepalive = cos.Duration(4 * time.Second)
-	config.Cksum.Type = cos.ChecksumXXHash
+	config.Cksum.Type = cos.ChecksumOneXxh
 	cmn.GCO.CommitUpdate(config)
 
 	o := newBMDOwnerPrx(cmn.GCO.Get())
@@ -174,22 +174,22 @@ func TestMetasyncDeepCopy(t *testing.T) {
 	bmd := newBucketMD()
 	bmd.add(meta.NewBck("bucket1", apc.AIS, cmn.NsGlobal), &cmn.Bprops{
 		Cksum: cmn.CksumConf{
-			Type: cos.ChecksumXXHash,
+			Type: cos.ChecksumOneXxh,
 		},
 	})
 	bmd.add(meta.NewBck("bucket2", apc.AIS, cmn.NsGlobal), &cmn.Bprops{
 		Cksum: cmn.CksumConf{
-			Type: cos.ChecksumXXHash,
+			Type: cos.ChecksumOneXxh,
 		},
 	})
 	bmd.add(meta.NewBck("bucket3", apc.AWS, cmn.NsGlobal), &cmn.Bprops{
 		Cksum: cmn.CksumConf{
-			Type: cos.ChecksumXXHash,
+			Type: cos.ChecksumOneXxh,
 		},
 	})
 	bmd.add(meta.NewBck("bucket4", apc.AWS, cmn.NsGlobal), &cmn.Bprops{
 		Cksum: cmn.CksumConf{
-			Type: cos.ChecksumXXHash,
+			Type: cos.ChecksumOneXxh,
 		},
 	})
 
@@ -640,12 +640,12 @@ func TestMetasyncData(t *testing.T) {
 	// sync bucketmd, fail target and retry
 	bmd.add(meta.NewBck("bucket1", apc.AIS, cmn.NsGlobal), &cmn.Bprops{
 		Cksum: cmn.CksumConf{
-			Type: cos.ChecksumXXHash,
+			Type: cos.ChecksumOneXxh,
 		},
 	})
 	bmd.add(meta.NewBck("bucket2", apc.AIS, cmn.NsGlobal), &cmn.Bprops{
 		Cksum: cmn.CksumConf{
-			Type: cos.ChecksumXXHash,
+			Type: cos.ChecksumOneXxh,
 		},
 	})
 	primary.owner.bmd.putPersist(bmd, nil)
@@ -664,7 +664,7 @@ func TestMetasyncData(t *testing.T) {
 	// after rejecting a few sync requests
 	bmd = bmd.clone()
 	bprops := &cmn.Bprops{
-		Cksum: cmn.CksumConf{Type: cos.ChecksumXXHash},
+		Cksum: cmn.CksumConf{Type: cos.ChecksumOneXxh},
 		LRU:   cmn.GCO.Get().LRU,
 	}
 	bmd.add(meta.NewBck("bucket3", apc.AIS, cmn.NsGlobal), bprops)
 
@@ -56,7 +56,7 @@ func newDiscoverServerPrimary() *proxy {
 	config.Timeout.MaxKeepalive = cos.Duration(4 * time.Second)
 	config.Client.Timeout = cos.Duration(10 * time.Second)
 	config.Client.TimeoutLong = cos.Duration(10 * time.Second)
-	config.Cksum.Type = cos.ChecksumXXHash
+	config.Cksum.Type = cos.ChecksumCesXxh
 	cmn.GCO.CommitUpdate(config)
 
 	p.owner.smap = newSmapOwner(config)
 
@@ -3130,7 +3130,7 @@ func TestAllChecksums(t *testing.T) {
 	checksums := cos.SupportedChecksums()
 	for _, mirrored := range []bool{false, true} {
 		for _, cksumType := range checksums {
-			if testing.Short() && cksumType != cos.ChecksumNone && cksumType != cos.ChecksumXXHash {
+			if testing.Short() && cksumType != cos.ChecksumNone && cksumType != cos.ChecksumOneXxh && cksumType != cos.ChecksumCesXxh {
 				continue
 			}
 			tag := cksumType
@@ -3146,7 +3146,7 @@ func TestAllChecksums(t *testing.T) {
 	}
 
 	for _, cksumType := range checksums {
-		if testing.Short() && cksumType != cos.ChecksumNone && cksumType != cos.ChecksumXXHash {
+		if testing.Short() && cksumType != cos.ChecksumNone && cksumType != cos.ChecksumOneXxh && cksumType != cos.ChecksumCesXxh {
 			continue
 		}
 		tag := cksumType + "/EC"
@@ -3171,13 +3171,13 @@ func testWarmValidation(t *testing.T, cksumType string, mirrored, eced bool) {
 			t:               t,
 			num:             1000,
 			numGetsEachFile: 1,
-			fileSize:        uint64(cos.KiB + rand.Int64N(cos.KiB*10)),
+			fileSize:        cos.MiB/2 + rand.Uint64N(cos.KiB*10),
 		}
 		numCorrupted = rand.IntN(m.num/100) + 2
 	)
 	if testing.Short() {
 		m.num = 40
-		m.fileSize = cos.KiB
+		m.fileSize = cos.KiB + rand.Uint64N(cos.KiB)
 		numCorrupted = 13
 	}
 
 
@@ -31,7 +31,7 @@ func TestCopyMultiObjSimple(t *testing.T) {
 	const (
 		copyCnt   = 20
 		objSize   = 128
-		cksumType = cos.ChecksumXXHash
+		cksumType = cos.ChecksumCesXxh
 	)
 	var (
 		objCnt     = 2345
 
@@ -71,7 +71,7 @@ func TestETLTar2TFS3(t *testing.T) {
 	tools.CreateBucket(t, proxyURL, bck, nil, true /*cleanup*/)
 
 	// PUT TAR to the cluster
-	f, err := readers.NewExistingFile(tarPath, cos.ChecksumXXHash)
+	f, err := readers.NewExistingFile(tarPath, cos.ChecksumCesXxh)
 	tassert.CheckFatal(t, err)
 	putArgs := api.PutArgs{
 		BaseParams: baseParams,
@@ -149,7 +149,7 @@ func TestETLTar2TFRanges(t *testing.T) {
 	tools.CreateBucket(t, proxyURL, bck, nil, true /*cleanup*/)
 
 	// PUT TAR to the cluster
-	f, err := readers.NewExistingFile(tarPath, cos.ChecksumXXHash)
+	f, err := readers.NewExistingFile(tarPath, cos.ChecksumCesXxh)
 	tassert.CheckFatal(t, err)
 	putArgs := api.PutArgs{
 		BaseParams: baseParams,
 
@@ -39,7 +39,7 @@ import (
 	"github.com/NVIDIA/aistore/tools/trand"
 	"github.com/NVIDIA/aistore/xact"
 	"github.com/NVIDIA/go-tfdata/tfdata/core"
-	"github.com/OneOfOne/xxhash"
+	onexxh "github.com/OneOfOne/xxhash"
 )
 
 const (
@@ -456,7 +456,7 @@ func TestETLInlineObjWithArgs(t *testing.T) {
 					// Read the object and calculate the hash using the same hash algorithm as the ETL (same random seed).
 					// The results should match because the hash is calculated in the same way.
 					data, _ := io.ReadAll(r)
-					hash := xxhash.Checksum64S(data, seed)
+					hash := onexxh.Checksum64S(data, seed)
 					hashHex := fmt.Sprintf("%016x", hash)
 
 					return bytes.NewReader([]byte(hashHex))
 
@@ -208,7 +208,7 @@ func TestMaintenanceDecommissionRebalance(t *testing.T) {
 	tools.CreateBucket(t, proxyURL, bck, nil, true /*cleanup*/)
 	for i := range objCount {
 		objName := fmt.Sprintf("%sobj%04d", objPath, i)
-		r, _ := readers.NewRand(int64(fileSize), cos.ChecksumXXHash)
+		r, _ := readers.NewRand(int64(fileSize), cos.ChecksumCesXxh)
 		_, err := api.PutObject(&api.PutArgs{
 			BaseParams: baseParams,
 			Bck:        bck,
 
@@ -809,7 +809,7 @@ func TestChecksumValidateOnWarmGetForRemoteBucket(t *testing.T) {
 	_ = mock.NewTarget(mock.NewBaseBownerMock(
 		meta.NewBck(
 			m.bck.Name, m.bck.Provider, cmn.NsGlobal,
-			&cmn.Bprops{Cksum: cmn.CksumConf{Type: cos.ChecksumXXHash}, Extra: p.Extra, BID: 0xa73b9f11},
+			&cmn.Bprops{Cksum: cmn.CksumConf{Type: cos.ChecksumCesXxh}, Extra: p.Extra, BID: 0xa73b9f11},
 		),
 	))
 
@@ -860,7 +860,7 @@ func TestChecksumValidateOnWarmGetForRemoteBucket(t *testing.T) {
 	oldFileInfo, _ = os.Stat(fqn)
 
 	tlog.Logf("Changing file xattr[%s]: %s\n", objName, fqn)
-	err = tools.SetXattrCksum(fqn, m.bck, cos.NewCksum(cos.ChecksumXXHash, "01234"))
+	err = tools.SetXattrCksum(fqn, m.bck, cos.NewCksum(cos.ChecksumCesXxh, "01234"))
 	tassert.CheckError(t, err)
 	validateGETUponFileChangeForChecksumValidation(t, proxyURL, objName, fqn, oldFileInfo)
 
@@ -879,7 +879,7 @@ func TestChecksumValidateOnWarmGetForRemoteBucket(t *testing.T) {
 	}
 
 	tlog.Logf("Changing file xattr[%s]: %s\n", objName, fqn)
-	err = tools.SetXattrCksum(fqn, m.bck, cos.NewCksum(cos.ChecksumXXHash, "01234abcde"))
+	err = tools.SetXattrCksum(fqn, m.bck, cos.NewCksum(cos.ChecksumCesXxh, "01234abcde"))
 	tassert.CheckError(t, err)
 
 	_, err = api.GetObject(baseParams, m.bck, objName, nil)
@@ -913,7 +913,7 @@ func TestValidateOnWarmGetRemoteBucket(t *testing.T) {
 	tMock := mock.NewTarget(mock.NewBaseBownerMock(
 		meta.NewBck(
 			m.bck.Name, m.bck.Provider, cmn.NsGlobal,
-			&cmn.Bprops{Cksum: cmn.CksumConf{Type: cos.ChecksumXXHash}, Extra: p.Extra, BID: 0xa73b9f11},
+			&cmn.Bprops{Cksum: cmn.CksumConf{Type: cos.ChecksumCesXxh}, Extra: p.Extra, BID: 0xa73b9f11},
 		),
 	))
 
@@ -941,7 +941,7 @@ func TestValidateOnWarmGetRemoteBucket(t *testing.T) {
 		propsToSet := &cmn.BpropsToSet{
 			Versioning: &cmn.VersionConfToSet{ValidateWarmGet: apc.Ptr(true)},
 			Cksum: &cmn.CksumConfToSet{
-				Type:            apc.Ptr(cos.ChecksumXXHash),
+				Type:            apc.Ptr(cos.ChecksumCesXxh),
 				ValidateWarmGet: apc.Ptr(true),
 			},
 		}
@@ -980,7 +980,7 @@ func TestValidateOnWarmGetRemoteBucket(t *testing.T) {
 			modify     func(*testing.T, *core.LOM)
 		}{
 			"checksum": {modify: func(_ *testing.T, lom *core.LOM) {
-				lom.SetCksum(cos.NewCksum(cos.ChecksumXXHash, "01234"))
+				lom.SetCksum(cos.NewCksum(cos.ChecksumCesXxh, "01234"))
 			}},
 			"local_content": {modify: func(t *testing.T, lom *core.LOM) {
 				err := os.WriteFile(lom.FQN, []byte("modified"), cos.PermRWR)
@@ -1158,7 +1158,7 @@ func TestChecksumValidateOnWarmGetForBucket(t *testing.T) {
 		_          = mock.NewTarget(mock.NewBaseBownerMock(
 			meta.NewBck(
 				m.bck.Name, apc.AIS, cmn.NsGlobal,
-				&cmn.Bprops{Cksum: cmn.CksumConf{Type: cos.ChecksumXXHash}, BID: 1},
+				&cmn.Bprops{Cksum: cmn.CksumConf{Type: cos.ChecksumCesXxh}, BID: 1},
 			),
 			meta.CloneBck(&m.bck),
 		))
@@ -1199,7 +1199,7 @@ func TestChecksumValidateOnWarmGetForBucket(t *testing.T) {
 	objName = m.objNames[1]
 	fqn = findObjOnDisk(m.bck, objName)
 	tlog.Logf("Changing file xattr[%s]: %s\n", objName, fqn)
-	err = tools.SetXattrCksum(fqn, m.bck, cos.NewCksum(cos.ChecksumXXHash, "01234abcde"))
+	err = tools.SetXattrCksum(fqn, m.bck, cos.NewCksum(cos.ChecksumCesXxh, "01234abcde"))
 	tassert.CheckError(t, err)
 	executeTwoGETsForChecksumValidation(proxyURL, m.bck, objName, t)
 
@@ -1218,7 +1218,7 @@ func TestChecksumValidateOnWarmGetForBucket(t *testing.T) {
 	}
 
 	tlog.Logf("Changing file xattr[%s]: %s\n", objName, fqn)
-	err = tools.SetXattrCksum(fqn, m.bck, cos.NewCksum(cos.ChecksumXXHash, "01234abcde"))
+	err = tools.SetXattrCksum(fqn, m.bck, cos.NewCksum(cos.ChecksumCesXxh, "01234abcde"))
 	tassert.CheckError(t, err)
 	_, err = api.GetObject(baseParams, m.bck, objName, nil)
 	tassert.CheckError(t, err)
@@ -1501,7 +1501,7 @@ func Test_checksum(t *testing.T) {
 
 	propsToSet := &cmn.BpropsToSet{
 		Cksum: &cmn.CksumConfToSet{
-			Type:            apc.Ptr(cos.ChecksumXXHash),
+			Type:            apc.Ptr(cos.ChecksumCesXxh),
 			ValidateColdGet: apc.Ptr(true),
 		},
 	}
Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ var _ = Describe("BMD marshal and unmarshal", func() {`
`33`	`33`	`// Set path for proxy (it uses ConfigDir)`
`34`	`34`	`config := cmn.GCO.BeginUpdate()`
`35`	`35`	`config.ConfigDir = mpath`
`36`		`- config.Cksum.Type = cos.ChecksumXXHash`
	`36`	`+ config.Cksum.Type = cos.ChecksumOneXxh`
`37`	`37`	`config.Space = cmn.SpaceConf{`
`38`	`38`	`LowWM: 75, HighWM: 90, OOS: 95,`
`39`	`39`	`}`
Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ var _ = Describe("EtlMD marshal and unmarshal", func() {`
`52`	`52`	`// Set path for proxy (it uses ConfigDir)`
`53`	`53`	`config := cmn.GCO.BeginUpdate()`
`54`	`54`	`config.ConfigDir = mpath`
`55`		`- config.Cksum.Type = cos.ChecksumXXHash`
	`55`	`+ config.Cksum.Type = cos.ChecksumOneXxh`
`56`	`56`	`config.Space = cmn.SpaceConf{`
`57`	`57`	`LowWM: 75, HighWM: 90, OOS: 95,`
`58`	`58`	`}`
Original file line number	Diff line number	Diff line change
`@@ -3130,7 +3130,7 @@ func TestAllChecksums(t *testing.T) {`
`3130`	`3130`	`checksums := cos.SupportedChecksums()`
`3131`	`3131`	`for _, mirrored := range []bool{false, true} {`
`3132`	`3132`	`for _, cksumType := range checksums {`
`3133`		`- if testing.Short() && cksumType != cos.ChecksumNone && cksumType != cos.ChecksumXXHash {`
	`3133`	`+ if testing.Short() && cksumType != cos.ChecksumNone && cksumType != cos.ChecksumOneXxh && cksumType != cos.ChecksumCesXxh {`
`3134`	`3134`	`continue`
`3135`	`3135`	`}`
`3136`	`3136`	`tag := cksumType`
`@@ -3146,7 +3146,7 @@ func TestAllChecksums(t *testing.T) {`
`3146`	`3146`	`}`
`3147`	`3147`
`3148`	`3148`	`for _, cksumType := range checksums {`
`3149`		`- if testing.Short() && cksumType != cos.ChecksumNone && cksumType != cos.ChecksumXXHash {`
	`3149`	`+ if testing.Short() && cksumType != cos.ChecksumNone && cksumType != cos.ChecksumOneXxh && cksumType != cos.ChecksumCesXxh {`
`3150`	`3150`	`continue`
`3151`	`3151`	`}`
`3152`	`3152`	`tag := cksumType + "/EC"`
`@@ -3171,13 +3171,13 @@ func testWarmValidation(t *testing.T, cksumType string, mirrored, eced bool) {`
`3171`	`3171`	`t: t,`
`3172`	`3172`	`num: 1000,`
`3173`	`3173`	`numGetsEachFile: 1,`
`3174`		`- fileSize: uint64(cos.KiB + rand.Int64N(cos.KiB*10)),`
	`3174`	`+ fileSize: cos.MiB/2 + rand.Uint64N(cos.KiB*10),`
`3175`	`3175`	`}`
`3176`	`3176`	`numCorrupted = rand.IntN(m.num/100) + 2`
`3177`	`3177`	`)`
`3178`	`3178`	`if testing.Short() {`
`3179`	`3179`	`m.num = 40`
`3180`		`- m.fileSize = cos.KiB`
	`3180`	`+ m.fileSize = cos.KiB + rand.Uint64N(cos.KiB)`
`3181`	`3181`	`numCorrupted = 13`
`3182`	`3182`	`}`
`3183`	`3183`
Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ func TestCopyMultiObjSimple(t *testing.T) {`
`31`	`31`	`const (`
`32`	`32`	`copyCnt = 20`
`33`	`33`	`objSize = 128`
`34`		`- cksumType = cos.ChecksumXXHash`
	`34`	`+ cksumType = cos.ChecksumCesXxh`
`35`	`35`	`)`
`36`	`36`	`var (`
`37`	`37`	`objCnt = 2345`