/frameworks/av/services/camera/libcameraservice/gui/ |
H A D | RingBufferConsumer.h | 59 // Create a new ring buffer consumer. The consumerUsage parameter determines 60 // the consumer usage flags passed to the graphics allocator. The 63 RingBufferConsumer(const sp<IGraphicBufferConsumer>& consumer, uint64_t consumerUsage, 81 // setConsumerUsage allows the BufferQueue consumer usage to be 120 PinnedBufferItem(wp<RingBufferConsumer> consumer, argument 122 mConsumer(consumer), 127 sp<RingBufferConsumer> consumer = mConsumer.promote(); local 128 if (consumer != NULL) { 129 consumer->unpinBuffer(mBufferItem);
|
/frameworks/base/packages/SystemUI/src/com/android/systemui/keyguard/ |
H A D | Lifecycle.java | 37 public void dispatch(Consumer<T> consumer) { argument 39 consumer.accept(mObservers.get(i));
|
/frameworks/support/room/integration-tests/testapp/src/androidTest/java/android/arch/persistence/room/integration/testapp/test/ |
H A D | RxJava2Test.java | 189 TestSubscriber<User> consumer = new TestSubscriber<>(); 190 Disposable disposable = mUserDao.flowableUserById(3).subscribeWith(consumer); 192 consumer.assertValue(user); 201 TestSubscriber<User> consumer = new TestSubscriber<>(); 203 .subscribeWith(consumer); 205 assertThat(consumer.values().get(0), is(user)); 209 User next = consumer.values().get(1); 215 assertThat(consumer.valueCount(), is(2)); 221 TestSubscriber<User> consumer = new TestSubscriber<>(); 223 .subscribeWith(consumer); [all...] |
/frameworks/support/room/rxjava2/src/test/java/android/arch/persistence/room/ |
H A D | RxRoomTest.java | 103 CountingConsumer consumer = new CountingConsumer(); 104 Disposable disposable = flowable.subscribe(consumer); 107 assertThat(consumer.mCount, CoreMatchers.is(1)); 109 assertThat(consumer.mCount, CoreMatchers.is(2)); 111 assertThat(consumer.mCount, CoreMatchers.is(3)); 114 assertThat(consumer.mCount, CoreMatchers.is(3)); 129 final CountingConsumer consumer = new CountingConsumer(); 130 flowable.subscribe(consumer); 134 assertThat(consumer.mCount, CoreMatchers.is(0)); 139 assertThat(consumer [all...] |
/frameworks/base/libs/hwui/tests/common/ |
H A D | TestContext.cpp | 93 sp<IGraphicBufferConsumer> consumer; local 94 BufferQueue::createBufferQueue(&producer, &consumer); 97 mConsumer = new BufferItemConsumer(consumer, GRALLOC_USAGE_HW_COMPOSER, 4);
|
/frameworks/native/libs/gui/ |
H A D | BufferQueue.cpp | 96 sp<IGraphicBufferConsumer> consumer(new BufferQueueConsumer(core)); 97 LOG_ALWAYS_FATAL_IF(consumer == NULL, 101 *outConsumer = consumer;
|
H A D | BufferItemConsumer.cpp | 36 const sp<IGraphicBufferConsumer>& consumer, uint64_t consumerUsage, 38 ConsumerBase(consumer, controlledByApp) 42 "Failed to set consumer usage bits to %#" PRIx64, consumerUsage); 35 BufferItemConsumer( const sp<IGraphicBufferConsumer>& consumer, uint64_t consumerUsage, int bufferCount, bool controlledByApp) argument
|
/frameworks/native/services/surfaceflinger/ |
H A D | SurfaceFlingerConsumer.h | 41 SurfaceFlingerConsumer(const sp<IGraphicBufferConsumer>& consumer, argument 43 : GLConsumer(consumer, tex, GLConsumer::TEXTURE_EXTERNAL, false, false),
|
/frameworks/base/packages/SystemUI/src/com/android/systemui/settings/ |
H A D | CurrentUserTracker.java | 118 for (Consumer<Integer> consumer : callbacks) { 120 if (mCallbacks.contains(consumer)) { 121 consumer.accept(newUserId);
|
/frameworks/native/libs/gui/tests/ |
H A D | MultiTextureConsumer_test.cpp | 38 sp<IGraphicBufferConsumer> consumer; local 39 BufferQueue::createBufferQueue(&producer, &consumer); 40 mGlConsumer = new GLConsumer(consumer, TEX_ID,
|
H A D | Surface_test.cpp | 118 sp<IGraphicBufferConsumer> consumer; local 119 BufferQueue::createBufferQueue(&producer, &consumer); 120 sp<CpuConsumer> cpuConsumer = new CpuConsumer(consumer, 1); 179 sp<IGraphicBufferConsumer> consumer; local 180 BufferQueue::createBufferQueue(&producer, &consumer); 181 sp<BufferItemConsumer> c = new BufferItemConsumer(consumer, 197 sp<IGraphicBufferConsumer> consumer; local 198 BufferQueue::createBufferQueue(&producer, &consumer); 199 sp<CpuConsumer> cpuConsumer = new CpuConsumer(consumer, 1); 218 sp<IGraphicBufferConsumer> consumer; local 253 sp<IGraphicBufferConsumer> consumer; local 269 sp<IGraphicBufferConsumer> consumer; local 300 sp<IGraphicBufferConsumer> consumer; local 326 sp<IGraphicBufferConsumer> consumer; local [all...] |
/frameworks/native/include/gui/ |
H A D | BufferItemConsumer.h | 30 * BufferItemConsumer is a BufferQueue consumer endpoint that allows clients 32 * be acquired at once, to be used concurrently by the client. This consumer can 48 // Create a new buffer item consumer. The consumerUsage parameter determines 49 // the consumer usage flags passed to the graphics allocator. The 52 // controlledByApp tells whether this consumer is controlled by the 54 BufferItemConsumer(const sp<IGraphicBufferConsumer>& consumer,
|
H A D | BufferQueueConsumer.h | 42 // field of buffer is set to NULL and it is assumed that the consumer still 59 // releaseBuffer releases a buffer slot from the consumer back to the 64 // If releaseBuffer returns STALE_BUFFER_SLOT, then the consumer must free 75 // connect connects a consumer to the BufferQueue. Only one 76 // consumer may be connected, and when that consumer disconnects the 79 // controlledByApp indicates whether the consumer is controlled by 86 // disconnect disconnects a consumer from the BufferQueue. All 94 // but have not yet been released by the consumer. 108 // be acquired by the consumer a 165 consumerConnect(const sp<IConsumerListener>& consumer, bool controlledByApp) argument [all...] |
/frameworks/native/libs/gui/include/gui/ |
H A D | BufferItemConsumer.h | 30 * BufferItemConsumer is a BufferQueue consumer endpoint that allows clients 32 * be acquired at once, to be used concurrently by the client. This consumer can 48 // Create a new buffer item consumer. The consumerUsage parameter determines 49 // the consumer usage flags passed to the graphics allocator. The 52 // controlledByApp tells whether this consumer is controlled by the 54 BufferItemConsumer(const sp<IGraphicBufferConsumer>& consumer,
|
H A D | BufferQueueConsumer.h | 42 // field of buffer is set to NULL and it is assumed that the consumer still 59 // releaseBuffer releases a buffer slot from the consumer back to the 64 // If releaseBuffer returns STALE_BUFFER_SLOT, then the consumer must free 75 // connect connects a consumer to the BufferQueue. Only one 76 // consumer may be connected, and when that consumer disconnects the 79 // controlledByApp indicates whether the consumer is controlled by 86 // disconnect disconnects a consumer from the BufferQueue. All 94 // but have not yet been released by the consumer. 108 // be acquired by the consumer a 165 consumerConnect(const sp<IConsumerListener>& consumer, bool controlledByApp) argument [all...] |
/frameworks/base/services/backup/java/com/android/server/backup/ |
H A D | DataChangedJournal.java | 69 * @param consumer The callback. 72 public void forEach(Consumer consumer) throws IOException { argument 80 consumer.accept(packageName);
|
/frameworks/native/opengl/tests/EGLTest/ |
H A D | EGL_test.cpp | 140 sp<IGraphicBufferConsumer> consumer; 141 BufferQueue::createBufferQueue(&producer, &consumer); 142 consumer->consumerConnect(new DummyConsumer, false); 259 sp<IGraphicBufferConsumer> consumer; local 260 BufferQueue::createBufferQueue(&producer, &consumer); 261 consumer->consumerConnect(new DummyConsumer, false); 345 sp<IGraphicBufferConsumer> consumer; local 346 BufferQueue::createBufferQueue(&producer, &consumer); 347 consumer->consumerConnect(new DummyConsumer, false); 424 sp<IGraphicBufferConsumer> consumer; local 529 sp<IGraphicBufferConsumer> consumer; local [all...] |
/frameworks/native/services/vr/bufferhubd/ |
H A D | producer_channel.cpp | 134 for (auto consumer : consumer_channels_) 135 consumer->OnProducerClosed(); 139 // Derive the mask of signaled buffers in this producer / consumer set. 141 for (const ConsumerChannel* consumer : consumer_channels_) { 142 signaled_mask |= consumer->signaled() ? consumer->consumer_state_bit() : 0; 226 "ProducerChannel::CreateConsumer: Failed to push consumer channel: %s", 231 // Try find the next consumer state bit which has not been claimed by any 232 // consumer yet. 243 auto consumer local [all...] |
/frameworks/av/cmds/screenrecord/ |
H A D | FrameOutput.cpp | 71 sp<IGraphicBufferConsumer> consumer; local 72 BufferQueue::createBufferQueue(&producer, &consumer); 73 mGlConsumer = new GLConsumer(consumer, mExtTextureName,
|
/frameworks/av/services/camera/libcameraservice/device3/ |
H A D | Camera3OutputStream.h | 82 Camera3OutputStream(int id, sp<Surface> consumer, 93 Camera3OutputStream(int id, sp<Surface> consumer, 99 * Set up a stream with deferred consumer for formats that have 2 dimensions, such as 100 * RAW and YUV. The consumer must be set before using this stream for output. A valid 137 * Return if the consumer configuration of this stream is deferred. 142 * Set the consumer surfaces to the output stream. 151 * Implementation of IProducerListener, used to notify this stream that the consumer 164 * being queued to the consumer. 221 // Name of Surface consumer 224 // Whether consumer assume [all...] |
H A D | Camera3SharedOutputStream.cpp | 77 ALOGE("%s: it's illegal to set zero consumer surfaces!", __FUNCTION__); 84 ALOGE("%s: it's illegal to set a null consumer surface!", __FUNCTION__); 143 status_t Camera3SharedOutputStream::queueBufferToConsumer(sp<ANativeWindow>& consumer, argument 145 status_t res = consumer->queueBuffer(consumer.get(), buffer, anwReleaseFence); 147 // After queuing buffer to the internal consumer queue, check whether the buffer is
|
H A D | Camera3SharedOutputStream.h | 70 virtual status_t queueBufferToConsumer(sp<ANativeWindow>& consumer,
|
/frameworks/base/services/core/java/com/android/server/wm/ |
H A D | InputMonitor.java | 98 * The set of input consumer added to the window manager by name, which consumes input events 131 private void addInputConsumer(String name, InputConsumerImpl consumer) { argument 132 mInputConsumers.put(name, consumer); 144 private boolean disposeInputConsumer(InputConsumerImpl consumer) { argument 145 if (consumer != null) { 146 consumer.disposeChannelsLw(); 166 throw new IllegalStateException("Existing input consumer found with name: " + name); 169 final EventReceiverInputConsumer consumer = new EventReceiverInputConsumer(mService, 171 addInputConsumer(name, consumer); 172 return consumer; [all...] |
/frameworks/native/services/surfaceflinger/tests/hwc2/ |
H A D | Hwc2TestBuffer.cpp | 50 BufferListener(sp<IGraphicBufferConsumer> consumer, argument 52 : mConsumer(consumer), 80 sp<IGraphicBufferConsumer> consumer; local 81 BufferQueue::createBufferQueue(&producer, &consumer); 83 consumer->setDefaultBufferSize(bufferArea.width, bufferArea.height); 84 consumer->setDefaultBufferFormat(format); 86 mBufferItemConsumer = new BufferItemConsumer(consumer, 0); 88 mListener = new BufferListener(consumer, callback, callbackArgs);
|
/frameworks/native/services/surfaceflinger/DisplayHardware/ |
H A D | FramebufferSurface.h | 41 FramebufferSurface(HWComposer& hwc, int disp, const sp<IGraphicBufferConsumer>& consumer);
|