/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/ |
H A D | harness_concurrency.h | 38 static int maxProcs = 0; variable 40 if ( !maxProcs ) { in GetMaxProcs() 44 maxProcs = si.dwNumberOfProcessors; in GetMaxProcs() 46 maxProcs = get_nprocs(); in GetMaxProcs() 48 maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in GetMaxProcs() 51 return maxProcs; in GetMaxProcs() 56 maxProcs = GetMaxProcs(); in LimitNumberOfThreads() 57 if ( maxProcs < max_threads ) in LimitNumberOfThreads() 59 return maxProcs; in LimitNumberOfThreads() 87 …ASSERT_WARNING( maskSize >= maxProcs, "The mask size doesn't seem to be big enough to call setaffi… in LimitNumberOfThreads()
|
H A D | test_hw_concurrency.cpp | 41 int maxProcs = Harness::GetMaxProcs(); in TestMain() local 43 if ( maxProcs < 2 ) in TestMain() 46 int availableProcs = maxProcs/2; in TestMain()
|
/dports/devel/tbb/oneTBB-2020.3/src/test/ |
H A D | harness_concurrency.h | 38 static int maxProcs = 0; variable 40 if ( !maxProcs ) { in GetMaxProcs() 44 maxProcs = si.dwNumberOfProcessors; in GetMaxProcs() 46 maxProcs = get_nprocs(); in GetMaxProcs() 48 maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in GetMaxProcs() 51 return maxProcs; in GetMaxProcs() 56 maxProcs = GetMaxProcs(); in LimitNumberOfThreads() 57 if ( maxProcs < max_threads ) in LimitNumberOfThreads() 59 return maxProcs; in LimitNumberOfThreads() 87 …ASSERT_WARNING( maskSize >= maxProcs, "The mask size doesn't seem to be big enough to call setaffi… in LimitNumberOfThreads()
|
H A D | test_hw_concurrency.cpp | 41 int maxProcs = Harness::GetMaxProcs(); in TestMain() local 43 if ( maxProcs < 2 ) in TestMain() 46 int availableProcs = maxProcs/2; in TestMain()
|
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/test/ |
H A D | harness_concurrency.h | 38 static int maxProcs = 0; variable 40 if ( !maxProcs ) { in GetMaxProcs() 44 maxProcs = si.dwNumberOfProcessors; in GetMaxProcs() 46 maxProcs = get_nprocs(); in GetMaxProcs() 48 maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in GetMaxProcs() 51 return maxProcs; in GetMaxProcs() 56 maxProcs = GetMaxProcs(); in LimitNumberOfThreads() 57 if ( maxProcs < max_threads ) in LimitNumberOfThreads() 59 return maxProcs; in LimitNumberOfThreads() 87 …ASSERT_WARNING( maskSize >= maxProcs, "The mask size doesn't seem to be big enough to call setaffi… in LimitNumberOfThreads()
|
H A D | test_hw_concurrency.cpp | 41 int maxProcs = Harness::GetMaxProcs(); in TestMain() local 43 if ( maxProcs < 2 ) in TestMain() 46 int availableProcs = maxProcs/2; in TestMain()
|
/dports/net/yggdrasil/yggdrasil-go-0.3.11/src/util/ |
H A D | workerpool.go | 8 maxProcs := runtime.GOMAXPROCS(0) 9 if maxProcs < 1 { 10 maxProcs = 1 12 workerPool = make(chan func(), maxProcs) 13 for idx := 0; idx < maxProcs; idx++ {
|
/dports/devel/onetbb/oneTBB-2021.4.0/test/common/ |
H A D | utils_concurrency_limit.h | 80 static int maxProcs = 0; variable 83 if (!maxProcs) { in get_max_procs() 92 maxProcs = nproc; in get_max_procs() 101 maxProcs = result; in get_max_procs() 103 maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in get_max_procs() 106 return maxProcs; in get_max_procs() 133 maxProcs = get_max_procs(); in limit_number_of_threads() 134 if (maxProcs < max_threads) { in limit_number_of_threads() 136 return maxProcs; in limit_number_of_threads() 158 if ( mask_size < maxProcs ) { in limit_number_of_threads()
|
/dports/net-mgmt/promscale/promscale-0.6.2/pkg/pgclient/ |
H A D | config.go | 136 maxProcs := runtime.GOMAXPROCS(-1) 180 min = maxProcs 182 …msg", fmt.Sprintf("database can only handle %v connection; connector has %v procs", max, maxProcs)) 186 numCopiers = perProc * maxProcs 188 if numCopiers > max-maxProcs { 190 numCopiers = max - maxProcs
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.uber.org/automaxprocs/maxprocs/ |
H A D | maxprocs.go | 104 maxProcs, status, err := cfg.procs(cfg.minGOMAXPROCS) 122 cfg.log("maxprocs: Updating GOMAXPROCS=%d: using minimum allowed GOMAXPROCS", maxProcs) 124 cfg.log("maxprocs: Updating GOMAXPROCS=%d: determined from CPU quota", maxProcs) 127 runtime.GOMAXPROCS(maxProcs)
|
/dports/ftp/sftpgo/sftpgo-2.2.0/vendor/go.uber.org/automaxprocs/maxprocs/ |
H A D | maxprocs.go | 105 maxProcs, status, err := cfg.procs(cfg.minGOMAXPROCS) 123 cfg.log("maxprocs: Updating GOMAXPROCS=%v: using minimum allowed GOMAXPROCS", maxProcs) 125 cfg.log("maxprocs: Updating GOMAXPROCS=%v: determined from CPU quota", maxProcs) 128 runtime.GOMAXPROCS(maxProcs)
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.uber.org/automaxprocs/internal/runtime/ |
H A D | cpu_quota_linux.go | 44 maxProcs := int(math.Floor(quota)) 45 if minValue > 0 && maxProcs < minValue { 48 return maxProcs, CPUQuotaUsed, nil
|
/dports/ftp/sftpgo/sftpgo-2.2.0/vendor/go.uber.org/automaxprocs/internal/runtime/ |
H A D | cpu_quota_linux.go | 44 maxProcs := int(math.Floor(quota)) 45 if minValue > 0 && maxProcs < minValue { 48 return maxProcs, CPUQuotaUsed, nil
|
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/tbb/ |
H A D | tbb_misc_ex.cpp | 135 int maxProcs = INT_MAX; // To check the entire mask. in initialize_hardware_concurrency_info() local 138 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 142 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 189 for ( int m = 0; availableProcs < maxProcs && m < numMasks; ++m ) { in initialize_hardware_concurrency_info() 190 … for ( size_t i = 0; (availableProcs < maxProcs) && (i < BasicMaskSize * CHAR_BIT); ++i ) { in initialize_hardware_concurrency_info() 199 availableProcs = (maxProcs == INT_MAX) ? sysconf(_SC_NPROCESSORS_ONLN) : maxProcs; in initialize_hardware_concurrency_info()
|
/dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/tbb-2018_U2/src/tbb/ |
H A D | tbb_misc_ex.cpp | 144 int maxProcs = INT_MAX; // To check the entire mask. in initialize_hardware_concurrency_info() local 147 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 151 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 198 for ( int m = 0; availableProcs < maxProcs && m < numMasks; ++m ) { in initialize_hardware_concurrency_info() 199 … for ( size_t i = 0; (availableProcs < maxProcs) && (i < BasicMaskSize * CHAR_BIT); ++i ) { in initialize_hardware_concurrency_info() 208 availableProcs = (maxProcs == INT_MAX) ? sysconf(_SC_NPROCESSORS_ONLN) : maxProcs; in initialize_hardware_concurrency_info()
|
/dports/devel/concurrentqueue/concurrentqueue-1.0.3-15-g0753496/benchmarks/tbb/ |
H A D | tbb_misc_ex.cpp | 120 int maxProcs = INT_MAX; // To check the entire mask. in initialize_hardware_concurrency_info() local 123 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 139 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 159 for ( int m = 0; availableProcs < maxProcs && m < numMasks; ++m ) { in initialize_hardware_concurrency_info() 160 … for ( size_t i = 0; (availableProcs < maxProcs) && (i < BasicMaskSize * CHAR_BIT); ++i ) { in initialize_hardware_concurrency_info() 169 availableProcs = (maxProcs == INT_MAX) ? sysconf(_SC_NPROCESSORS_ONLN) : maxProcs; in initialize_hardware_concurrency_info()
|
/dports/devel/tbb/oneTBB-2020.3/src/tbb/ |
H A D | tbb_misc_ex.cpp | 135 int maxProcs = INT_MAX; // To check the entire mask. in initialize_hardware_concurrency_info() local 138 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 142 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 189 for ( int m = 0; availableProcs < maxProcs && m < numMasks; ++m ) { in initialize_hardware_concurrency_info() 190 … for ( size_t i = 0; (availableProcs < maxProcs) && (i < BasicMaskSize * CHAR_BIT); ++i ) { in initialize_hardware_concurrency_info() 199 availableProcs = (maxProcs == INT_MAX) ? sysconf(_SC_NPROCESSORS_ONLN) : maxProcs; in initialize_hardware_concurrency_info()
|
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/tbb/ |
H A D | tbb_misc_ex.cpp | 135 int maxProcs = INT_MAX; // To check the entire mask. in initialize_hardware_concurrency_info() local 138 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 142 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 189 for ( int m = 0; availableProcs < maxProcs && m < numMasks; ++m ) { in initialize_hardware_concurrency_info() 190 … for ( size_t i = 0; (availableProcs < maxProcs) && (i < BasicMaskSize * CHAR_BIT); ++i ) { in initialize_hardware_concurrency_info() 199 availableProcs = (maxProcs == INT_MAX) ? sysconf(_SC_NPROCESSORS_ONLN) : maxProcs; in initialize_hardware_concurrency_info()
|
/dports/misc/perkeep/perkeep-0.11/internal/video/thumbnail/ |
H A D | service.go | 82 func NewService(th Thumbnailer, timeout time.Duration, maxProcs int) *Service { 85 if maxProcs > 0 { 86 g = syncutil.NewGate(maxProcs)
|
/dports/devel/onetbb/oneTBB-2021.4.0/test/tbb/ |
H A D | test_hw_concurrency.cpp | 94 int maxProcs = utils::get_max_procs(); variable 96 if (maxProcs >= 2) { 97 int availableProcs = maxProcs / 2;
|
/dports/devel/eric6/eric6-21.11/eric/eric6/Utilities/ |
H A D | BackgroundClient.py | 27 def __init__(self, host, port, maxProcs): argument 45 self.__maxProcs = maxProcs 225 host, port, maxProcs, pyLibraryPath = sys.argv[1:] variable 231 backgroundClient = BackgroundClient(host, int(port), int(maxProcs))
|
/dports/devel/onetbb/oneTBB-2021.4.0/src/tbb/ |
H A D | misc_ex.cpp | 144 int maxProcs = sysconf(_SC_NPROCESSORS_ONLN); in initialize_hardware_concurrency_info() local 175 for ( size_t i = 0; availableProcs < maxProcs && i < sizeof(cpu_set_t); ++i ) { in initialize_hardware_concurrency_info() 201 for ( int m = 0; availableProcs < maxProcs && m < numMasks; ++m ) { in initialize_hardware_concurrency_info() 202 … for ( std::size_t i = 0; (availableProcs < maxProcs) && (i < BasicMaskSize * CHAR_BIT); ++i ) { in initialize_hardware_concurrency_info() 212 availableProcs = (maxProcs == INT_MAX) ? sysconf(_SC_NPROCESSORS_ONLN) : maxProcs; in initialize_hardware_concurrency_info()
|
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/ |
H A D | cadvisor.go | 38 var maxProcs = flag.Int("max_procs", 0, "max number of CPUs that can be used simultaneously. Less t… var 116 if *maxProcs < 1 { 119 numProcs = *maxProcs
|
/dports/devel/lazygit/lazygit-0.31.4/pkg/gui/presentation/graph/ |
H A D | graph.go | 78 maxProcs := runtime.GOMAXPROCS(0) 82 chunks := make([][]string, maxProcs) 83 perProc := len(pipeSets) / maxProcs 86 wg.Add(maxProcs) 88 for i := 0; i < maxProcs; i++ { 93 if i == maxProcs-1 {
|
/dports/lang/gcc11/gcc-11.2.0/libgo/go/runtime/testdata/testprog/ |
H A D | gc.go | 161 maxProcs = 4 166 if procs > maxProcs { 167 defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(maxProcs))
|