/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-gridmix/src/test/java/org/apache/hadoop/mapred/gridmix/ |
H A D | DebugJobFactory.java | 39 JobSubmitter submitter, Path scratch, int numJobs, Configuration conf, in getFactory() argument 45 submitter, scratch, numJobs, conf, startFlag, resolver); in getFactory() 48 submitter, scratch, numJobs, conf, startFlag, resolver); in getFactory() 51 submitter, scratch, numJobs, conf, startFlag, resolver); in getFactory() 60 JobSubmitter submitter, Path scratch, int numJobs, Configuration conf, in DebugReplayJobFactory() argument 63 submitter, new DebugJobProducer(numJobs, conf), scratch, conf, in DebugReplayJobFactory() 77 JobSubmitter submitter, Path scratch, int numJobs, Configuration conf, in DebugSerialJobFactory() argument 80 submitter, new DebugJobProducer(numJobs, conf), scratch, conf, in DebugSerialJobFactory() 93 JobSubmitter submitter, Path scratch, int numJobs, Configuration conf, in DebugStressJobFactory() argument 96 submitter, new DebugJobProducer(numJobs, conf), scratch, conf, in DebugStressJobFactory()
|
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/test/org/apache/hadoop/mapred/gridmix/ |
H A D | DebugJobFactory.java | 38 JobSubmitter submitter, Path scratch, int numJobs, Configuration conf, in getFactory() argument 44 submitter, scratch, numJobs, conf, startFlag,resolver); in getFactory() 47 submitter, scratch, numJobs, conf, startFlag,resolver); in getFactory() 50 submitter, scratch, numJobs, conf, startFlag,resolver); in getFactory() 59 JobSubmitter submitter, Path scratch, int numJobs, Configuration conf, in DebugReplayJobFactory() argument 62 submitter, new DebugJobProducer(numJobs, conf), scratch, conf, in DebugReplayJobFactory() 76 JobSubmitter submitter, Path scratch, int numJobs, Configuration conf, in DebugSerialJobFactory() argument 79 submitter, new DebugJobProducer(numJobs, conf), scratch, conf, in DebugSerialJobFactory() 93 JobSubmitter submitter, Path scratch, int numJobs, Configuration conf, in DebugStressJobFactory() argument 96 submitter, new DebugJobProducer(numJobs, conf), scratch, conf, in DebugStressJobFactory()
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/pkg/test/ |
H A D | restore_test.go | 66 numJobs int 74 numJobs: 4, 82 numJobs: 0, 90 numJobs: 4, 98 numJobs: 4, 106 numJobs: 4, 114 numJobs: 4, 122 numJobs: 4, 130 numJobs: 4, 138 numJobs: 4, [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/test/java/org/apache/hadoop/mapreduce/v2/hs/ |
H A D | MockHistoryContext.java | 39 public MockHistoryContext(int numJobs, int numTasks, int numAttempts) { in MockHistoryContext() argument 43 jobs = MockHistoryJobs.newHistoryJobs(numJobs, numTasks, numAttempts); in MockHistoryContext() 51 public MockHistoryContext(int appid, int numJobs, int numTasks, in MockHistoryContext() argument 56 jobs = MockHistoryJobs.newHistoryJobs(getApplicationID(), numJobs, numTasks, in MockHistoryContext() 71 public MockHistoryContext(int appid, int numJobs, int numTasks, int numAttempts, in MockHistoryContext() argument 76 jobs = MockHistoryJobs.newHistoryJobs(getApplicationID(), numJobs, numTasks, in MockHistoryContext()
|
/dports/www/firefox-legacy/firefox-52.8.0esr/gfx/tests/gtest/ |
H A D | TestJobScheduler.cpp | 167 uint32_t numJobs = 10; in TestSchedulerChain() local 173 syncs.reserve(numJobs); in TestSchedulerChain() 174 tasks.reserve(numJobs); in TestSchedulerChain() 176 for (uint32_t t = 0; t < numJobs-1; ++t) { in TestSchedulerChain() 184 tasks.push_back(new TestJob(numJobs, i, &check, syncs.back(), completion)); in TestSchedulerChain() 194 for (int32_t reverse = numJobs-1; reverse >= 0; --reverse) { in TestSchedulerChain() 205 EXPECT_TRUE(advancement == numJobs); in TestSchedulerChain()
|
/dports/lang/spidermonkey60/firefox-60.9.0/gfx/tests/gtest/ |
H A D | TestJobScheduler.cpp | 158 uint32_t numJobs = 10; in TestSchedulerChain() local 163 syncs.reserve(numJobs); in TestSchedulerChain() 164 tasks.reserve(numJobs); in TestSchedulerChain() 166 for (uint32_t t = 0; t < numJobs - 1; ++t) { in TestSchedulerChain() 173 tasks.push_back(new TestJob(numJobs, i, &check, syncs.back(), completion)); in TestSchedulerChain() 183 for (int32_t reverse = numJobs - 1; reverse >= 0; --reverse) { in TestSchedulerChain() 194 EXPECT_TRUE(advancement == numJobs); in TestSchedulerChain()
|
/dports/security/vault/vault-1.8.2/helper/fairshare/ |
H A D | jobmanager_test.go | 70 numJobs := 10 74 wg.Add(numJobs) 91 for i := 0; i < numJobs; i++ { 106 numJobs := 10 110 wg.Add(numJobs) 127 for i := 0; i < numJobs; i++ { 153 for i := numJobs; i < numJobs+numAdditionalJobs; i++ { 166 numJobs += numAdditionalJobs 290 numJobs := 15 293 for i := 0; i < numJobs; i++ { [all …]
|
H A D | workerpool_test.go | 202 numJobs := 10 210 wg.Add(numJobs) 223 for i := 0; i < numJobs; i++ { 349 numJobs := 10 364 wg.Add(numJobs) 377 for i := 0; i < numJobs; i++ {
|
/dports/math/hs-Agda/Agda-2.6.2/_cabal_deps/Cabal-3.0.2.0/Distribution/Simple/ |
H A D | Build.hs | 212 buildComponent verbosity numJobs pkg_descr lbi suffixes 226 buildLib verbosity numJobs pkg_descr lbi lib' clbi 253 buildComponent verbosity numJobs pkg_descr lbi suffixes 258 buildFLib verbosity numJobs pkg_descr lbi flib clbi 269 buildExe verbosity numJobs pkg_descr lbi exe' clbi 283 buildExe verbosity numJobs pkg_descr lbi exe' clbi 303 buildLib verbosity numJobs pkg lbi lib libClbi 337 buildExe verbosity numJobs pkg_descr lbi exe' clbi 608 buildLib verbosity numJobs pkg_descr lbi lib clbi = 623 buildFLib verbosity numJobs pkg_descr lbi flib clbi = [all …]
|
/dports/devel/hs-cabal-install/cabal-cabal-install-3.4.0.0/Cabal/Distribution/Simple/ |
H A D | Build.hs | 216 buildComponent verbosity numJobs pkg_descr lbi suffixes 230 buildLib verbosity numJobs pkg_descr lbi lib' clbi 257 buildComponent verbosity numJobs pkg_descr lbi suffixes 262 buildFLib verbosity numJobs pkg_descr lbi flib clbi 273 buildExe verbosity numJobs pkg_descr lbi exe' clbi 287 buildExe verbosity numJobs pkg_descr lbi exe' clbi 307 buildLib verbosity numJobs pkg lbi lib libClbi 341 buildExe verbosity numJobs pkg_descr lbi exe' clbi 616 buildLib verbosity numJobs pkg_descr lbi lib clbi = 631 buildFLib verbosity numJobs pkg_descr lbi flib clbi = [all …]
|
/dports/devel/hs-hls-install/haskell-language-server-1.4.0/install/_cabal_deps/Cabal-3.4.0.0/Distribution/Simple/ |
H A D | Build.hs | 216 buildComponent verbosity numJobs pkg_descr lbi suffixes 230 buildLib verbosity numJobs pkg_descr lbi lib' clbi 257 buildComponent verbosity numJobs pkg_descr lbi suffixes 262 buildFLib verbosity numJobs pkg_descr lbi flib clbi 273 buildExe verbosity numJobs pkg_descr lbi exe' clbi 287 buildExe verbosity numJobs pkg_descr lbi exe' clbi 307 buildLib verbosity numJobs pkg lbi lib libClbi 341 buildExe verbosity numJobs pkg_descr lbi exe' clbi 616 buildLib verbosity numJobs pkg_descr lbi lib clbi = 631 buildFLib verbosity numJobs pkg_descr lbi flib clbi = [all …]
|
/dports/devel/hs-ormolu/ormolu-0.4.0.0/_cabal_deps/Cabal-3.6.0.0/src/Distribution/Simple/ |
H A D | Build.hs | 217 buildComponent verbosity numJobs pkg_descr lbi suffixes 231 buildLib verbosity numJobs pkg_descr lbi lib' clbi 258 buildComponent verbosity numJobs pkg_descr lbi suffixes 263 buildFLib verbosity numJobs pkg_descr lbi flib clbi 274 buildExe verbosity numJobs pkg_descr lbi exe' clbi 288 buildExe verbosity numJobs pkg_descr lbi exe' clbi 308 buildLib verbosity numJobs pkg lbi lib libClbi 342 buildExe verbosity numJobs pkg_descr lbi exe' clbi 617 buildLib verbosity numJobs pkg_descr lbi lib clbi = 632 buildFLib verbosity numJobs pkg_descr lbi flib clbi = [all …]
|
/dports/lang/ghc/ghc-8.10.7/libraries/Cabal/Cabal/Distribution/Simple/ |
H A D | Build.hs | 215 buildComponent verbosity numJobs pkg_descr lbi suffixes 229 buildLib verbosity numJobs pkg_descr lbi lib' clbi 256 buildComponent verbosity numJobs pkg_descr lbi suffixes 261 buildFLib verbosity numJobs pkg_descr lbi flib clbi 272 buildExe verbosity numJobs pkg_descr lbi exe' clbi 286 buildExe verbosity numJobs pkg_descr lbi exe' clbi 306 buildLib verbosity numJobs pkg lbi lib libClbi 340 buildExe verbosity numJobs pkg_descr lbi exe' clbi 611 buildLib verbosity numJobs pkg_descr lbi lib clbi = 626 buildFLib verbosity numJobs pkg_descr lbi flib clbi = [all …]
|
/dports/misc/mnn/MNN-1.2.0/tools/train/source/data/ |
H A D | DataLoader.cpp | 24 if (mConfig->numJobs > 0) { in DataLoader() 25 mJobs = std::make_shared<BlockingQueue<Job>>(mConfig->numJobs); in DataLoader() 26 mDataQueue = std::make_shared<BlockingQueue<std::vector<Example>>>(mConfig->numJobs); in DataLoader() 27 prefetch(mConfig->numJobs); in DataLoader() 94 prefetch(mConfig->numJobs); in reset()
|
/dports/archivers/p5-Compress-Zstd/Compress-Zstd-0.20/ext/zstd/contrib/adaptive-compression/ |
H A D | adapt.c | 80 unsigned numJobs; member 163 for (u=0; u<ctx->numJobs; u++) { in freeCompressionJobs() 230 static int initCCtx(adaptCCtx* ctx, unsigned numJobs) in initCCtx() argument 249 ctx->numJobs = numJobs; in initCCtx() 266 ctx->jobs = calloc(1, numJobs*sizeof(jobDescription)); in initCCtx() 276 for (jobNum=0; jobNum<numJobs; jobNum++) { in initCCtx() 311 static adaptCCtx* createCCtx(unsigned numJobs) in createCCtx() argument 320 int const error = initCCtx(ctx, numJobs); in createCCtx() 761 unsigned const nextJobIndex = nextJob % ctx->numJobs; in createCompressionJob() 916 size_t const numJobs = MAX_NUM_JOBS; in createFileCompressionResources() local [all …]
|
/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/zstd/contrib/adaptive-compression/ |
H A D | adapt.c | 80 unsigned numJobs; member 163 for (u=0; u<ctx->numJobs; u++) { in freeCompressionJobs() 230 static int initCCtx(adaptCCtx* ctx, unsigned numJobs) in initCCtx() argument 249 ctx->numJobs = numJobs; in initCCtx() 266 ctx->jobs = calloc(1, numJobs*sizeof(jobDescription)); in initCCtx() 276 for (jobNum=0; jobNum<numJobs; jobNum++) { in initCCtx() 311 static adaptCCtx* createCCtx(unsigned numJobs) in createCCtx() argument 320 int const error = initCCtx(ctx, numJobs); in createCCtx() 766 unsigned const nextJobIndex = nextJob % ctx->numJobs; in createCompressionJob() 921 size_t const numJobs = MAX_NUM_JOBS; in createFileCompressionResources() local [all …]
|
/dports/biology/mmseqs2/MMseqs2-13-45111/lib/zstd/contrib/adaptive-compression/ |
H A D | adapt.c | 79 unsigned numJobs; member 162 for (u=0; u<ctx->numJobs; u++) { in freeCompressionJobs() 229 static int initCCtx(adaptCCtx* ctx, unsigned numJobs) in initCCtx() argument 248 ctx->numJobs = numJobs; in initCCtx() 265 ctx->jobs = calloc(1, numJobs*sizeof(jobDescription)); in initCCtx() 275 for (jobNum=0; jobNum<numJobs; jobNum++) { in initCCtx() 310 static adaptCCtx* createCCtx(unsigned numJobs) in createCCtx() argument 319 int const error = initCCtx(ctx, numJobs); in createCCtx() 760 unsigned const nextJobIndex = nextJob % ctx->numJobs; in createCompressionJob() 915 size_t const numJobs = MAX_NUM_JOBS; in createFileCompressionResources() local [all …]
|
/dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.team/tests/org.eclipse.team.tests.cvs.core/src/org/eclipse/team/tests/ccvs/core/subscriber/ |
H A D | SyncSetTests.java | 84 for(int numJobs = 0; numJobs < 10; numJobs++) { in testConcurrentAccessToSyncSet() 85 Job job = new Job("SyncSetTests" + numJobs) { in testConcurrentAccessToSyncSet()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/ |
H A D | MockAppContext.java | 59 public MockAppContext(int appid, int numJobs, int numTasks, int numAttempts) { in MockAppContext() argument 60 this(appid, numJobs, numTasks, numAttempts, false); in MockAppContext() 63 public MockAppContext(int appid, int numJobs, int numTasks, int numAttempts, in MockAppContext() argument 67 jobs = MockJobs.newJobs(appID, numJobs, numTasks, numAttempts, hasFailedTasks); in MockAppContext()
|
/dports/graphics/lightzone/LightZone-4.1.8-3-g36e87773/lightcrafts/src/com/lightcrafts/jai/utils/ |
H A D | LCTileScheduler.java | 902 int numJobs = 0; in scheduleJob() local 921 while(numJobs < numTiles) { in scheduleJob() 922 Point p = tileIndices[numJobs]; in scheduleJob() 944 addJob(jobs[numJobs++], false); in scheduleJob() 949 while(numJobs < numTiles) { in scheduleJob() 950 jobs[numJobs] = new TileJob(this, in scheduleJob() 955 numJobs, in scheduleJob() 957 addJob(jobs[numJobs++], isPrefetch); in scheduleJob() 1019 jobs[numJobs] = new TileJob(this, in scheduleJob() 1028 addJob(jobs[numJobs++], isPrefetch); in scheduleJob() [all …]
|
/dports/biology/seqan-apps/seqan-seqan-v2.4.0/include/seqan/stream/ |
H A D | iostream_bgzf.h | 104 size_t numJobs; variable 156 numJobs(numThreads * jobsPerThread), in numThreads() 157 jobQueue(numJobs), in numThreads() 158 idleQueue(numJobs), in numThreads() 161 resize(jobs, numJobs, Exact()); in numThreads() 169 for (unsigned i = 0; i < numJobs; ++i) in numThreads() 370 size_t numJobs; variable 517 numJobs(numThreads * jobsPerThread), in serializer() 518 runningQueue(numJobs), in serializer() 519 todoQueue(numJobs), in serializer() [all …]
|
/dports/biology/seqan/seqan-library-2.4.0/include/seqan/stream/ |
H A D | iostream_bgzf.h | 104 size_t numJobs; variable 156 numJobs(numThreads * jobsPerThread), in numThreads() 157 jobQueue(numJobs), in numThreads() 158 idleQueue(numJobs), in numThreads() 161 resize(jobs, numJobs, Exact()); in numThreads() 169 for (unsigned i = 0; i < numJobs; ++i) in numThreads() 370 size_t numJobs; variable 517 numJobs(numThreads * jobsPerThread), in serializer() 518 runningQueue(numJobs), in serializer() 519 todoQueue(numJobs), in serializer() [all …]
|
/dports/biology/pbseqan/seqan-21d95d737d8decb5cc3693b9065d81e831e7f57d/include/seqan/stream/ |
H A D | iostream_bgzf.h | 112 size_t numJobs; variable 163 numJobs(numThreads * jobsPerThread), in numThreads() 164 jobQueue(numJobs), in numThreads() 165 idleQueue(numJobs), in numThreads() 168 resize(jobs, numJobs, Exact()); in numThreads() 176 for (unsigned i = 0; i < numJobs; ++i) in numThreads() 375 size_t numJobs; variable 515 numJobs(numThreads * jobsPerThread), in serializer() 516 runningQueue(numJobs), in serializer() 517 todoQueue(numJobs), in serializer() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/centrifugal/centrifuge/internal/dissolve/ |
H A D | dissolve_test.go | 15 numJobs := 1024 18 wg.Add(numJobs) 20 for i := 0; i < numJobs; i++ {
|
/dports/graphics/lightzone/LightZone-4.1.8-3-g36e87773/lightcrafts/extsrc/com/lightcrafts/media/jai/util/ |
H A D | SunTileScheduler.java | 1017 int numJobs = 0; in scheduleJob() local 1036 while(numJobs < numTiles) { in scheduleJob() 1037 Point p = tileIndices[numJobs]; in scheduleJob() 1055 jobs[numJobs] = in scheduleJob() 1067 while(numJobs < numTiles) { in scheduleJob() 1068 jobs[numJobs] = new TileJob(this, in scheduleJob() 1073 numJobs, in scheduleJob() 1075 addJob(jobs[numJobs++], isPrefetch); in scheduleJob() 1137 jobs[numJobs] = new TileJob(this, in scheduleJob() 1146 addJob(jobs[numJobs++], isPrefetch); in scheduleJob() [all …]
|