| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/ |
| D | ExportComponentImpl.java | 20 import io.opencensus.implcore.internal.EventQueue;
62 public static ExportComponentImpl createWithInProcessStores(EventQueue eventQueue) { in createWithInProcessStores()
72 public static ExportComponentImpl createWithoutInProcessStores(EventQueue eventQueue) { in createWithoutInProcessStores()
82 private ExportComponentImpl(boolean supportInProcessStores, EventQueue eventQueue) { in ExportComponentImpl()
|
| D | InProcessSampledSpanStoreImpl.java | 20 import io.opencensus.implcore.internal.EventQueue;
55 private final EventQueue eventQueue;
247 InProcessSampledSpanStoreImpl(EventQueue eventQueue) { in InProcessSampledSpanStoreImpl()
301 private static final class RegisterSpanNameEvent implements EventQueue.Entry {
328 private static final class UnregisterSpanNameEvent implements EventQueue.Entry {
|
| /external/crosvm/devices/src/virtio/video/ |
| D | utils.rs | 22 pub struct EventQueue<T> { struct
29 impl<T> EventQueue<T> { argument
91 impl<T> AsRawDescriptor for EventQueue<T> { implementation
99 pub struct SyncEventQueue<T>(Mutex<EventQueue<T>>);
101 impl<T> From<EventQueue<T>> for SyncEventQueue<T> {
102 fn from(queue: EventQueue<T>) -> Self { in from()
273 let mut event_queue = EventQueue::new().unwrap(); in event_queue()
324 let mut event_queue = EventQueue::new().unwrap(); in decoder_event_queue_polling()
|
| D | device.rs | 20 EventQueue, enumerator
|
| D | worker.rs | 330 (event_evt, Token::EventQueue), in run()
352 Token::EventQueue => { in run()
|
| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/ |
| D | StartEndHandlerImpl.java | 19 import io.opencensus.implcore.internal.EventQueue;
38 private final EventQueue eventQueue;
55 EventQueue eventQueue) { in StartEndHandlerImpl()
79 private static final class SpanStartEvent implements EventQueue.Entry {
97 private static final class SpanEndEvent implements EventQueue.Entry {
|
| D | TraceComponentImplBase.java | 20 import io.opencensus.implcore.internal.EventQueue;
54 public TraceComponentImplBase(Clock clock, RandomHandler randomHandler, EventQueue eventQueue) { in TraceComponentImplBase()
|
| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/stats/ |
| D | StatsManager.java | 24 import io.opencensus.implcore.internal.EventQueue;
36 private final EventQueue queue;
44 StatsManager(EventQueue queue, Clock clock, CurrentState state) { in StatsManager()
87 private static final class StatsEvent implements EventQueue.Entry {
|
| D | StatsComponentImplBase.java | 23 import io.opencensus.implcore.internal.EventQueue;
45 public StatsComponentImplBase(EventQueue queue, Clock clock) { in StatsComponentImplBase()
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| D | TargetVM.java | 39 … private List<EventQueue> eventQueues = Collections.synchronizedList(new ArrayList<EventQueue>(2));
185 Iterator<EventQueue> iter = eventQueues.iterator(); in run()
259 Iterator<EventQueue> iter = eventQueues.iterator(); in notifyDequeueEventSet()
272 Iterator<EventQueue> iter = eventQueues.iterator(); in queueEventSet()
|
| D | EventQueueImpl.java | 29 import com.sun.jdi.event.EventQueue;
34 public class EventQueueImpl extends MirrorImpl implements EventQueue {
|
| /external/cronet/base/win/ |
| D | event_trace_consumer_unittest.cc | 33 using EventQueue = std::list<EVENT_TRACE>; typedef
51 for (EventQueue::const_iterator it(events_.begin()), end(events_.end()); in ClearQueue()
75 static EventQueue events_;
79 EventQueue TestConsumer::events_;
346 EventQueue events_;
|
| /external/opencensus-java/impl/src/test/java/io/opencensus/impl/internal/ |
| D | DisruptorEventQueueTest.java | 21 import io.opencensus.implcore.internal.EventQueue;
61 private static class IncrementEvent implements EventQueue.Entry {
|
| /external/oj-libjdwp/src/share/classes/com/sun/jdi/ |
| D | VirtualMachine.java | 28 import com.sun.jdi.event.EventQueue;
286 EventQueue eventQueue(); in eventQueue()
|
| /external/tensorflow/tensorflow/core/profiler/backends/cpu/ |
| D | traceme_recorder.cc | 119 class EventQueue { class
121 EventQueue() in EventQueue() function in tensorflow::profiler::__anon4c11b14f0111::EventQueue
131 ~EventQueue() { in ~EventQueue()
276 EventQueue queue_;
|
| /external/opencensus-java/impl_core/src/test/java/io/opencensus/implcore/trace/export/ |
| D | NoopRunningSpanStoreImplTest.java | 22 import io.opencensus.implcore.internal.EventQueue;
59 private final EventQueue eventQueue = new SimpleEventQueue();
|
| D | NoopSampledSpanStoreImplTest.java | 22 import io.opencensus.implcore.internal.EventQueue;
71 private final EventQueue eventQueue = new SimpleEventQueue();
|
| /external/opencensus-java/impl/src/main/java/io/opencensus/impl/internal/ |
| D | DisruptorEventQueue.java | 26 import io.opencensus.implcore.internal.EventQueue;
90 public final class DisruptorEventQueue implements EventQueue {
|
| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/internal/ |
| D | EventQueue.java | 20 public interface EventQueue { interface
|
| D | SimpleEventQueue.java | 23 public class SimpleEventQueue implements EventQueue {
|
| /external/oj-libjdwp/src/share/classes/com/sun/jdi/event/ |
| D | EventQueue.java | 61 public interface EventQueue extends Mirror { interface
|
| /external/cronet/net/log/ |
| D | file_net_log_observer.cc | 124 using EventQueue = base::queue<std::unique_ptr<std::string>>; typedef
156 void SwapQueue(EventQueue* local_queue);
168 EventQueue queue_;
538 void FileNetLogObserver::WriteQueue::SwapQueue(EventQueue* local_queue) { in SwapQueue()
617 EventQueue local_file_queue; in Flush()
|
| /external/javassist/src/main/javassist/util/ |
| D | HotSwapper.java | 32 import com.sun.jdi.event.EventQueue;
255 EventQueue queue = jvm.eventQueue(); in waitEvent()
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | trace.h | 158 struct EventQueue { struct
165 std::array<EventQueue, 1> eventQueues; argument
|
| /external/crosvm/devices/src/virtio/video/encoder/backend/ |
| D | ffmpeg.rs | 50 use crate::virtio::video::utils::EventQueue;
497 EventQueue::new() in start_session()
|