| /external/perfetto/src/tracing/core/ |
| virtual_destructors.cc | 18 #include "perfetto/tracing/core/producer.h"
31 Producer::~Producer() = default;
|
| /external/perfetto/include/perfetto/tracing/core/ |
| producer.h | 28 // A Producer is an entity that connects to the write-only port of the Service
30 // of a Producer is as follows:
31 // 1. The producer connects to the service and advertises its data sources
36 // 3. At some point later on, the Service asks the Producer to turn on some of
39 // 4. In response to that the Producer will spawn an instance of the given data
43 // 1. The actual producer code in the clients e.g., the ftrace reader process.
45 class PERFETTO_EXPORT Producer {
47 virtual ~Producer();
50 // the remote Service), once the Producer <> Service connection has been
58 // The Producer is expected to tear down all its data sources if this happens
[all...] |
| tracing_service.h | 40 class Producer;
48 // The API for the Producer port of the Service.
52 // 2. The transport layer (e.g., src/ipc) when the producer and
58 // Called by the Producer to (un)register data sources. Data sources are
66 // buffer, e.g. when a producer process crashes or when a flush is
75 // Called by the Producer to signal that some pages in the shared memory
76 // buffer (shared between Service and Producer) have changed.
77 // When the Producer and the Service are hosted in the same process and
80 // if on the same thread. This is to avoid a deadlock where the Producer
109 // this returns the producer's SharedMemoryArbiter which can be use
[all...] |
| /external/perfetto/include/perfetto/tracing/ipc/ |
| producer_ipc_client.h | 27 class Producer;
31 // Producer(s) of the tracing library.
33 // src/tracing/ipc/producer/producer_ipc_client_impl.cc
36 // Connects to the producer port of the Service listening on the given
38 // method will be invoked asynchronously on the passed Producer interface.
41 // callbacks invoked on the Producer interface: no more Producer callbacks are
46 Producer*,
|
| /external/dagger2/producers/src/main/java/dagger/producers/ |
| Producer.java | 23 * {@code Producer<T>} instead of {@code T}, which will delay the execution of any code that
26 * <p>For example, you might inject {@code Producer} to lazily choose between several different
30 * {@literal @Electric Producer<Heater>} electricHeater,
31 * {@literal @Gas Producer<Heater>} gasHeater) {
56 * {@literal @Produces @Delayed ListenableFuture<C>} delayedC(A a, {@literal Producer<C>} c) {
93 public interface Producer<T> {
|
| /external/mockito/src/test/java/org/mockitousage/misuse/ |
| SpyStubbingMisuseTest.java | 20 Producer out = spy(new Producer(mfoo));
45 public class Producer {
47 Producer(Strategy f) {
|
| /external/dagger2/producers/src/main/java/dagger/producers/internal/ |
| SetProducer.java | 22 import dagger.producers.Producer;
29 * A {@link Producer} implementation used to implement {@link Set} bindings. This producer returns
31 * {@link Producer#get} methods.
38 * Returns a new producer that creates {@link Set} futures from the union of the given
39 * {@link Producer} instances.
42 public static <T> Producer<Set<T>> create(Producer<Set<T>>... producers) {
46 private final Set<Producer<Set<T>>> contributingProducers;
48 private SetProducer(Set<Producer<Set<T>>> contributingProducers)
[all...] |
| Producers.java | 24 import dagger.producers.Producer;
32 * Utility methods for use in generated producer code.
91 * Returns a producer that immediately executes the binding logic for the given provider every
94 public static <T> Producer<T> producerFromProvider(final Provider<T> provider) {
104 /** Returns a producer that succeeds with the given value. */
105 public static <T> Producer<T> immediateProducer(final T value) {
106 return new Producer<T>() {
114 /** Returns a producer that fails with the given exception. */
115 public static <T> Producer<T> immediateFailedProducer(final Throwable throwable) {
116 return new Producer<T>()
[all...] |
| SetOfProducedProducer.java | 23 import dagger.producers.Producer;
31 * A {@link Producer} implementation used to implement {@link Set} bindings. This producer returns a
33 * {@link Producer#get} methods.
40 * Returns a new producer that creates {@link Set} futures from the union of the given
41 * {@link Producer} instances.
44 public static <T> Producer<Set<Produced<T>>> create(Producer<Set<T>>... producers) {
48 private final ImmutableSet<Producer<Set<T>>> contributingProducers;
50 private SetOfProducedProducer(ImmutableSet<Producer<Set<T>>> contributingProducers)
[all...] |
| AbstractProducer.java | 19 import dagger.producers.Producer;
31 * An abstract {@link Producer} implementation that memoizes the result of its compute method.
36 public abstract class AbstractProducer<T> implements Producer<T> {
51 /** Computes this producer's future, which is then cached in {@link #get}. */
|
| /device/linaro/bootloader/edk2/OvmfPkg/Library/XenConsoleSerialPortLib/ |
| XenConsoleSerialPortLib.c | 105 XENCONS_RING_IDX Consumer, Producer;
121 Producer = mXenConsoleInterface->out_prod;
125 while (Sent < NumberOfBytes && ((Producer - Consumer) < sizeof (mXenConsoleInterface->out)))
126 mXenConsoleInterface->out[MASK_XENCONS_IDX(Producer++, mXenConsoleInterface->out)] = Buffer[Sent++];
130 mXenConsoleInterface->out_prod = Producer;
161 XENCONS_RING_IDX Consumer, Producer;
175 Producer = mXenConsoleInterface->in_prod;
180 while (Received < NumberOfBytes && Consumer < Producer)
|
| /external/dagger2/producers/src/test/java/dagger/producers/internal/ |
| SetProducerTest.java | 20 import dagger.producers.Producer;
37 Producer<Set<Integer>> producer = local
41 assertThat(producer.get().get()).containsExactly(1, 2, 5, 7);
45 Producer<Set<Integer>> producer = local
49 ListenableFuture<Set<Integer>> future = producer.get();
59 Producer<Set<Integer>> producer = local
63 ListenableFuture<Set<Integer>> future = producer.get()
[all...] |
| AbstractProducerTest.java | 21 import dagger.producers.Producer;
67 Producer<Object> producer = new DelegateProducer<>(componentMonitorProvider, null); local
69 producer.get();
76 Producer<Integer> producer = local
85 assertThat(producer.get().get()).isEqualTo(0);
86 assertThat(producer.get().get()).isEqualTo(0);
87 assertThat(producer.get().get()).isEqualTo(0);
93 Producer<Integer> producer = new DelegateProducer<>(componentMonitorProvider, delegateFuture) local
107 Producer<Integer> producer = new DelegateProducer<>(componentMonitorProvider, delegateFuture); local
[all...] |
| SetOfProducedProducerTest.java | 22 import dagger.producers.Producer;
40 Producer<Set<Produced<Integer>>> producer = local
44 assertThat(producer.get().get())
55 Producer<Set<Produced<Integer>>> producer = local
59 assertThat(producer.get().get())
66 Producer<Set<Produced<Integer>>> producer = local
68 Results<Integer> results = Results.create(producer.get().get())
77 Producer<Set<Produced<Integer>>> producer = local
90 Producer<Set<Produced<Integer>>> producer = local
102 Producer<Set<Produced<Integer>>> producer = local
[all...] |
| /external/pdfium/xfa/fxfa/parser/ |
| cxfa_producer.cpp | 16 constexpr wchar_t kName[] = L"producer";
25 XFA_Element::Producer,
|
| /external/dagger2/compiler/src/main/java/dagger/internal/codegen/ |
| DependencyRequestMapper.java | 22 import dagger.producers.Producer;
29 * the type of code to be generated (e.g., for {@link Provider} or {@link Producer}).
51 } else if (classes.equals(ImmutableSet.of(Producer.class, Provider.class))) {
68 case PRODUCER:
83 case PRODUCER:
84 return Producer.class;
|
| /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/deqp/framework/delibs/decpp/ |
| deThreadSafeRingBuffer.cpp | 96 class Producer : public Thread
99 Producer (ThreadSafeRingBuffer<Message>& buffer, deUint16 threadId, int dataSize)
134 vector<Producer*> producers;
138 producers.push_back(new Producer(buffer, (deUint16)i, dataSize));
148 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++)
152 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++)
177 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++)
|
| deBlockBuffer.cpp | 122 class Producer : public Thread
125 Producer (MessageBuffer& buffer, deUint16 threadId, int numMessages)
171 vector<Producer*> producers;
175 producers.push_back(new Producer(buffer, (deUint16)i, dataSize));
185 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++)
189 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++)
216 for (vector<Producer*>::iterator i = producers.begin(); i != producers.end(); i++)
228 class Producer : public Thread
231 Producer (BlockBuffer<deUint8>* buffer, deUint32 seed)
316 threads.push_back(new Producer(&buffer, rnd.getUint32()))
[all...] |
| /external/perfetto/src/tracing/ipc/producer/ |
| producer_ipc_client_impl.h | 44 class Producer;
48 // Exposes a Service endpoint to Producer(s), proxying all requests through a
56 Producer*,
63 // These methods are invoked by the actual Producer(s) code by clients of the
96 Producer* const producer_;
102 // The proxy interface for the producer port of the service. It is bound
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| QueuesTest.java | 64 // notice that if a Producer is interrupted (a bug), the Producer will go into an infinite
87 threadPool.submit(new Producer(q, 20));
88 threadPool.submit(new Producer(q, 20));
89 threadPool.submit(new Producer(q, 20));
90 threadPool.submit(new Producer(q, 20));
91 threadPool.submit(new Producer(q, 20));
112 Future<?> submitter = threadPool.submit(new Producer(q, 1));
160 threadPool.submit(new Producer(q, 1));
167 // Clean up produced element to free the producer thread, otherwise it will complai
[all...] |
| /external/dagger2/compiler/src/test/java/dagger/internal/codegen/ |
| DependencyRequestMapperTest.java | 25 import dagger.producers.Producer;
118 .isEqualTo(Producer.class);
126 .isEqualTo(Producer.class);
128 .isEqualTo(Producer.class);
141 @Produces String produceString(Producer<Integer> a, Produced<Integer> b) {
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| AltsFraming.java | 64 Producer producer = new Producer(); local
67 producer.readBytes(inputAlias);
68 producer.flush();
70 ByteBuffer output = producer.getRawFrame();
87 * Producer producer = new Producer();
91 * producer.readBytes(inputBuffer)
[all...] |
| /external/perfetto/src/perfetto_cmd/ |
| trigger_producer.h | 25 #include "perfetto/tracing/core/producer.h"
32 // This is a producer that only sends the provided |triggers| to the service. It
34 class TriggerProducer : public Producer {
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/ |
| SimpleProducerModule.java | 23 import dagger.producers.Producer;
108 static String strWithArgs(int i, Produced<Double> b, Producer<Object> c, Provider<Boolean> d) {
115 int i, Produced<Double> b, Producer<Object> c, Provider<Boolean> d) throws IOException {
122 int i, Produced<Double> b, Producer<Object> c, Provider<Boolean> d) {
129 int i, Produced<Double> b, Producer<Object> c, Provider<Boolean> d) throws IOException {
|
