| /external/chromium-trace/catapult/third_party/polymer/components/web-animations-js/src/ |
| handler-utils.js | 28 function consumeTrimmed(consumer, string) {
30 var result = consumer(string);
36 function consumeRepeated(consumer, separator, string) {
37 consumer = consumeTrimmed.bind(null, consumer);
40 var result = consumer(string);
|
| /external/webrtc/webrtc/common_audio/ |
| swap_queue.h | 43 // an element of type T at the back of the queue, and a consumer calls
45 // for the producer(s) and the consumer(s) to access the queue
50 // producer to consumer, SwapQueue<T> passes an "empty" T in the other
52 // consumer). This bidirectional movement is implemented with swap().
66 // // Consumer pseudo-code:
75 // enough; no deallocations in the consumer, since it returns each empty
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| IntPrimitiveOpsTests.java | 157 AssertingConsumer consumer = new AssertingConsumer(expected); local
158 IntStream.range(1, 1000).sequential().forEach(consumer);
159 assertEquals(expected.length, consumer.getCount());
163 AssertingConsumer consumer = new AssertingConsumer(expected); local
164 IntStream.range(1, 1000).parallel().sequential().forEach(consumer);
165 assertEquals(expected.length, consumer.getCount());
|
| LongPrimitiveOpsTests.java | 157 AssertingConsumer consumer = new AssertingConsumer(expected); local
158 LongStream.range(1, 1000).sequential().forEach(consumer);
159 assertEquals(expected.length, consumer.getCount());
163 AssertingConsumer consumer = new AssertingConsumer(expected); local
164 LongStream.range(1, 1000).parallel().sequential().forEach(consumer);
165 assertEquals(expected.length, consumer.getCount());
|
| /frameworks/native/include/gui/ |
| BufferQueueCore.h | 68 // consumer can run asynchronously.
163 // mConsumerControlledByApp indicates whether the connected consumer is
172 // mConsumerListener is used to notify the connected consumer of
177 // mConsumerUsageBits contains flags that the consumer wants for
192 // and consumer without sending a GraphicBuffer over Binder. The entire
221 // consumer are controlled by the application.
242 // allocated at one time. This limit can be set by the consumer.
245 // mMaxAcquiredBufferCount is the number of buffers that the consumer may
246 // acquire at one time. It defaults to 1, and can be changed by the consumer
303 // When shared buffer mode is enabled, this indicates whether the consumer
[all...] |
| BufferSlot.h | 70 // queued for use by the consumer. The buffer contents may continue to be
76 // ACQUIRED indicates that the buffer has been acquired by the consumer. As
77 // with QUEUED, the contents must not be accessed by the consumer until the
78 // acquire fence is signaled. The slot is "owned" by the consumer. It
217 // the fence indicates when the consumer has finished reading
222 // passed to the consumer or producer along with ownership of the
226 // Indicates whether this buffer has been seen by a consumer yet
|
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| MediaSet.java | 185 // media sets), in an efficient order. ItemConsumer.consumer() will be
187 public void enumerateMediaItems(ItemConsumer consumer) {
188 enumerateMediaItems(consumer, 0);
191 public void enumerateTotalMediaItems(ItemConsumer consumer) {
192 enumerateTotalMediaItems(consumer, 0);
202 protected int enumerateMediaItems(ItemConsumer consumer, int startIndex) {
210 consumer.consume(startIndex + start + i, item);
220 ItemConsumer consumer, int startIndex) {
222 start += enumerateMediaItems(consumer, startIndex);
226 consumer, startIndex + start)
[all...] |
| /prebuilts/tools/common/m2/repository/org/gradle/gradle-tooling-api/2.14.1/ |
| gradle-tooling-api-2.14.1.jar | |
| /external/chromium-trace/catapult/third_party/Paste/paste/auth/ |
| open_id.py | 5 OpenID Authentication (Consumer)
25 This module is based highly off the consumer.py that Python OpenID comes with.
77 from openid.consumer import consumer
82 This middleware implements OpenID Consumer behavior to authenticate a
113 self.oidconsumer = consumer.OpenIDConsumer(store)
198 if status in [consumer.HTTP_FAILURE, consumer.PARSE_ERROR]:
199 if status == consumer.HTTP_FAILURE:
206 elif status == consumer.SUCCESS
[all...] |
| /docs/source.android.com/src/devices/graphics/ |
| arch-bq-gralloc.jd | 33 processing (the <em>consumer</em>). Nearly everything that moves buffers of
47 and returns it to the queue (<code>queueBuffer()</code>). Later, the consumer
49 contents. When the consumer is done, it returns the buffer to the queue
58 to the free list, so the consumer can release the buffer while the contents are
63 can hold, are determined jointly by the producer and the consumer. However, the
70 consumer always creates and owns the data structure. In older versions of
72 remote process but consumer had to live in the process where the queue was
|
| /frameworks/av/services/camera/libcameraservice/device3/ |
| Camera3OutputStream.cpp | 35 sp<Surface> consumer,
41 mConsumer(consumer),
49 ALOGE("%s: Consumer is NULL!", __FUNCTION__);
59 sp<Surface> consumer,
65 mConsumer(consumer),
80 ALOGE("%s: Consumer is NULL!", __FUNCTION__);
101 // Deferred consumer only support preview surface format now.
103 ALOGE("%s: Deferred consumer only supports IMPLEMENTATION_DEFINED format now!",
108 // Sanity check for the consumer usage flag.
111 ALOGE("%s: Deferred consumer usage flag is illegal (0x%x)!", __FUNCTION__, consumerUsage)
[all...] |
| Camera3InputStream.cpp | 194 * no-op since we can't disconnect the producer from the consumer-side
226 sp<IGraphicBufferConsumer> consumer; local
227 BufferQueue::createBufferQueue(&producer, &consumer);
250 * (Note that this sets consumer-side buffer count only,
251 * and not the sum of producer+consumer side as in other camera streams).
257 mConsumer = new BufferItemConsumer(consumer, camera3_stream::usage,
|
| /libcore/ojluni/src/main/java/java/util/ |
| PrimitiveIterator.java | 27 import java.util.function.Consumer;
38 * and {@link Iterator#forEachRemaining(java.util.function.Consumer)} box
45 * {@link PrimitiveIterator.OfInt#forEachRemaining(java.util.function.Consumer)}.
49 * {@link Iterator#forEachRemaining(java.util.function.Consumer) forEachRemaining()},
61 * @param <T_CONS> the type of primitive consumer. The type must be a
62 * primitive specialization of {@link java.util.function.Consumer} for
141 default void forEachRemaining(Consumer<? super Integer> action) {
215 default void forEachRemaining(Consumer<? super Long> action) {
289 default void forEachRemaining(Consumer<? super Double> action) {
|
| /external/smali/smalidea/src/main/java/org/jf/smalidea/errorReporting/ |
| GithubFeedbackTask.java | 27 import com.intellij.util.Consumer;
42 private final Consumer<String> myCallback;
43 private final Consumer<Exception> myErrorCallback;
50 final Consumer<String> callback,
51 final Consumer<Exception> errorCallback) {
|
| /packages/apps/Camera2/src/com/android/camera/async/ |
| ConcurrentBufferQueue.java | 31 * A {@link BufferQueue} implementation useful for thread-safe producer-consumer
34 * closing the queue from either the producer or consumer side and enables
35 * precise accounting of objects which are never read by the consumer. Notably,
36 * this enables cleanly shutting down producer-consumer interactions without
122 // Keep feeding any currently-waiting consumer threads "poison pill"
|
| /prebuilts/tools/common/m2/repository/org/gradle/gradle-tooling-api/2.10/ |
| gradle-tooling-api-2.10-sources.jar | |
| /external/webrtc/webrtc/examples/objc/AppRTCDemo/third_party/SocketRocket/ |
| SRWebSocket.m | 158 @property (nonatomic, copy, readonly) stream_scanner consumer;
172 - (void)returnConsumer:(SRIOConsumer *)consumer;
191 - (void)_addConsumerWithScanner:(stream_scanner)consumer callback:(data_callback)callback;
193 - (void)_addConsumerWithScanner:(stream_scanner)consumer callback:(data_callback)callback dataLength:(size_t)dataLength;
[all...] |
| /prebuilts/tools/common/m2/repository/org/gradle/gradle-tooling-api/2.8/ |
| gradle-tooling-api-2.8-sources.jar | |
| /external/clang/unittests/AST/ |
| EvaluateAsRValueTest.cpp | 63 return llvm::make_unique<Consumer>();
67 class Consumer : public clang::ASTConsumer {
69 ~Consumer() override {}
|
| /external/llvm/tools/llvm-diff/ |
| llvm-diff.cpp | 80 DiffConsumer Consumer;
81 DifferenceEngine Engine(Consumer);
93 return Consumer.hadDifferences();
|
| /external/oauth/core/src/main/java/net/oauth/client/ |
| OAuthClient.java | 41 * Methods for an OAuth consumer to request tokens from a service provider.
87 * should contain a consumer that contains a non-null consumerKey
89 * accessor.consumer.serviceProvider.requestTokenURL should be
104 * should contain a consumer that contains a non-null consumerKey
106 * accessor.consumer.serviceProvider.requestTokenURL should be
123 * should contain a consumer that contains a non-null consumerKey
125 * accessor.consumer.serviceProvider.requestTokenURL should be
158 accessor.consumer.serviceProvider.requestTokenURL, parameters);
170 * consumer that contains a consumerKey and consumerSecret. Also,
171 * accessor.consumer.serviceProvider.accessTokenURL should be th
[all...] |
| /external/smali/smalidea/src/main/java/org/jf/smalidea/findUsages/ |
| SmaliClassReferenceSearcher.java | 52 @Override public void processQuery(final SearchParameters queryParameters, final Processor<PsiReference> consumer) {
92 return processor.processTextOccurrence(element, offsetInElement, consumer);
110 return processor.processTextOccurrence(element, offsetInElement, consumer);
|
| /frameworks/native/libs/gui/ |
| BufferItemConsumer.cpp | 34 const sp<IGraphicBufferConsumer>& consumer, uint32_t consumerUsage,
36 ConsumerBase(consumer, controlledByApp)
40 "Failed to set consumer usage bits to %#x", consumerUsage);
|
| /frameworks/native/opengl/tests/EGLTest/ |
| EGL_test.cpp | 111 sp<IGraphicBufferConsumer> consumer; local
112 BufferQueue::createBufferQueue(&producer, &consumer);
113 consumer->consumerConnect(new DummyConsumer, false);
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| Nodes.java | 37 import java.util.function.Consumer;
572 public void forEach(T_CONS consumer) { }
574 private static class OfRef<T> extends EmptyNode<T, T[], Consumer<? super T>> {
682 public void forEach(Consumer<? super T> consumer) {
684 consumer.accept(array[i]);
730 public void forEach(Consumer<? super T> consumer) {
731 c.forEach(consumer);
811 public void forEach(Consumer<? super T> consumer)
[all...] |
