From 9e62187df84ae425a5d7226b6baf1bef576f0a10 Mon Sep 17 00:00:00 2001 From: Kai Xu Date: Mon, 24 Jul 2017 20:48:54 +0200 Subject: The first step to allow non-lifecycle build stream to specify notification keywords. Change-Id: I8421e9d2d8a5e6720d7b8d6de4417bee71c0fa68 PiperOrigin-RevId: 162966141 --- .../BuildEventServiceProtoUtil.java | 27 ++++++++++++++-------- 1 file changed, 17 insertions(+), 10 deletions(-) (limited to 'src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceProtoUtil.java') diff --git a/src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceProtoUtil.java b/src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceProtoUtil.java index 7ecfcb020a..90209f0b15 100644 --- a/src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceProtoUtil.java +++ b/src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceProtoUtil.java @@ -28,6 +28,7 @@ import com.google.devtools.build.v1.BuildEvent.InvocationAttemptStarted; import com.google.devtools.build.v1.BuildStatus; import com.google.devtools.build.v1.BuildStatus.Result; import com.google.devtools.build.v1.OrderedBuildEvent; +import com.google.devtools.build.v1.PublishBuildToolEventStreamRequest; import com.google.devtools.build.v1.PublishLifecycleEventRequest; import com.google.devtools.build.v1.StreamId; import com.google.devtools.build.v1.StreamId.BuildComponent; @@ -91,26 +92,31 @@ public final class BuildEventServiceProtoUtil { .build(); } - /** Utility method used to create a OrderedBuildEvent that delimits the end of the stream. */ - public OrderedBuildEvent streamFinished() { + /** + * Utility method used to create a PublishBuildToolEventStreamRequest that delimits the end of the + * stream. + */ + public PublishBuildToolEventStreamRequest streamFinished() { return streamFinished(streamSequenceNumber.getAndIncrement()); } - /** Utility method used to create a OrderedBuildEvent from an packed bazel event */ - public OrderedBuildEvent bazelEvent(Any packedEvent) { + /** + * Utility method used to create a PublishBuildToolEventStreamRequest from an packed bazel event + */ + public PublishBuildToolEventStreamRequest bazelEvent(Any packedEvent) { return bazelEvent(streamSequenceNumber.getAndIncrement(), packedEvent); } @VisibleForTesting - public OrderedBuildEvent bazelEvent(int sequenceNumber, Any packedEvent) { - return orderedBuildEvent( + public PublishBuildToolEventStreamRequest bazelEvent(int sequenceNumber, Any packedEvent) { + return publishBuildToolEventStreamRequest( sequenceNumber, com.google.devtools.build.v1.BuildEvent.newBuilder().setBazelEvent(packedEvent)); } @VisibleForTesting - public OrderedBuildEvent streamFinished(int sequenceNumber) { - return orderedBuildEvent( + public PublishBuildToolEventStreamRequest streamFinished(int sequenceNumber) { + return publishBuildToolEventStreamRequest( sequenceNumber, BuildEvent.newBuilder() .setComponentStreamFinished( @@ -118,8 +124,9 @@ public final class BuildEventServiceProtoUtil { } @VisibleForTesting - public OrderedBuildEvent orderedBuildEvent(int sequenceNumber, BuildEvent.Builder besEvent) { - return OrderedBuildEvent.newBuilder() + public PublishBuildToolEventStreamRequest publishBuildToolEventStreamRequest( + int sequenceNumber, BuildEvent.Builder besEvent) { + return PublishBuildToolEventStreamRequest.newBuilder() .setSequenceNumber(sequenceNumber) .setEvent(besEvent.setEventTime(Timestamps.fromMillis(clock.currentTimeMillis()))) .setStreamId(streamId(besEvent.getEventCase())) -- cgit v1.2.3