| /external/perfetto/src/tracing/ipc/service/ |
| producer_ipc_service.cc | 30 // The remote Producer(s) are not trusted. All the methods from the ProducerPort
31 // IPC layer (e.g. RegisterDataSource()) must assume that the remote Producer is
51 // Called by the remote Producer through the IPC channel soon after connecting.
61 "The remote Producer is trying to re-initialize the connection");
66 std::unique_ptr<RemoteProducer> producer(new RemoteProducer());
69 producer->service_endpoint = core_service_->ConnectProducer(
70 producer.get(), client_info.uid(), req.producer_name(),
74 if (!producer->service_endpoint)
77 producers_.emplace(ipc_client_id, std::move(producer));
78 // Because of the std::move() |producer| is invalid after this point
89 RemoteProducer* producer = GetProducerForCurrentRequest(); local
120 RemoteProducer* producer = GetProducerForCurrentRequest(); local
136 RemoteProducer* producer = GetProducerForCurrentRequest(); local
165 RemoteProducer* producer = GetProducerForCurrentRequest(); local
[all...] |
| /external/python/cpython2/Demo/metaclasses/ |
| Synch.py | 211 def producer(buffer, wait, n=1000): function in function:_test
218 print "Producer: done producing", n, "items"
247 thread.start_new_thread(producer, (buffer, pwait, n))
249 print "Producer done"
|
| /frameworks/av/cmds/screenrecord/ |
| FrameOutput.cpp | 70 sp<IGraphicBufferProducer> producer; local
72 BufferQueue::createBufferQueue(&producer, &consumer);
77 producer->setMaxDequeuedBufferCount(4);
84 *pBufferProducer = producer;
|
| /frameworks/base/libs/hwui/tests/common/ |
| TestContext.cpp | 89 sp<IGraphicBufferProducer> producer; local
91 BufferQueue::createBufferQueue(&producer, &consumer);
92 producer->setMaxDequeuedBufferCount(3);
93 producer->setAsyncMode(true);
96 mSurface = new Surface(producer);
108 // We assume the producer is internally ordered enough such that
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
| ProducerFactoryTest.java | 21 import dagger.producers.Producer;
65 Producer<String> producer = local
68 assertThat(producer.get().get()).isEqualTo("str");
79 Producer<Integer> intProducer = producerOfFuture(intFuture);
80 Producer<String> producer = local
83 assertThat(producer.get().isDone()).isFalse();
85 assertThat(producer.get().get()).isEqualTo("str with arg");
94 Producer<SettableFuture<String>> strFutureProducer = producerOfFuture(strFutureFuture)
95 Producer<String> producer = local
122 Producer<String> producer = local
152 Producer<String> producer = local
[all...] |
| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| sample_service_unittest.cc | 71 mojo::ScopedDataPipeProducerHandle producer; local
73 mojo::CreateDataPipe(&options, &producer, &consumer);
75 output_streams[i] = std::move(producer);
|
| /external/perfetto/test/ |
| end_to_end_benchmark.cc | 45 FakeProducer* producer = helper.ConnectFakeProducer(); local
80 producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed));
|
| /external/proguard/src/proguard/optimize/info/ |
| ParameterUsageMarker.java | 196 Value producer = local
198 if (producer != null &&
199 producer.instructionOffsetValue().contains(PartialEvaluator.AT_METHOD_ENTRY))
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| graph_runner.cc | 163 const int producer = graph_to_run->versions().producer(); local
164 params.create_kernel = [this, producer](const NodeDef& ndef,
166 return CreateNonCachedKernel(cpu_device_.get(), nullptr, ndef, producer,
|
| /external/valgrind/drd/tests/ |
| circular_buffer.c | 1 /* Test program that performs producer-consumer style communication through
159 static void producer(int* id) function
211 (void * (*)(void *)) producer, &thread_arg[i]);
|
| /frameworks/av/services/camera/libcameraservice/device3/ |
| Camera3InputStream.cpp | 173 sp<IGraphicBufferProducer> *producer) {
176 if (producer == NULL) {
183 *producer = mProducer;
200 * no-op since we can't disconnect the producer from the consumer-side
232 sp<IGraphicBufferProducer> producer; local
234 BufferQueue::createBufferQueue(&producer, &consumer);
237 res = producer->query(NATIVE_WINDOW_MIN_UNDEQUEUED_BUFFERS, &minUndequeuedBuffers);
258 * and not the sum of producer+consumer side as in other camera streams).
262 // TODO: somehow set the total buffer count when producer connects?
268 mProducer = producer;
[all...] |
| Camera3StreamSplitter.cpp | 126 sp<IGraphicBufferProducer> producer = notifier.first; local
128 IInterface::asBinder(producer)->unlinkToDeath(listener);
193 // Connect to the buffer producer
213 SP_LOGV("%s: Consumer wants %d buffers, Producer wants %zu", __FUNCTION__,
303 SP_LOGE("%s: Failed to unlink producer death listener: %d ", __FUNCTION__, res);
309 SP_LOGE("%s: Unable disconnect from producer interface: %d ", __FUNCTION__, res);
680 SP_LOGE("%s: Producer needs to re-allocate buffer!", __FUNCTION__);
|
| /frameworks/native/opengl/tests/EGLTest/ |
| EGL_test.cpp | 149 sp<IGraphicBufferProducer> producer;
151 BufferQueue::createBufferQueue(&producer, &consumer);
153 sp<Surface> mSTC = new Surface(producer);
268 sp<IGraphicBufferProducer> producer; local
270 BufferQueue::createBufferQueue(&producer, &consumer);
272 sp<Surface> mSTC = new Surface(producer);
354 sp<IGraphicBufferProducer> producer; local
356 BufferQueue::createBufferQueue(&producer, &consumer);
358 sp<Surface> mSTC = new Surface(producer);
526 sp<IGraphicBufferProducer> producer; local
578 sp<IGraphicBufferProducer> producer; local
660 sp<IGraphicBufferProducer> producer; local
765 sp<IGraphicBufferProducer> producer; local
[all...] |
| /frameworks/native/vulkan/include/vulkan/ |
| vk_android_native_buffer.h | 68 uint64_t producer; member in struct:__anon46615::__anon46616
|
| /device/linaro/hikey/gralloc960/ |
| mali_gralloc_formats.cpp | 167 static uint64_t determine_best_format(int req_format, mali_gralloc_producer_type producer, mali_gralloc_consumer_type consumer,
177 if(producer == MALI_GRALLOC_PRODUCER_GPU && gpu_runtime_caps.caps_mask & MALI_GRALLOC_FORMAT_CAPABILITY_OPTIONS_PRESENT)
207 /* When GPU acts as both producer and consumer it prefers 16x16 superblocks */
238 else if(producer == MALI_GRALLOC_PRODUCER_VIDEO_DECODER && vpu_runtime_caps.caps_mask & MALI_GRALLOC_FORMAT_CAPABILITY_OPTIONS_PRESENT)
288 else if(producer == MALI_GRALLOC_PRODUCER_CAMERA && cam_runtime_caps.caps_mask & MALI_GRALLOC_FORMAT_CAPABILITY_OPTIONS_PRESENT)
367 static bool determine_producer(mali_gralloc_producer_type *producer, uint64_t *producer_runtime_mask, int req_format, int usage)
372 *producer = MALI_GRALLOC_PRODUCER_GPU;
392 *producer = MALI_GRALLOC_PRODUCER_GPU;
396 *producer = MALI_GRALLOC_PRODUCER_CAMERA;
404 *producer = MALI_GRALLOC_PRODUCER_VIDEO_DECODER
569 mali_gralloc_producer_type producer; local
[all...] |
| /external/perfetto/src/tracing/core/ |
| service_impl_unittest.cc | 29 #include "perfetto/tracing/core/producer.h"
131 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
132 producer->Connect(svc.get(), "mock_producer");
133 producer->RegisterDataSource("data_source");
141 producer->WaitForTracingSetup();
142 producer->WaitForDataSourceStart("data_source");
145 producer->WaitForDataSourceStop("data_source");
153 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
154 producer->Connect(svc.get(), "mock_producer_sameuid", geteuid());
155 producer->RegisterDataSource("data_source")
197 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
220 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
274 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
360 std::unique_ptr<MockProducer> producer[kNumProducers]; local
399 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
436 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
475 std::unique_ptr<MockProducer> producer = CreateMockProducer(); local
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_queues.py | 284 def producer(queue, num_items): function in function:QueueGetTests.test_why_are_getters_waiting
293 asyncio.gather(producer(q, producer_num_items),
|
| /frameworks/av/services/camera/libcameraservice/api1/client2/ |
| CallbackProcessor.cpp | 113 sp<IGraphicBufferProducer> producer; local
115 BufferQueue::createBufferQueue(&producer, &consumer);
119 mCallbackWindow = new Surface(producer);
|
| JpegProcessor.cpp | 108 sp<IGraphicBufferProducer> producer; local
110 BufferQueue::createBufferQueue(&producer, &consumer);
114 mCaptureWindow = new Surface(producer);
|
| /frameworks/base/core/jni/android/graphics/ |
| SurfaceTexture.cpp | 53 jfieldID producer; member in struct:android::fields_t
97 const sp<IGraphicBufferProducer>& producer)
100 (IGraphicBufferProducer*)env->GetLongField(thiz, fields.producer);
101 if (producer.get()) {
102 producer->incStrong((void*)SurfaceTexture_setProducer);
107 env->SetLongField(thiz, fields.producer, (jlong)producer.get());
130 return (IGraphicBufferProducer*)env->GetLongField(thiz, fields.producer);
135 sp<IGraphicBufferProducer> producer(SurfaceTexture_getProducer(env, thiz));
136 sp<Surface> surfaceTextureClient(surfaceTexture != NULL ? new Surface(producer) : NULL)
261 sp<IGraphicBufferProducer> producer; local
[all...] |
| /frameworks/base/media/mca/filterfw/native/core/ |
| gl_env.cpp | 168 sp<IGraphicBufferProducer> producer; local
170 BufferQueue::createBufferQueue(&producer, &consumer);
173 window_ = new Surface(producer);
|
| /frameworks/native/cmds/flatland/ |
| GLHelper.cpp | 203 sp<IGraphicBufferProducer> producer; local
205 BufferQueue::createBufferQueue(&producer, &consumer);
209 producer->setMaxDequeuedBufferCount(2);
212 sp<ANativeWindow> anw = new Surface(producer);
|
| /frameworks/native/libs/gui/ |
| BufferHubProducer.cpp | 29 sp<BufferHubProducer> producer = new BufferHubProducer; local
30 producer->queue_ = queue;
31 return producer;
37 ALOGE("BufferHubProducer::Create: Invalid producer parcelable.");
41 sp<BufferHubProducer> producer = new BufferHubProducer; local
42 producer->queue_ = ProducerQueue::Import(parcelable.TakeChannelHandle());
43 return producer;
52 ALOGE("requestBuffer: BufferHubProducer has no connected producer");
60 ALOGE("requestBuffer: slot %d is not owned by the producer (state = %s)", slot,
121 // In Daydream, non-blocking producer side dequeue is guaranteed by carefu
[all...] |
| /frameworks/native/libs/gui/tests/ |
| BufferQueue_test.cpp | 116 sp<IGraphicBufferProducer> producer; local
118 BufferQueue::createBufferQueue(&producer, &consumer);
120 serviceManager->addService(PRODUCER_NAME, IInterface::asBinder(producer));
581 // Repeatedly queue and dequeue a buffer from the producer side, it should
646 // Repeatedly queue and dequeue a buffer from the producer side, it should
701 // Repeatedly queue and dequeue a buffer from the producer side, it should
[all...] |
| SurfaceTextureClient_test.cpp | 51 sp<IGraphicBufferProducer> producer; local
53 BufferQueue::createBufferQueue(&producer, &consumer);
56 mSTC = new Surface(producer);
761 sp<IGraphicBufferProducer> producer; local
763 BufferQueue::createBufferQueue(&producer, &consumer);
766 sp<Surface> stc(new Surface(producer));
|
