Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for removeRoots (0.05 sec)

  1. cmd/erasure-server-pool-decom_test.go

    	objLayer, _, err := initObjectLayer(context.Background(), pools)
    	if err != nil {
    		removeRoots(fsDirs)
    		return nil, nil, err
    	}
    	return objLayer, fsDirs, nil
    }
    
    func TestPoolMetaValidate(t *testing.T) {
    	objLayer1, fsDirs, err := prepareErasurePools()
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer removeRoots(fsDirs)
    
    	meta := objLayer1.(*erasureServerPools).poolMeta
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  2. cmd/erasure-metadata-utils_test.go

    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal(err)
    	}
    	objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    		removeRoots(disks)
    		t.Fatal(err)
    	}
    	defer removeRoots(disks)
    	z := objLayer.(*erasureServerPools)
    	testShuffleDisks(t, z)
    }
    
    // Test shuffleDisks which returns shuffled slice of disks for their actual distribution.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  3. cmd/erasure-object_test.go

    	}
    
    	objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...))
    	if err != nil {
    		removeRoots(fsDirs)
    		t.Fatal(err)
    	}
    
    	// cleaning up of temporary test directories
    	defer objLayer.Shutdown(t.Context())
    	defer removeRoots(fsDirs)
    
    	// Create a testbucket
    	err = objLayer.MakeBucket(ctx, "testbucket", MakeBucketOptions{})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  4. cmd/server-main_test.go

    	defer cancel()
    	// Tests for ErasureSD object layer.
    	nDisks := 1
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal("Failed to create drives for the backend")
    	}
    	defer removeRoots(disks)
    
    	obj, err := newObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    		t.Fatal("Unexpected object layer initialization error", err)
    	}
    
    	_, ok := obj.(*erasureServerPools)
    	if !ok {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  5. cmd/benchmark-utils_test.go

    	if err != nil {
    		b.Fatalf("Failed obtaining Temp Backend: <ERROR> %s", err)
    	}
    	// cleaning up the backend by removing all the directories and files created on function return.
    	defer removeRoots(disks)
    
    	// uses *testing.B and the object Layer to run the benchmark.
    	runPutObjectPartBenchmark(b, objLayer, objSize)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    	// credentials are necessary to sign the HTTP request.
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatalf("Unable to initialize server config. %s", err)
    	}
    
    	defer removeRoots(fsDirs)
    
    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    
    	// Create "bucket"
    	err = obj.MakeBucket(ctx, "bucket", MakeBucketOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    		formattedDisks = z.serverPools[0].GetDisks(0)()
    	}
    
    	// Success.
    	return objLayer, formattedDisks, nil
    }
    
    // removeRoots - Cleans up initialized directories during tests.
    func removeRoots(roots []string) {
    	for _, root := range roots {
    		os.RemoveAll(root)
    	}
    }
    
    // creates a bucket for the tests and returns the bucket name.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  8. cmd/erasure-healing-common_test.go

    	defer cancel()
    
    	obj, disks, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatalf("Prepare Erasure backend failed - %v", err)
    	}
    	setObjectLayer(obj)
    	defer obj.Shutdown(t.Context())
    	defer removeRoots(disks)
    
    	type tamperKind int
    	const (
    		noTamper tamperKind = iota
    		deletePart
    		corruptPart
    	)
    
    	timeSentinel := time.Unix(1, 0).UTC()
    	threeNanoSecs := time.Unix(3, 0).UTC()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  9. cmd/admin-handlers_test.go

    		done:        cancel,
    	}, nil
    }
    
    // TearDown - method that resets the test bed for subsequent unit
    // tests to start afresh.
    func (atb *adminErasureTestBed) TearDown() {
    	atb.done()
    	removeRoots(atb.erasureDirs)
    	resetTestGlobals()
    }
    
    // initTestObjLayer - Helper function to initialize an Erasure-based object
    // layer and set globalObjectAPI.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  10. cmd/data-scanner_test.go

    func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) {
    	// Prepare object layer
    	objAPI, disks, err := prepareErasure(t.Context(), 8)
    	if err != nil {
    		t.Fatalf("Failed to initialize object layer: %v", err)
    	}
    	defer removeRoots(disks)
    	setObjectLayer(objAPI)
    
    	// Prepare bucket metadata
    	globalBucketMetadataSys = NewBucketMetadataSys()
    	globalBucketObjectLockSys = &BucketObjectLockSys{}
    	globalBucketVersioningSys = &BucketVersioningSys{}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
Back to top