Home
last modified time | relevance | path

Searched refs:maxProcs (Results 1 – 25 of 162) sorted by relevance

1234567

/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/
H A Dharness_concurrency.h38 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 Dtest_hw_concurrency.cpp41 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 Dharness_concurrency.h38 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 Dtest_hw_concurrency.cpp41 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 Dharness_concurrency.h38 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 Dtest_hw_concurrency.cpp41 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 Dworkerpool.go8 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 Dutils_concurrency_limit.h80 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 Dconfig.go136 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 Dmaxprocs.go104 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 Dmaxprocs.go105 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 Dcpu_quota_linux.go44 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 Dcpu_quota_linux.go44 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 Dtbb_misc_ex.cpp135 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 Dtbb_misc_ex.cpp144 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 Dtbb_misc_ex.cpp120 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 Dtbb_misc_ex.cpp135 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 Dtbb_misc_ex.cpp135 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 Dservice.go82 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 Dtest_hw_concurrency.cpp94 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 DBackgroundClient.py27 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 Dmisc_ex.cpp144 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 Dcadvisor.go38 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 Dgraph.go78 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 Dgc.go161 maxProcs = 4
166 if procs > maxProcs {
167 defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(maxProcs))

1234567