Searched refs:consumer (Results 1 - 25 of 73) sorted by relevance

123

/frameworks/av/services/camera/libcameraservice/gui/
H A DRingBufferConsumer.h59 // 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 DLifecycle.java37 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 DRxJava2Test.java189 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 DRxRoomTest.java103 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 DTestContext.cpp93 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 DBufferQueue.cpp96 sp<IGraphicBufferConsumer> consumer(new BufferQueueConsumer(core));
97 LOG_ALWAYS_FATAL_IF(consumer == NULL,
101 *outConsumer = consumer;
H A DBufferItemConsumer.cpp36 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 DSurfaceFlingerConsumer.h41 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 DCurrentUserTracker.java118 for (Consumer<Integer> consumer : callbacks) {
120 if (mCallbacks.contains(consumer)) {
121 consumer.accept(newUserId);
/frameworks/native/libs/gui/tests/
H A DMultiTextureConsumer_test.cpp38 sp<IGraphicBufferConsumer> consumer; local
39 BufferQueue::createBufferQueue(&producer, &consumer);
40 mGlConsumer = new GLConsumer(consumer, TEX_ID,
H A DSurface_test.cpp118 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 DBufferItemConsumer.h30 * 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 DBufferQueueConsumer.h42 // 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 DBufferItemConsumer.h30 * 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 DBufferQueueConsumer.h42 // 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 DDataChangedJournal.java69 * @param consumer The callback.
72 public void forEach(Consumer consumer) throws IOException { argument
80 consumer.accept(packageName);
/frameworks/native/opengl/tests/EGLTest/
H A DEGL_test.cpp140 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 Dproducer_channel.cpp134 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 DFrameOutput.cpp71 sp<IGraphicBufferConsumer> consumer; local
72 BufferQueue::createBufferQueue(&producer, &consumer);
73 mGlConsumer = new GLConsumer(consumer, mExtTextureName,
/frameworks/av/services/camera/libcameraservice/device3/
H A DCamera3OutputStream.h82 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 DCamera3SharedOutputStream.cpp77 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 DCamera3SharedOutputStream.h70 virtual status_t queueBufferToConsumer(sp<ANativeWindow>& consumer,
/frameworks/base/services/core/java/com/android/server/wm/
H A DInputMonitor.java98 * 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 DHwc2TestBuffer.cpp50 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 DFramebufferSurface.h41 FramebufferSurface(HWComposer& hwc, int disp, const sp<IGraphicBufferConsumer>& consumer);

Completed in 503 milliseconds

123