Home
last modified time | relevance | path

Searched refs:messageEvent (Results 1 – 14 of 14) sorted by relevance

/external/opencensus-java/api/src/test/java/io/opencensus/trace/
DMessageEventTest.java35 MessageEvent messageEvent = MessageEvent.builder(MessageEvent.Type.SENT, 1L).build(); in buildMessageEvent_WithRequiredFields() local
36 assertThat(messageEvent.getType()).isEqualTo(MessageEvent.Type.SENT); in buildMessageEvent_WithRequiredFields()
37 assertThat(messageEvent.getMessageId()).isEqualTo(1L); in buildMessageEvent_WithRequiredFields()
38 assertThat(messageEvent.getUncompressedMessageSize()).isEqualTo(0L); in buildMessageEvent_WithRequiredFields()
43 MessageEvent messageEvent = in buildMessageEvent_WithUncompressedMessageSize() local
45 assertThat(messageEvent.getType()).isEqualTo(MessageEvent.Type.SENT); in buildMessageEvent_WithUncompressedMessageSize()
46 assertThat(messageEvent.getMessageId()).isEqualTo(1L); in buildMessageEvent_WithUncompressedMessageSize()
47 assertThat(messageEvent.getUncompressedMessageSize()).isEqualTo(123L); in buildMessageEvent_WithUncompressedMessageSize()
52 MessageEvent messageEvent = in buildMessageEvent_WithCompressedMessageSize() local
54 assertThat(messageEvent.getType()).isEqualTo(MessageEvent.Type.SENT); in buildMessageEvent_WithCompressedMessageSize()
[all …]
DSpanTest.java105 MessageEvent messageEvent = in addMessageEventDefaultImplementation() local
115 Mockito.doCallRealMethod().when(mockSpan).addMessageEvent(messageEvent); in addMessageEventDefaultImplementation()
116 mockSpan.addMessageEvent(messageEvent); in addMessageEventDefaultImplementation()
DNoopSpan.java56 public void addMessageEvent(MessageEvent messageEvent) { in addMessageEvent() argument
57 Utils.checkNotNull(messageEvent, "messageEvent"); in addMessageEvent()
/external/perfetto/ui/src/frontend/
Dpost_message_handler.ts45 export function postMessageHandler(messageEvent: MessageEvent) {
46 if (messageEvent.origin === 'https://tagassistant.google.com') {
57 if (messageEvent.source === null || messageEvent.source !== window.opener) {
62 if (!('data' in messageEvent)) {
66 if (messageEvent.data === 'PING') {
70 const windowSource = messageEvent.source as Window;
71 windowSource.postMessage('PONG', messageEvent.origin);
77 if (isPostedTraceWrapped(messageEvent.data)) {
78 postedTrace = sanitizePostedTrace(messageEvent.data.perfetto);
79 } else if (messageEvent.data instanceof ArrayBuffer) {
[all …]
/external/opencensus-java/api/src/main/java/io/opencensus/trace/internal/
DBaseMessageEventUtils.java69 io.opencensus.trace.MessageEvent messageEvent = (io.opencensus.trace.MessageEvent) event; in asNetworkEvent() local
71 (messageEvent.getType() == io.opencensus.trace.MessageEvent.Type.RECEIVED) in asNetworkEvent()
74 return io.opencensus.trace.NetworkEvent.builder(type, messageEvent.getMessageId()) in asNetworkEvent()
75 .setUncompressedMessageSize(messageEvent.getUncompressedMessageSize()) in asNetworkEvent()
76 .setCompressedMessageSize(messageEvent.getCompressedMessageSize()) in asNetworkEvent()
/external/opencensus-java/api/src/main/java/io/opencensus/trace/
DSpan.java188 public void addMessageEvent(MessageEvent messageEvent) { in addMessageEvent() argument
191 Utils.checkNotNull(messageEvent, "messageEvent"); in addMessageEvent()
192 addNetworkEvent(BaseMessageEventUtils.asNetworkEvent(messageEvent)); in addMessageEvent()
DBlankSpan.java77 public void addMessageEvent(MessageEvent messageEvent) { in addMessageEvent() argument
78 Utils.checkNotNull(messageEvent, "messageEvent"); in addMessageEvent()
/external/opencensus-java/exporters/trace/ocagent/src/main/java/io/opencensus/exporter/trace/ocagent/
DTraceProtoUtils.java216 io.opencensus.trace.MessageEvent messageEvent = timedEvent.getEvent(); in toTimeMessageEventProto() local
219 .setId(messageEvent.getMessageId()) in toTimeMessageEventProto()
220 .setCompressedSize(messageEvent.getCompressedMessageSize()) in toTimeMessageEventProto()
221 .setUncompressedSize(messageEvent.getUncompressedMessageSize()) in toTimeMessageEventProto()
222 .setType(toMessageEventTypeProto(messageEvent)) in toTimeMessageEventProto()
228 io.opencensus.trace.MessageEvent messageEvent) { in toMessageEventTypeProto() argument
229 if (messageEvent.getType() == Type.RECEIVED) { in toMessageEventTypeProto()
/external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/
DNoRecordEventsSpanImpl.java63 public void addMessageEvent(io.opencensus.trace.MessageEvent messageEvent) { in addMessageEvent() argument
64 Preconditions.checkNotNull(messageEvent, "messageEvent"); in addMessageEvent()
DRecordEventsSpanImpl.java331 public void addMessageEvent(io.opencensus.trace.MessageEvent messageEvent) { in addMessageEvent() argument
332 Preconditions.checkNotNull(messageEvent, "messageEvent"); in addMessageEvent()
341 clock.nowNanos(), checkNotNull(messageEvent, "networkEvent"))); in addMessageEvent()
/external/opencensus-java/exporters/trace/stackdriver/src/main/java/io/opencensus/exporter/trace/stackdriver/
DStackdriverV2ExporterHandler.java246 io.opencensus.trace.MessageEvent messageEvent = timedEvent.getEvent(); in toTimeMessageEventProto() local
249 .setId(messageEvent.getMessageId()) in toTimeMessageEventProto()
250 .setCompressedSizeBytes(messageEvent.getCompressedMessageSize()) in toTimeMessageEventProto()
251 .setUncompressedSizeBytes(messageEvent.getUncompressedMessageSize()) in toTimeMessageEventProto()
252 .setType(toMessageEventTypeProto(messageEvent)) in toTimeMessageEventProto()
258 io.opencensus.trace.MessageEvent messageEvent) { in toMessageEventTypeProto() argument
259 if (messageEvent.getType() == Type.RECEIVED) { in toMessageEventTypeProto()
/external/opencensus-java/exporters/trace/zipkin/src/main/java/io/opencensus/exporter/trace/zipkin/
DZipkinExporterHandler.java144 for (TimedEvent<io.opencensus.trace.MessageEvent> messageEvent : in generateSpan()
147 toEpochMicros(messageEvent.getTimestamp()), messageEvent.getEvent().getType().name()); in generateSpan()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DStatsTestUtils.java350 public void addMessageEvent(MessageEvent messageEvent) {}
/external/guice/extensions/persist/lib/
Dantlr-2.7.5h3.jarMETA-INF/ META-INF/MANIFEST.MF antlr/ antlr/ActionElement.class ActionElement ...