Home
last modified time | relevance | path

Searched refs:numThreads (Results 1 – 25 of 82) sorted by relevance

1234

/external/deqp/framework/delibs/decpp/
DdeSpinBarrier.cpp34 SpinBarrier::SpinBarrier (deInt32 numThreads) in SpinBarrier() argument
36 , m_numThreads (numThreads) in SpinBarrier()
41 DE_ASSERT(numThreads > 0); in SpinBarrier()
49 void SpinBarrier::reset (deUint32 numThreads) in reset() argument
53 DE_ASSERT(numThreads > 0); in reset()
54 m_numThreads = numThreads; in reset()
60 …rier::WaitMode getWaitMode (SpinBarrier::WaitMode requested, deUint32 numCores, deInt32 numThreads) in getWaitMode() argument
63 …return ((deUint32)numThreads <= numCores) ? SpinBarrier::WAIT_MODE_BUSY : SpinBarrier::WAIT_MODE_Y… in getWaitMode()
175 TestThread (SpinBarrier& barrier, volatile deInt32* sharedVar, int numThreads, int threadNdx) in TestThread() argument
178 , m_numThreads (numThreads) in TestThread()
[all …]
DdeAppendList.cpp62 SharedState (deUint32 numThreads, deUint32 numElements_, deUint32 numElementsHint) in SharedState()
64 , barrier (numThreads) in SharedState()
97 void runAppendListTest (deUint32 numThreads, deUint32 numElements, deUint32 numElementsHint) in runAppendListTest() argument
99 SharedState sharedState (numThreads, numElements, numElementsHint); in runAppendListTest()
100 vector<TestThreadSp> threads (numThreads); in runAppendListTest()
102 for (deUint32 threadNdx = 0; threadNdx < numThreads; ++threadNdx) in runAppendListTest()
108 for (deUint32 threadNdx = 0; threadNdx < numThreads; ++threadNdx) in runAppendListTest()
111 DE_TEST_ASSERT(sharedState.testList.size() == (size_t)numElements*(size_t)numThreads); in runAppendListTest()
114 vector<deUint32> countByThread (numThreads); in runAppendListTest()
124 DE_TEST_ASSERT(de::inBounds(elem.threadNdx, 0u, numThreads)); in runAppendListTest()
[all …]
DdeSpinBarrier.hpp57 SpinBarrier (deInt32 numThreads);
62 void reset (deUint32 numThreads);
/external/lzma/CPP/7zip/Common/
DMethodProps.h20 …MtProp(const UString &name, const PROPVARIANT &prop, UInt32 defaultNumThreads, UInt32 &numThreads);
131 int numThreads = Get_NumThreads(); in Get_Lzma_NumThreads() local
132 if (numThreads >= 0) in Get_Lzma_NumThreads()
133 return numThreads < 2 ? 1 : 2; in Get_Lzma_NumThreads()
140 int numThreads = Get_NumThreads(); in Get_Xz_NumThreads() local
141 if (numThreads >= 0 && numThreads <= 1) in Get_Xz_NumThreads()
145 return numThreads; in Get_Xz_NumThreads()
188 int numThreads = Get_NumThreads(); in Get_BZip2_NumThreads() local
189 if (numThreads >= 0) in Get_BZip2_NumThreads()
192 if (numThreads < 1) return 1; in Get_BZip2_NumThreads()
[all …]
/external/tensorflow/tensorflow/lite/java/src/main/java/org/tensorflow/lite/
DInterpreter.java88 public Options setNumThreads(int numThreads) { in setNumThreads() argument
89 this.numThreads = numThreads; in setNumThreads()
135 int numThreads = -1; field in Interpreter.Options
160 public Interpreter(@NonNull File modelFile, int numThreads) { in Interpreter() argument
161 this(modelFile, new Options().setNumThreads(numThreads)); in Interpreter()
197 public Interpreter(@NonNull ByteBuffer byteBuffer, int numThreads) { in Interpreter() argument
198 this(byteBuffer, new Options().setNumThreads(numThreads)); in Interpreter()
372 public void setNumThreads(int numThreads) { in setNumThreads() argument
374 wrapper.setNumThreads(numThreads); in setNumThreads()
DNativeInterpreterWrapper.java69 this.interpreterHandle = createInterpreter(modelHandle, errorHandle, options.numThreads); in init()
187 void setNumThreads(int numThreads) { in setNumThreads() argument
188 numThreads(interpreterHandle, numThreads); in setNumThreads()
360 private static native void numThreads(long interpreterHandle, int numThreads); in numThreads() argument
372 private static native long createInterpreter(long modelHandle, long errorHandle, int numThreads); in createInterpreter() argument
/external/lzma/CPP/7zip/Compress/
DLzma2Decoder.cpp107 props.numThreads = 1; in Code()
108 UInt32 numThreads = _numThreads; in Code() local
110 if (_tryMt && numThreads >= 1) in Code()
123 if (numThreads > okThreads) in Code()
124 numThreads = (UInt32)okThreads; in Code()
125 if (numThreads == 0) in Code()
126 numThreads = 1; in Code()
127 props.numThreads = numThreads; in Code()
167 if (props.numThreads > 1) in Code()
198 STDMETHODIMP CDecoder::SetNumberOfThreads(UInt32 numThreads) in SetNumberOfThreads() argument
[all …]
DXzDecoder.cpp55 props.numThreads = 1; in Decode()
56 UInt32 numThreads = _numThreads; in Decode() local
58 if (_tryMt && numThreads > 1) in Decode()
64 isMT = (numThreads > 1); in Decode()
67 props.numThreads = numThreads; in Decode()
136 STDMETHODIMP CComDecoder::SetNumberOfThreads(UInt32 numThreads) in SetNumberOfThreads() argument
138 _numThreads = numThreads; in SetNumberOfThreads()
/external/tensorflow/tensorflow/core/framework/
Ddevice_base_test.cc40 EXPECT_EQ(d->numThreads(), 16); in TEST()
46 EXPECT_EQ(d->numThreads(), 4); in TEST()
52 EXPECT_EQ(d->numThreads(), 1); in TEST()
58 EXPECT_EQ(d->numThreads(), 16); in TEST()
/external/eigen/unsupported/Eigen/CXX11/src/Tensor/
DTensorDeviceThreadPool.h133 EIGEN_STRONG_INLINE int numThreads() const { in numThreads() function
186 if (n <= 1 || numThreads() == 1 || in parallelFor()
187 CostModel::numThreads(n, cost, static_cast<int>(numThreads())) == 1) { in parallelFor()
212 (divup<int>(block_count, numThreads()) * numThreads()); in parallelFor()
233 (divup<int>(coarser_block_count, numThreads()) * numThreads()); in parallelFor()
/external/mesa3d/src/gallium/drivers/swr/rasterizer/core/
Dthreads.cpp102 uint32_t numThreads = (uint32_t)_mm_popcount_sizeT(gmask.Mask); in CalculateProcessorTopology() local
895 static void InitPerThreadStats(SWR_CONTEXT* pContext, uint32_t numThreads) in InitPerThreadStats() argument
900 …ontext->dcRing[dc].dynState.pStats = (SWR_STATS*)AlignedMalloc(sizeof(SWR_STATS) * numThreads, 64); in InitPerThreadStats()
901 memset(pContext->dcRing[dc].dynState.pStats, 0, sizeof(SWR_STATS) * numThreads); in InitPerThreadStats()
1023 uint32_t numThreads = numNodes * numCoresPerNode * numHyperThreads; in CreateThreadPool() local
1024 SWR_REL_ASSERT(numThreads <= numHWThreads); in CreateThreadPool()
1033 numThreads = 1; in CreateThreadPool()
1037 pPool->numThreads = 0; in CreateThreadPool()
1041 numThreads = std::min(pContext->threadInfo.MAX_WORKER_THREADS, numHWThreads); in CreateThreadPool()
1049 if (numAPIReservedThreads >= numThreads) in CreateThreadPool()
[all …]
/external/dagger2/core/src/test/java/dagger/internal/
DDoubleCheckLazyTest.java42 int numThreads = 10; in get() local
43 ExecutorService executor = Executors.newFixedThreadPool(numThreads); in get()
45 final CountDownLatch latch = new CountDownLatch(numThreads); in get()
49 List<Callable<Object>> tasks = Lists.newArrayListWithCapacity(numThreads); in get()
50 for (int i = 0; i < numThreads; i++) { in get()
/external/lzma/CPP/7zip/UI/Common/
DBench.cpp1170 numThreads in MethodBench()
1198 numEncoderThreads = numThreads; in MethodBench()
1202 if (numThreads == 1 && method.Get_NumThreads() < 0) in MethodBench()
1205 if (numThreads > 1 && numLzmaThreads > 1) in MethodBench()
1207 numEncoderThreads = numThreads / 2; in MethodBench()
1443 UInt64 GetBenchMemoryUsage(UInt32 numThreads, UInt32 dictionary, bool totalBench) in GetBenchMemoryUsage() argument
1447 bool lzmaMt = (totalBench || numThreads > 1); in GetBenchMemoryUsage()
1448 UInt32 numBigThreads = numThreads; in GetBenchMemoryUsage()
1934 bool size_Defined, UInt64 size, const char *threadsString, UInt32 numThreads) in PrintRequirements() argument
1954 PrintNumber(f, numThreads, 3); in PrintRequirements()
[all …]
/external/lzma/C/
DLzmaLib.c17 int numThreads /* 1 or 2, default = 2 */ in LzmaCompress() argument
28 props.numThreads = numThreads; in LzmaCompress()
DMtCoder.h18 #define MTCODER__GET_NUM_BLOCKS_FROM_THREADS(numThreads) ((numThreads) + (numThreads) / 8 + 1) argument
/external/deqp/modules/egl/
DteglColorClearCase.cpp353 int numThreads = (int)contexts.size(); in executeForContexts() local
354 int numPackets = numThreads * numPacketsPerThread; in executeForContexts()
357 vector<vector<ClearPacket> > packets (numThreads); in executeForContexts()
358 vector<ColorClearThreadSp> threads (numThreads); in executeForContexts()
365 for (int threadNdx = 0; threadNdx < numThreads; threadNdx++) in executeForContexts()
374 packet.wait = semaphores[packetNdx*numThreads + threadNdx]; in executeForContexts()
375 packet.signal = semaphores[packetNdx*numThreads + threadNdx + 1]; in executeForContexts()
389 for (int threadNdx = 0; threadNdx < numThreads; threadNdx++) in executeForContexts()
414 for (int threadNdx = 0; threadNdx < numThreads; threadNdx++) in executeForContexts()
420 for (int threadNdx = 0; threadNdx < numThreads; threadNdx++) in executeForContexts()
/external/guava/guava-tests/test/com/google/common/base/
DSuppliersTest.java268 final int numThreads = 3; in testSupplierThreadSafe() local
269 final Thread[] threads = new Thread[numThreads]; in testSupplierThreadSafe()
299 while (waitingThreads() != numThreads - 1) { in testSupplierThreadSafe()
315 for (int i = 0; i < numThreads; i++) { in testSupplierThreadSafe()
350 final int numThreads = 10; in testSynchronizedSupplierThreadSafe() local
352 Thread[] threads = new Thread[numThreads]; in testSynchronizedSupplierThreadSafe()
353 for (int i = 0; i < numThreads; i++) { in testSynchronizedSupplierThreadSafe()
369 assertEquals(numThreads * iterations + 1, (int) nonThreadSafe.get()); in testSynchronizedSupplierThreadSafe()
/external/aac/libAACdec/src/
Daacdec_drc.cpp168 self->numThreads = 0; in aacDecoder_drcInit()
696 self->numThreads = 0; in aacDecoder_drcExtractAndMap()
699 for (i = 0; i < self->numPayloads && self->numThreads < MAX_DRC_THREADS; in aacDecoder_drcExtractAndMap()
704 FDKmemclear(&threadBs[self->numThreads], sizeof(CDrcPayload)); in aacDecoder_drcExtractAndMap()
705 threadBs[self->numThreads].channelData.bandTop[0] = in aacDecoder_drcExtractAndMap()
709 self->numThreads += aacDecoder_drcParse(hBs, &threadBs[self->numThreads], in aacDecoder_drcExtractAndMap()
715 self->numThreads < MAX_DRC_THREADS) { /* Append a DVB heavy compression in aacDecoder_drcExtractAndMap()
721 FDKmemclear(&threadBs[self->numThreads], sizeof(CDrcPayload)); in aacDecoder_drcExtractAndMap()
722 threadBs[self->numThreads].channelData.bandTop[0] = in aacDecoder_drcExtractAndMap()
726 self->numThreads += aacDecoder_drcReadCompression( in aacDecoder_drcExtractAndMap()
[all …]
/external/swiftshader/third_party/LLVM/utils/lit/lit/
Dmain.py300 def runTests(numThreads, litConfig, provider, display): argument
303 if numThreads == 1:
310 for i in range(numThreads)]
459 if opts.numThreads is None:
465 opts.numThreads = Util.detectCPUs()
467 opts.numThreads = 1
554 opts.numThreads)
574 opts.numThreads = min(len(tests), opts.numThreads)
579 runTests(opts.numThreads, litConfig, provider, display)
/external/jemalloc_new/msvc/test_threads/
Dtest_threads.cpp31 static const int numThreads = narenas + 1, numAllocsMax = 25, numIter1 = 50, numIter2 = 50; in test_threads() local
38 printf("Starting %d threads x %d x %d iterations...\n", numThreads, numIter1, numIter2); in test_threads()
39 for (int i = 0; i < numThreads; i++) { in test_threads()
/external/jemalloc/msvc/projects/vc2015/test_threads/
Dtest_threads.cpp32 static const int numThreads = narenas + 1, numAllocsMax = 25, numIter1 = 50, numIter2 = 50; in test_threads() local
39 printf("Starting %d threads x %d x %d iterations...\n", numThreads, numIter1, numIter2); in test_threads()
40 for (int i = 0; i < numThreads; i++) { in test_threads()
/external/deqp/framework/delibs/dethread/
DdeThreadTest.c627 static void runSingletonThreadedTest (int numThreads, int initTimeMs) in runSingletonThreadedTest() argument
635 for (threadNdx = 0; threadNdx < numThreads; threadNdx++) in runSingletonThreadedTest()
647 for (threadNdx = 0; threadNdx < numThreads; threadNdx++) in runSingletonThreadedTest()
665 int numThreads; in deSingleton_selfTest() member
683 int numThreads = cases[caseNdx].numThreads; in deSingleton_selfTest() local
689 runSingletonThreadedTest(numThreads, initTimeMs); in deSingleton_selfTest()
/external/llvm/utils/lit/lit/
Dmain.py261 if opts.numThreads is None:
267 opts.numThreads = lit.util.detectCPUs()
269 opts.numThreads = 1
380 opts.numThreads = min(len(run.tests), opts.numThreads)
388 desired_limit = opts.numThreads * cpus * 2 # the 2 is a safety factor
408 opts.numThreads)
424 run.execute_tests(display, opts.numThreads, opts.maxTime,
/external/deqp/external/glslang/
Dosinclude.cpp94 void OS_WaitForAllThreads (void* threads, int numThreads) in OS_WaitForAllThreads() argument
96 for (int ndx = 0; ndx < numThreads; ndx++) in OS_WaitForAllThreads()
/external/swiftshader/third_party/llvm-7.0/llvm/utils/lit/lit/
Dmain.py339 if opts.numThreads is None:
340 opts.numThreads = lit.util.detectCPUs()
485 opts.numThreads = min(len(run.tests), opts.numThreads)
493 desired_limit = opts.numThreads * cpus * 2 # the 2 is a safety factor
513 opts.numThreads)
529 run.execute_tests(display, opts.numThreads, opts.maxTime)

1234