Home
last modified time | relevance | path

Searched refs:consumers (Results 1 - 7 of 7) sorted by relevance

/third_party/vk-gl-cts/framework/delibs/decpp/
H A DdeThreadSafeRingBuffer.cpp135 vector<Consumer*> consumers; in ThreadSafeRingBuffer_selfTest() local
141 consumers.push_back(new Consumer(buffer, numProducers)); in ThreadSafeRingBuffer_selfTest()
143 // Start consumers. in ThreadSafeRingBuffer_selfTest()
144 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++) in ThreadSafeRingBuffer_selfTest()
155 // Write end messages for consumers. in ThreadSafeRingBuffer_selfTest()
159 // Wait for consumers. in ThreadSafeRingBuffer_selfTest()
160 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++) in ThreadSafeRingBuffer_selfTest()
172 cmpSum += consumers[ in ThreadSafeRingBuffer_selfTest()
[all...]
H A DdeBlockBuffer.cpp89 /* Feed back rest of messages to buffer (they are end messages) so other consumers wake up. */ in run()
173 vector<Consumer*> consumers; in runTest() local
179 consumers.push_back(new Consumer(buffer, numProducers)); in runTest()
181 // Start consumers. in runTest()
182 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++) in runTest()
193 // Write end messages for consumers. in runTest()
199 // Wait for consumers. in runTest()
200 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers in runTest()
[all...]
/third_party/backends/japi/
H A DScanIt.java64 private Vector consumers = new Vector(); field in ScanIt
77 * Tell consumers our status. The scan is also terminated de-
82 Enumeration next = consumers.elements(); in tellStatus()
95 * Tell consumers the image size.
100 Enumeration next = consumers.elements(); in tellDimensions()
119 Enumeration next = consumers.elements(); in tellPixels()
141 if (consumers.contains(ic)) in addConsumer()
143 consumers.addElement(ic); in addConsumer()
150 { return consumers.contains(ic); } in isConsumer()
156 { consumers in removeConsumer()
[all...]
/third_party/python/Lib/test/
H A Dtest_queue.py489 consumers = [threading.Thread(target=log_exceptions(consume_func),
493 with threading_helper.start_threads(feeders + consumers):
561 # Multiple consumers without synchronization append the
/third_party/skia/third_party/externals/spirv-tools/source/val/
H A Dvalidate_image.cpp1001 std::vector<Instruction*> consumers = _.getSampledImageConsumers(inst->id()); in ValidateSampledImage() local
1002 if (!consumers.empty()) { in ValidateSampledImage()
1003 for (auto consumer_instr : consumers) { in ValidateSampledImage()
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/source/val/
H A Dvalidate_image.cpp1001 std::vector<Instruction*> consumers = _.getSampledImageConsumers(inst->id()); in ValidateSampledImage() local
1002 if (!consumers.empty()) { in ValidateSampledImage()
1003 for (auto consumer_instr : consumers) { in ValidateSampledImage()
/third_party/spirv-tools/source/val/
H A Dvalidate_image.cpp1047 std::vector<Instruction*> consumers = _.getSampledImageConsumers(inst->id()); in ValidateSampledImage() local
1048 if (!consumers.empty()) { in ValidateSampledImage()
1049 for (auto consumer_instr : consumers) { in ValidateSampledImage()

Completed in 13 milliseconds