Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 33 for Done (0.13 sec)

  1. docs/distributed/CONFIG.md

    - Mixing `local-path` and `distributed-path` is not allowed, doing so would cause MinIO to refuse starting the server.
    - Ellipses notation (e.g. `{1...10}`) or bracket notations are fully allowed (e.g. `{a,c,f}`) to have multiple entries in one line.
    
    > NOTE: MinIO environmental variables still take precedence over the `config.yaml` file, however `config.yaml` is preferred over MinIO internal config KV settings via `mc admin config set alias/ <sub-system>`.
    
    ### TODO
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    	timer := time.NewTimer(globalAPIConfig.getDeleteCleanupInterval())
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			var wg sync.WaitGroup
    			for _, set := range s.sets {
    				wg.Add(1)
    				go func(set *erasureObjects) {
    					defer wg.Done()
    					if set == nil {
    						return
    					}
    					set.cleanupDeletedObjects(ctx)
    				}(set)
    			}
    			wg.Wait()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  3. cmd/handler-api.go

    			if val := globalServiceFreeze.Load(); val != nil {
    				if unlock, ok := val.(chan struct{}); ok && unlock != nil {
    					// Wait until unfrozen.
    					select {
    					case <-unlock:
    					case <-r.Context().Done():
    						// if client canceled we don't need to wait here forever.
    						return
    					}
    				}
    			}
    		}
    
    		pool, deadline := globalAPIConfig.getRequestsPool()
    		if pool == nil {
    			f.ServeHTTP(w, r)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 10K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    					if kv.Match(BatchJobKV{Key: k, Value: v}) {
    						return true
    					}
    				}
    			}
    
    			// None of the provided metadata filters match skip the object.
    			return false
    		}
    
    		// if one of source or target is non MinIO, just replicate the top most version like `mc mirror`
    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)
  5. cmd/utils.go

    }
    
    func ptr[T any](a T) *T {
    	return &a
    }
    
    // sleepContext sleeps for d duration or until ctx is done.
    func sleepContext(ctx context.Context, d time.Duration) error {
    	select {
    	case <-ctx.Done():
    		return ctx.Err()
    	case <-time.After(d):
    	}
    	return nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  6. internal/logger/logger.go

    	sort.Strings(paths)
    	n := uniq(sort.StringSlice(paths))
    	return paths[:n]
    }
    
    // Init sets the trimStrings to possible GOPATHs
    // and GOROOT directories. Also append github.com/minio/minio
    // This is done to clean up the filename, when stack trace is
    // displayed when an error happens.
    func Init(goPath string, goRoot string) {
    	var goPathList []string
    	var goRootList []string
    	var defaultgoPathList []string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users.go

    		return rd, wr
    	}
    
    	bucketStorageCache.InitOnce(10*time.Second,
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func() (DataUsageInfo, error) {
    			ctx, done := context.WithTimeout(context.Background(), 2*time.Second)
    			defer done()
    
    			return loadDataUsageFromBackend(ctx, objectAPI)
    		},
    	)
    
    	dataUsageInfo, _ := bucketStorageCache.Get()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
  8. cmd/server-main.go

    }
    
    func initServerConfig(ctx context.Context, newObject ObjectLayer) error {
    	t1 := time.Now()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	for {
    		select {
    		case <-ctx.Done():
    			// Retry was canceled successfully.
    			return fmt.Errorf("Initializing sub-systems stopped gracefully %w", ctx.Err())
    		default:
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  9. cmd/sts-handlers.go

    	// Now, we have to check that the client has provided exactly one leaf
    	// certificate that we can map to a policy.
    	if len(r.TLS.PeerCertificates) == 0 {
    		writeSTSErrorResponse(ctx, w, ErrSTSMissingParameter, errors.New("No client certificate provided"))
    		return
    	}
    	if len(r.TLS.PeerCertificates) > 1 {
    		writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, errors.New("More than one client certificate provided"))
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 34.7K bytes
    - Viewed (2)
  10. internal/bucket/lifecycle/lifecycle.go

    var (
    	errLifecycleTooManyRules = Errorf("Lifecycle configuration allows a maximum of 1000 rules")
    	errLifecycleNoRule       = Errorf("Lifecycle configuration should have at least one rule")
    	errLifecycleDuplicateID  = Errorf("Rule ID must be unique. Found same ID for more than one rule")
    	errXMLNotWellFormed      = Errorf("The XML you provided was not well-formed or did not validate against our published schema")
    )
    
    const (
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
Back to top