Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 29 for GOMAXPROCS (0.17 seconds)

  1. doc/godebug.md

    runtime will consider cgroup CPU limits when setting the default GOMAXPROCS.
    The default value `containermaxprocs=1` will use cgroup limits in addition to
    the total logical CPU count and CPU affinity. `containermaxprocs=0` will
    disable consideration of cgroup limits. This setting only affects Linux.
    
    Go 1.25 added a new `updatemaxprocs` setting that controls whether the Go
    runtime will periodically update GOMAXPROCS for new CPU affinity or cgroup
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Mar 20 15:49:10 GMT 2026
    - 26K bytes
    - Click Count (0)
  2. cmd/server-main.go

    	}
    
    	maxProcs := runtime.GOMAXPROCS(0)
    	cpuProcs := runtime.NumCPU()
    	if maxProcs < cpuProcs {
    		warnings = append(warnings, color.YellowBold("Detected GOMAXPROCS(%d) < NumCPU(%d), please make sure to provide all PROCS to MinIO for optimal performance",
    			maxProcs, cpuProcs))
    	}
    
    	// Initialize grid
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  3. internal/grid/benchmark_test.go

    	errFatal(err)
    
    	// Wait for all to connect
    	// Parallel writes per server.
    	b.Run("bytes", func(b *testing.B) {
    		for par := 1; par <= 32; par *= 2 {
    			b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
    				defer timeout(60 * time.Second)()
    				ctx, cancel := context.WithTimeout(b.Context(), 30*time.Second)
    				defer cancel()
    				b.ReportAllocs()
    				b.SetBytes(int64(len(payload) * 2))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.5K bytes
    - Click Count (0)
  4. src/cmd/api/main_test.go

    // list' has its own internal concurrency, so we use a hard-coded constant (to
    // allow the I/O-intensive phases of 'go list' to overlap) instead of scaling
    // all the way up to GOMAXPROCS.
    var listSem = make(chan semToken, 2)
    
    type semToken struct{}
    
    // loadImports populates w with information about the packages in the standard
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Mar 02 13:20:41 GMT 2026
    - 31.4K bytes
    - Click Count (0)
  5. cmd/background-heal-ops.go

    				} else {
    					bgSeq.countFailed(res.Type)
    				}
    			}
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    func newHealRoutine() *healRoutine {
    	workers := runtime.GOMAXPROCS(0) / 2
    
    	if envHealWorkers := env.Get("_MINIO_HEAL_WORKERS", ""); envHealWorkers != "" {
    		if numHealers, err := strconv.Atoi(envHealWorkers); err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  6. cmd/dynamic-timeouts_test.go

    	}
    }
    
    func TestDynamicTimeoutConcurrent(t *testing.T) {
    	// Race test.
    	timeout := newDynamicTimeout(time.Second, time.Millisecond)
    	var wg sync.WaitGroup
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		wg.Add(1)
    		rng := rand.New(rand.NewSource(int64(i)))
    		go func() {
    			defer wg.Done()
    			for range 100 {
    				for range 100 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  7. CHANGELOG/CHANGELOG-1.35.md

    - Kubernetes now uses Go Language Version 1.25, including https://go.dev/blog/container-aware-gomaxprocs ([#134120](https://github.com/kubernetes/kubernetes/pull/134120), [@BenTheElder](https://github.com/BenTheElder)) [SIG API Machinery, Architecture, Auth, CLI, Cloud Provider, Cluster Lifecycle, Instrumentation, Network, Node, Release, Scheduling...
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Mar 19 03:20:49 GMT 2026
    - 265.9K bytes
    - Click Count (0)
  8. cmd/event-notification.go

    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	if err := evnot.targetList.Add(globalNotifyTargetList.Targets()...); err != nil {
    		return err
    	}
    	evnot.targetList = evnot.targetList.Init(runtime.GOMAXPROCS(0)) // TODO: make this configurable (y4m4)
    	return nil
    }
    
    // AddRulesMap - adds rules map for bucket name.
    func (evnot *EventNotifier) AddRulesMap(bucketName string, rulesMap event.RulesMap) {
    	evnot.Lock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jun 21 22:22:24 GMT 2024
    - 7.7K bytes
    - Click Count (0)
  9. cmd/admin-handlers.go

    						TotalAlloc: server.MemStats.TotalAlloc,
    						Mallocs:    server.MemStats.Mallocs,
    						Frees:      server.MemStats.Frees,
    						HeapAlloc:  server.MemStats.HeapAlloc,
    					},
    					GoMaxProcs:     server.GoMaxProcs,
    					NumCPU:         server.NumCPU,
    					RuntimeVersion: server.RuntimeVersion,
    					GCStats:        server.GCStats,
    					MinioEnvVars:   server.MinioEnvVars,
    				})
    			}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  10. cmd/handler-api.go

    		MaxLWorkers: t.replicationMaxLWorkers,
    	}
    }
    
    func (t *apiConfig) getTransitionWorkers() int {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	if t.transitionWorkers <= 0 {
    		return runtime.GOMAXPROCS(0) / 2
    	}
    
    	return t.transitionWorkers
    }
    
    func (t *apiConfig) isSyncEventsEnabled() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.syncEvents
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.4K bytes
    - Click Count (0)
Back to Top