Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for GOMAXPROCS (0.18 sec)

  1. cmd/batch-handlers.go

    		return err
    	}
    
    	c.SetAppInfo("minio-"+batchJobPrefix, r.APIVersion+" "+job.ID)
    	core := &miniogo.Core{Client: c}
    
    	workerSize, err := strconv.Atoi(env.Get("_MINIO_BATCH_REPLICATION_WORKERS", strconv.Itoa(runtime.GOMAXPROCS(0)/2)))
    	if err != nil {
    		return err
    	}
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		// invalid worker size.
    		return err
    	}
    
    	retry := false
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  2. 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,
    				})
    			}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. 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
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 31.4K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    			return
    		}
    
    		// Set the correct hex md5sum for the fan-out stream.
    		fanOutOpts.MD5Hex = hex.EncodeToString(md5w.Sum(nil))
    
    		concurrentSize := 100
    		if runtime.GOMAXPROCS(0) < concurrentSize {
    			concurrentSize = runtime.GOMAXPROCS(0)
    		}
    
    		fanOutResp := make([]minio.PutObjectFanOutResponse, 0, len(fanOutEntries))
    		eventArgsList := make([]eventArgs, 0, len(fanOutEntries))
    		for {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  5. cmd/notification.go

    	// doing below. However the changes that are needed here are a bit involved,
    	// further discussion advised. Remove this comment and remove the worker model
    	// for this function in future.
    	maxWorkers := runtime.GOMAXPROCS(0) / 2
    	ng := WithNPeersThrottled(len(sys.peerClients), maxWorkers)
    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		client := client
    		ng.Go(ctx, func() error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  6. cmd/site-replication.go

    					// Log if we took a lot of time.
    					logger.Info("Site replication healing refresh took %.2fs", took)
    				}
    
    				// wait for 200 millisecond, if we are experience lot of I/O
    				waitForLowIO(runtime.GOMAXPROCS(0), 200*time.Millisecond, currentHTTPIO)
    			}
    			healTimer.Reset(siteHealTimeInterval)
    
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    type srBucketStatsSummary struct {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  7. api/go1.txt

    pkg runtime, func Caller(int) (uintptr, string, int, bool)
    pkg runtime, func Callers(int, []uintptr) int
    pkg runtime, func FuncForPC(uintptr) *Func
    pkg runtime, func GC()
    pkg runtime, func GOMAXPROCS(int) int
    pkg runtime, func GOROOT() string
    pkg runtime, func Goexit()
    pkg runtime, func GoroutineProfile([]StackRecord) (int, bool)
    pkg runtime, func Gosched()
    pkg runtime, func LockOSThread()
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top