Searched refs:networkEvent (Results 1 – 11 of 11) sorted by relevance
36 NetworkEvent networkEvent = NetworkEvent.builder(NetworkEvent.Type.SENT, 1L).build(); in buildNetworkEvent_WithRequiredFields() local37 assertThat(networkEvent.getType()).isEqualTo(NetworkEvent.Type.SENT); in buildNetworkEvent_WithRequiredFields()38 assertThat(networkEvent.getMessageId()).isEqualTo(1L); in buildNetworkEvent_WithRequiredFields()39 assertThat(networkEvent.getKernelTimestamp()).isNull(); in buildNetworkEvent_WithRequiredFields()40 assertThat(networkEvent.getUncompressedMessageSize()).isEqualTo(0L); in buildNetworkEvent_WithRequiredFields()45 NetworkEvent networkEvent = in buildNetworkEvent_WithTimestamp() local49 assertThat(networkEvent.getKernelTimestamp()).isEqualTo(Timestamp.fromMillis(123456L)); in buildNetworkEvent_WithTimestamp()50 assertThat(networkEvent.getType()).isEqualTo(NetworkEvent.Type.SENT); in buildNetworkEvent_WithTimestamp()51 assertThat(networkEvent.getMessageId()).isEqualTo(1L); in buildNetworkEvent_WithTimestamp()52 assertThat(networkEvent.getUncompressedMessageSize()).isEqualTo(0L); in buildNetworkEvent_WithTimestamp()[all …]
110 NetworkEvent networkEvent = in addMessageEventDefaultImplementation() local117 verify(mockSpan).addNetworkEvent(eq(networkEvent)); in addMessageEventDefaultImplementation()
53 public void addNetworkEvent(NetworkEvent networkEvent) {} in addNetworkEvent() argument
45 io.opencensus.trace.NetworkEvent networkEvent = (io.opencensus.trace.NetworkEvent) event; in asMessageEvent() local47 (networkEvent.getType() == io.opencensus.trace.NetworkEvent.Type.RECV) in asMessageEvent()50 return io.opencensus.trace.MessageEvent.builder(type, networkEvent.getMessageId()) in asMessageEvent()51 .setUncompressedMessageSize(networkEvent.getUncompressedMessageSize()) in asMessageEvent()52 .setCompressedMessageSize(networkEvent.getCompressedMessageSize()) in asMessageEvent()
161 NetworkEvent networkEvent = in toSpanData_ActiveSpan() local163 span.addNetworkEvent(networkEvent); in toSpanData_ActiveSpan()188 assertThat(spanData.getNetworkEvents().getEvents().get(0).getEvent()).isEqualTo(networkEvent); in toSpanData_ActiveSpan()220 NetworkEvent networkEvent = in toSpanData_EndedSpan() local222 span.addNetworkEvent(networkEvent); in toSpanData_EndedSpan()249 assertThat(spanData.getNetworkEvents().getEvents().get(0).getEvent()).isEqualTo(networkEvent); in toSpanData_EndedSpan()467 NetworkEvent networkEvent = in droppingNetworkEvents() local470 span.addNetworkEvent(networkEvent); in droppingNetworkEvents()480 assertThat(spanData.getNetworkEvents().getEvents().get(i).getEvent()).isEqualTo(networkEvent); in droppingNetworkEvents()490 assertThat(spanData.getNetworkEvents().getEvents().get(i).getEvent()).isEqualTo(networkEvent); in droppingNetworkEvents()
173 public void addNetworkEvent(NetworkEvent networkEvent) { in addNetworkEvent() argument174 addMessageEvent(BaseMessageEventUtils.asMessageEvent(networkEvent)); in addNetworkEvent()
73 public void addNetworkEvent(NetworkEvent networkEvent) {} in addNetworkEvent() argument
601 private static String renderNetworkEvents(io.opencensus.trace.NetworkEvent networkEvent) { in renderNetworkEvents() argument603 if (networkEvent.getType() == io.opencensus.trace.NetworkEvent.Type.RECV) { in renderNetworkEvents()605 } else if (networkEvent.getType() == io.opencensus.trace.NetworkEvent.Type.SENT) { in renderNetworkEvents()611 stringBuilder.append(networkEvent.getMessageId()); in renderNetworkEvents()613 stringBuilder.append(networkEvent.getUncompressedMessageSize()); in renderNetworkEvents()615 stringBuilder.append(networkEvent.getCompressedMessageSize()); in renderNetworkEvents()
434 for (EventWithNanoTime<T> networkEvent : events.events) { in createTimedEvents()436 networkEvent.toSpanDataTimedEvent(CheckerFrameworkUtils.castNonNull(timestampConverter))); in createTimedEvents()
193 for (TimedEvent<io.opencensus.trace.MessageEvent> networkEvent : in toTimeEventsProto()195 timeEventsBuilder.addTimeEvent(toTimeMessageEventProto(networkEvent)); in toTimeEventsProto()
223 for (TimedEvent<io.opencensus.trace.MessageEvent> networkEvent : in toTimeEventsProto()225 timeEventsBuilder.addTimeEvent(toTimeMessageEventProto(networkEvent)); in toTimeEventsProto()