Home
last modified time | relevance | path

Searched refs:eventQueue (Results 1 – 11 of 11) sorted by relevance

/external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/
DExportComponentImpl.java62 public static ExportComponentImpl createWithInProcessStores(EventQueue eventQueue) { in createWithInProcessStores() argument
63 return new ExportComponentImpl(true, eventQueue); in createWithInProcessStores()
72 public static ExportComponentImpl createWithoutInProcessStores(EventQueue eventQueue) { in createWithoutInProcessStores() argument
73 return new ExportComponentImpl(false, eventQueue); in createWithoutInProcessStores()
82 private ExportComponentImpl(boolean supportInProcessStores, EventQueue eventQueue) { in ExportComponentImpl() argument
90 ? new InProcessSampledSpanStoreImpl(eventQueue) in ExportComponentImpl()
DInProcessSampledSpanStoreImpl.java55 private final EventQueue eventQueue; field in InProcessSampledSpanStoreImpl
247 InProcessSampledSpanStoreImpl(EventQueue eventQueue) { in InProcessSampledSpanStoreImpl() argument
249 this.eventQueue = eventQueue; in InProcessSampledSpanStoreImpl()
283 eventQueue.enqueue(new RegisterSpanNameEvent(this, spanNames)); in registerSpanNamesForCollection()
288 eventQueue.shutdown(); in shutdown()
319 eventQueue.enqueue(new UnregisterSpanNameEvent(this, spanNames)); in unregisterSpanNamesForCollection()
/external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/
DTraceComponentImplBase.java54 public TraceComponentImplBase(Clock clock, RandomHandler randomHandler, EventQueue eventQueue) { in TraceComponentImplBase() argument
57 if (eventQueue instanceof SimpleEventQueue) { in TraceComponentImplBase()
58 exportComponent = ExportComponentImpl.createWithoutInProcessStores(eventQueue); in TraceComponentImplBase()
60 exportComponent = ExportComponentImpl.createWithInProcessStores(eventQueue); in TraceComponentImplBase()
67 eventQueue); in TraceComponentImplBase()
DStartEndHandlerImpl.java38 private final EventQueue eventQueue; field in StartEndHandlerImpl
55 EventQueue eventQueue) { in StartEndHandlerImpl() argument
60 this.eventQueue = eventQueue; in StartEndHandlerImpl()
66 eventQueue.enqueue(new SpanStartEvent(span, runningSpanStore)); in onStart()
74 eventQueue.enqueue(new SpanEndEvent(span, spanExporter, runningSpanStore, sampledSpanStore)); in onEnd()
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/framework/jdwp/
DPacketDispatcher.java89 private List<EventPacket> eventQueue; field in PacketDispatcher.EventsSynchronyzer
96 eventQueue = new ArrayList<EventPacket>(); in EventsSynchronyzer()
112 eventQueue.add(eventPacket); in notifyThread()
138 synchronized (eventQueue) { in waitForNextEvent()
139 if (!eventQueue.isEmpty()) { in waitForNextEvent()
140 return eventQueue.remove(0); in waitForNextEvent()
155 synchronized (eventQueue) { in waitForNextEvent()
156 if (!eventQueue.isEmpty()) { in waitForNextEvent()
158 EventPacket event = eventQueue.remove(0); in waitForNextEvent()
/external/opencensus-java/impl_core/src/test/java/io/opencensus/implcore/trace/export/
DNoopRunningSpanStoreImplTest.java59 private final EventQueue eventQueue = new SimpleEventQueue(); field in NoopRunningSpanStoreImplTest
61 ExportComponentImpl.createWithoutInProcessStores(eventQueue).getRunningSpanStore();
DNoopSampledSpanStoreImplTest.java71 private final EventQueue eventQueue = new SimpleEventQueue(); field in NoopSampledSpanStoreImplTest
73 ExportComponentImpl.createWithoutInProcessStores(eventQueue).getSampledSpanStore();
/external/opencensus-java/impl/src/main/java/io/opencensus/impl/internal/
DDisruptorEventQueue.java101 private static final DisruptorEventQueue eventQueue = create(); field in DisruptorEventQueue
158 return eventQueue; in getInstance()
/external/oj-libjdwp/src/share/classes/com/sun/jdi/
DVirtualMachine.java286 EventQueue eventQueue(); in eventQueue() method
/external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/
DVirtualMachineImpl.java55 private final EventQueueImpl eventQueue; field in VirtualMachineImpl
187 eventQueue = new EventQueueImpl(this, target); in VirtualMachineImpl()
454 public EventQueue eventQueue() { in eventQueue() method in VirtualMachineImpl
460 return eventQueue; in eventQueue()
/external/javassist/src/main/javassist/util/
DHotSwapper.java255 EventQueue queue = jvm.eventQueue(); in waitEvent()