Home
last modified time | relevance | path

Searched refs:numJobs (Results 1 – 25 of 96) sorted by relevance

1234

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-gridmix/src/test/java/org/apache/hadoop/mapred/gridmix/
H A DDebugJobFactory.java39 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 DDebugJobFactory.java38 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 Drestore_test.go66 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 DMockHistoryContext.java39 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 DTestJobScheduler.cpp167 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 DTestJobScheduler.cpp158 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 Djobmanager_test.go70 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 Dworkerpool_test.go202 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 DBuild.hs212 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 DBuild.hs216 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 DBuild.hs216 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 DBuild.hs217 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 DBuild.hs215 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 DDataLoader.cpp24 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 Dadapt.c80 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 Dadapt.c80 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 Dadapt.c79 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 DSyncSetTests.java84 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 DMockAppContext.java59 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 DLCTileScheduler.java902 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 Diostream_bgzf.h104 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 Diostream_bgzf.h104 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 Diostream_bgzf.h112 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 Ddissolve_test.go15 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 DSunTileScheduler.java1017 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 …]

1234