Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 17 for GOMAXPROCS (0.08 seconds)

  1. internal/lsync/lrwmutex_test.go

    		clocked <- true
    		<-cunlock
    		m.RUnlock()
    		cdone <- true
    	}
    }
    
    // Borrowed from rwmutex_test.go
    func doTestParallelReaders(numReaders, gomaxprocs int) {
    	runtime.GOMAXPROCS(gomaxprocs)
    	m := NewLRWMutex()
    
    	clocked := make(chan bool)
    	cunlock := make(chan bool)
    	cdone := make(chan bool)
    	for range numReaders {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  2. internal/dsync/drwmutex_test.go

    		}
    	}
    	cdone <- true
    }
    
    // Borrowed from rwmutex_test.go
    func hammerRWMutex(t *testing.T, gomaxprocs, numReaders, numIterations int) {
    	t.Run(fmt.Sprintf("%d-%d-%d", gomaxprocs, numReaders, numIterations), func(t *testing.T) {
    		resource := "test"
    		runtime.GOMAXPROCS(gomaxprocs)
    		// Number of active readers + 10000 * number of active writers.
    		var activity int32
    		cdone := make(chan bool)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  3. cmd/erasure.go

    				}
    				cache.replace(v.Name, v.Parent, v.Entry)
    				cache.Info.LastUpdate = time.Now()
    			}
    		}
    	}()
    
    	// Restrict parallelism for disk usage scanner
    	// upto GOMAXPROCS if GOMAXPROCS is < len(disks)
    	maxProcs := runtime.GOMAXPROCS(0)
    	if maxProcs < len(disks) {
    		disks = disks[:maxProcs]
    	}
    
    	// Start one scanner per disk
    	var wg sync.WaitGroup
    	wg.Add(len(disks))
    
    	for i := range disks {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
  4. internal/config/errors.go

    		"",
    		"MINIO_API_REPLICATION_WORKERS: should be > 0",
    	)
    
    	ErrInvalidTransitionWorkersValue = newErrFn(
    		"Invalid value for transition workers",
    		"",
    		"MINIO_API_TRANSITION_WORKERS: should be >= GOMAXPROCS/2",
    	)
    	ErrInvalidBatchKeyRotationWorkersWait = newErrFn(
    		"Invalid value for batch key rotation workers wait",
    		"Please input a non-negative duration",
    		"keyrotation_workers_wait should be > 0ms",
    	)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top