Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for setObjectLayer (0.2 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
    	)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
  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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K 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()
    }
    
    // objectAPIHandler implements and provides http handlers for S3 API.
    type objectAPIHandlers struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  5. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  6. 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
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    		initAutoHeal(GlobalContext, z)
    	})
    
    	bootstrapTrace("initHealMRF", func() {
    		go globalMRFState.healRoutine(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() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
Back to top