Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for setObjectLayer (0.12 sec)

  1. cmd/erasure-healing-common_test.go

    	}
    
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, disks, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatalf("Prepare Erasure backend failed - %v", err)
    	}
    	setObjectLayer(obj)
    	defer obj.Shutdown(context.Background())
    	defer removeRoots(disks)
    
    	type tamperKind int
    	const (
    		noTamper tamperKind = iota
    		deletePart
    		corruptPart
    	)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  2. cmd/data-scanner_test.go

    	objAPI, disks, err := prepareErasure(context.Background(), 8)
    	if err != nil {
    		t.Fatalf("Failed to initialize object layer: %v", err)
    	}
    	defer removeRoots(disks)
    	setObjectLayer(objAPI)
    	globalBucketMetadataSys = NewBucketMetadataSys()
    	globalBucketObjectLockSys = &BucketObjectLockSys{}
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	es := newExpiryState(context.Background(), objAPI, 0)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    			localMetacacheMgr.deleteAll()
    		}
    
    		objLayer, fsDir, err := prepareFS(ctx)
    		if err != nil {
    			t.Fatalf("Initialization of object layer failed for single node setup: %s", err)
    		}
    		setObjectLayer(objLayer)
    		initAllSubsystems(ctx)
    
    		// initialize the server and obtain the credentials and root.
    		// credentials are necessary to sign the HTTP request.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  4. cmd/api-router.go

    	globalConsoleSrv = srv
    	globalObjLayerMutex.Unlock()
    }
    
    func newObjectLayerFn() ObjectLayer {
    	globalObjLayerMutex.RLock()
    	defer globalObjLayerMutex.RUnlock()
    	return globalObjectAPI
    }
    
    func setObjectLayer(o ObjectLayer) {
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = o
    	globalObjLayerMutex.Unlock()
    }
    
    // objectAPIHandlers implements and provides http handlers for S3 API.
    type objectAPIHandlers struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  5. cmd/erasure-object_test.go

    	defer cancel()
    
    	obj, fsDirs, err := prepareErasureSets32(ctx)
    	if err != nil {
    		t.Fatal("Unable to initialize 'Erasure' object layer.", err)
    	}
    
    	setObjectLayer(obj)
    	initConfigSubsystem(ctx, obj)
    
    	// Remove all dirs.
    	for _, dir := range fsDirs {
    		defer os.RemoveAll(dir)
    	}
    
    	type testCaseType struct {
    		bucket string
    		object string
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    	}
    
    	defer removeRoots(fsDirs)
    
    	// Everything is fine, should return nil
    	objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	setObjectLayer(objLayer)
    
    	bucket := getRandomBucketName()
    	object := getRandomObjectName()
    	data := bytes.Repeat([]byte("a"), 128*1024)
    
    	err = objLayer.MakeBucket(ctx, bucket, MakeBucketOptions{})
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    	// so various tasks will be useful
    	bootstrapTrace("initAutoHeal", func() {
    		initAutoHeal(GlobalContext, z)
    	})
    
    	// initialize the object layer.
    	defer setObjectLayer(z)
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	attempt := 1
    	for {
    		var err error
    		bootstrapTrace(fmt.Sprintf("poolMeta.Init: loading pool metadata, attempt: %d", attempt), func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top