Function PrepareObjects

devtools/tutils/file.go:126–217

(t *testing.T, desc ObjectsDesc)

}

func PrepareObjects(t *testing.T, desc ObjectsDesc) *ObjectsOut {
	var (
		buf       = make([]byte, desc.ObjectSize)
		fqns      = make(map[string][]string, len(desc.CTs))
		mpathCnts = make(map[string]int, desc.MountpathsCnt)

		bck = cmn.Bck{
			Name:     cos.RandString(10),
			Provider: apc.ProviderAIS,
			Ns:       cmn.NsGlobal,
			Props: &cmn.BucketProps{
				Cksum: cmn.CksumConf{Type: cos.ChecksumXXHash},
				BID:   0xa5b6e7d8,
			},
		}
		bmd   = mock.NewBaseBownerMock((*cluster.Bck)(&bck))
		tMock cluster.Target
	)

	mios := mock.NewIOStater()
	fs.TestNew(mios)
	fs.TestDisableValidation()

	_ = fs.CSM.Reg(fs.WorkfileType, &fs.WorkfileContentResolver{})
	_ = fs.CSM.Reg(fs.ObjectType, &fs.ObjectContentResolver{})
	_ = fs.CSM.Reg(fs.ECSliceType, &fs.ECSliceContentResolver{})
	_ = fs.CSM.Reg(fs.ECMetaType, &fs.ECMetaContentResolver{})

	dir := t.TempDir()

	for i := 0; i < desc.MountpathsCnt; i++ {
		mpath, err := os.MkdirTemp(dir, "")
		tassert.CheckFatal(t, err)
		mp, err := fs.Add(mpath, "daeID")
		tassert.CheckFatal(t, err)
		mpathCnts[mp.Path] = 0
	}

	if len(desc.CTs) == 0 {
		return nil
	}

	tMock = mock.NewTarget(bmd)

	errs := fs.CreateBucket("testing", &bck, false /*nilbmd*/)
	if len(errs) > 0 {
		tassert.CheckFatal(t, errs[0])
	}

	for _, ct := range desc.CTs {
		for i := 0; i < ct.ContentCnt; i++ {
			fqn, _, err := cluster.HrwFQN(&bck, ct.Type, cos.RandString(15))
			tassert.CheckFatal(t, err)

			fqns[ct.Type] = append(fqns[ct.Type], fqn)

			f, err := cos.CreateFile(fqn)
			tassert.CheckFatal(t, err)