Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for load (0.26 sec)

  1. cmd/iam.go

    func (sys *IAMSys) Initialized() bool {
    	if sys == nil {
    		return false
    	}
    	sys.Lock()
    	defer sys.Unlock()
    	return sys.store != nil
    }
    
    // Load - loads all credentials, policies and policy mappings.
    func (sys *IAMSys) Load(ctx context.Context, firstTime bool) error {
    	loadStartTime := time.Now()
    	err := sys.store.LoadIAMCache(ctx, firstTime)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  2. cmd/iam-store.go

    				break
    			}
    		}
    		mappedPolicy, ok := cache.iamUserPolicyMap.Load(name)
    		if !ok {
    			mappedPolicy, ok = cache.iamSTSPolicyMap.Load(name)
    		}
    		if !ok {
    			// Attempt to load parent user mapping for STS accounts
    			store.loadMappedPolicy(context.TODO(), name, stsUser, false, cache.iamSTSPolicyMap)
    			mappedPolicy, ok = cache.iamSTSPolicyMap.Load(name)
    			if !ok {
    				return u, errNoSuchUser
    			}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  3. cmd/erasure-object.go

    	switch size := data.Size(); {
    	case size == 0:
    		buffer = make([]byte, 1) // Allocate at least a byte to reach EOF
    	case size >= fi.Erasure.BlockSize:
    		buffer = globalBytePoolCap.Load().Get()
    		defer globalBytePoolCap.Load().Put(buffer)
    	case size < fi.Erasure.BlockSize:
    		// No need to allocate fully blockSizeV1 buffer if the incoming data is smaller.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  4. cmd/sts-handlers_test.go

    	testRoleARN  = "arn:minio:iam:::role/nOybJqMNzNmroqEKq5D0EUsRZw0"
    	testRoleARN2 = "arn:minio:iam:::role/domXb70kze7Ugc1SaxaeFchhLP4"
    )
    
    var (
    	testRoleARNs = []string{testRoleARN, testRoleARN2}
    
    	// Load test client app and test role mapping depending on test
    	// environment.
    	testClientApps, testRoleMap = func() ([]OpenIDClientAppParams, map[string]OpenIDClientAppParams) {
    		var apps []OpenIDClientAppParams
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    			defer wg.Done()
    			// remember the pool index, we may sort the slice original index might be lost.
    			pinfo := PoolObjInfo{
    				Index: i,
    			}
    			// do not remove this check as it can lead to inconsistencies
    			// for all callers of bucket replication.
    			if !opts.MetadataChg {
    				opts.VersionID = ""
    			}
    			pinfo.ObjInfo, pinfo.Err = pool.GetObjectInfo(ctx, bucket, object, opts)
    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)
  6. cmd/xl-storage.go

    			return errFileVersionNotFound
    		}
    		return err
    	}
    	defer metaDataPoolPut(buf)
    
    	if !isXL2V1Format(buf) {
    		return errFileVersionNotFound
    	}
    
    	var xlMeta xlMetaV2
    	if err = xlMeta.Load(buf); err != nil {
    		return err
    	}
    
    	if err = xlMeta.UpdateObjectVersion(fi); err != nil {
    		return err
    	}
    
    	wbuf, err := xlMeta.AppendTo(metaDataPoolGet())
    	if err != nil {
    		return err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    	//
    	//	pemFile := filepath.Join(testDataDir, "server.pem")
    	//	keyFile := filepath.Join(testDataDir, "server.key")
    	cer, err := tls.X509KeyPair(cert, key)
    	if err != nil {
    		t.Fatalf("Failed to load certificate: %v", err)
    	}
    	config := &tls.Config{Certificates: []tls.Certificate{cer}}
    
    	testServer := UnstartedTestServer(t, instanceType)
    	testServer.Server.TLS = config
    	testServer.Server.StartTLS()
    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)
  8. cmd/xl-storage-format-v2.go

    	data xlMetaInlineData
    
    	// metadata version.
    	metaV uint8
    }
    
    // LoadOrConvert will load the metadata in the buffer.
    // If this is a legacy format, it will automatically be converted to XLV2.
    func (x *xlMetaV2) LoadOrConvert(buf []byte) error {
    	if isXL2V1Format(buf) {
    		return x.Load(buf)
    	}
    
    	xlMeta := &xlMetaV1Object{}
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  9. cmd/object-api-listobjects_test.go

    				// The length of the expected ListObjectsResult.Objects
    				// should match in both expected result from test cases
    				// and in the output. On failure calling t.Fatalf,
    				// otherwise it may lead to index out of range error in
    				// assertion following this.
    				if !testCase.versioned {
    					if len(testCase.resultL.Objects) != len(resultL.Objects) {
    						t.Logf("want: %v", objInfoNames(testCase.resultL.Objects))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  10. cmd/batch-handlers.go

    	ri := &batchJobInfo{
    		JobID:     job.ID,
    		JobType:   string(job.Type()),
    		StartTime: job.Started,
    	}
    	if err := ri.load(ctx, api, job); err != nil {
    		return err
    	}
    	if ri.Complete {
    		return nil
    	}
    	globalBatchJobsMetrics.save(job.ID, ri)
    
    	delay := job.Replicate.Flags.Retry.Delay
    	if delay == 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top