diff options
author | Oleg Tsarev <oleg@oleg.sh> | 2017-07-24 14:32:20 +0200 |
---|---|---|
committer | Jakob Buchgraber <buchgr@google.com> | 2017-07-24 21:04:31 +0200 |
commit | 20416ffa2bf18535d1fa2c560f996cf2ab88ea6b (patch) | |
tree | ff6da7341e1453bb738c568c8efad8d251bacb27 /src/main/java/com/google/devtools/build/lib | |
parent | 7d85d8b3a4448ff8b8c6db92960d5920bbbd4844 (diff) |
Update install-os-x.md
Incorrect instruction for OSX (apt-get instead of brew)
Closes #3437.
PiperOrigin-RevId: 162923095
Diffstat (limited to 'src/main/java/com/google/devtools/build/lib')
4 files changed, 46 insertions, 55 deletions
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 85259f8d6b..7ecfcb020a 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,7 +28,6 @@ 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; @@ -57,66 +56,61 @@ public final class BuildEventServiceProtoUtil { public PublishLifecycleEventRequest buildEnqueued() { return lifecycleEvent(projectId, 1, - com.google.devtools.build.v1.BuildEvent.newBuilder() - .setEventTime(Timestamps.fromMillis(clock.currentTimeMillis())) - .setBuildEnqueued(BuildEnqueued.newBuilder())) + com.google.devtools.build.v1.BuildEvent.newBuilder() + .setEventTime(Timestamps.fromMillis(clock.currentTimeMillis())) + .setBuildEnqueued(BuildEnqueued.newBuilder())) .build(); } public PublishLifecycleEventRequest buildFinished(Result result) { return lifecycleEvent(projectId, 2, - com.google.devtools.build.v1.BuildEvent.newBuilder() - .setEventTime(Timestamps.fromMillis(clock.currentTimeMillis())) - .setBuildFinished( - BuildFinished.newBuilder() - .setStatus(BuildStatus.newBuilder().setResult(result)))) + com.google.devtools.build.v1.BuildEvent.newBuilder() + .setEventTime(Timestamps.fromMillis(clock.currentTimeMillis())) + .setBuildFinished( + BuildFinished.newBuilder() + .setStatus(BuildStatus.newBuilder().setResult(result)))) .build(); } public PublishLifecycleEventRequest invocationStarted() { return lifecycleEvent(projectId, 1, - com.google.devtools.build.v1.BuildEvent.newBuilder() - .setEventTime(Timestamps.fromMillis(clock.currentTimeMillis())) - .setInvocationAttemptStarted( - InvocationAttemptStarted.newBuilder().setAttemptNumber(1))) + com.google.devtools.build.v1.BuildEvent.newBuilder() + .setEventTime(Timestamps.fromMillis(clock.currentTimeMillis())) + .setInvocationAttemptStarted( + InvocationAttemptStarted.newBuilder().setAttemptNumber(1))) .build(); } public PublishLifecycleEventRequest invocationFinished(Result result) { return lifecycleEvent(projectId, 2, - com.google.devtools.build.v1.BuildEvent.newBuilder() - .setEventTime(Timestamps.fromMillis(clock.currentTimeMillis())) - .setInvocationAttemptFinished( - InvocationAttemptFinished.newBuilder() - .setInvocationStatus(BuildStatus.newBuilder().setResult(result)))) + com.google.devtools.build.v1.BuildEvent.newBuilder() + .setEventTime(Timestamps.fromMillis(clock.currentTimeMillis())) + .setInvocationAttemptFinished( + InvocationAttemptFinished.newBuilder() + .setInvocationStatus(BuildStatus.newBuilder().setResult(result)))) .build(); } - /** - * Utility method used to create a PublishBuildToolEventStreamRequest that delimits the end of the - * stream. - */ - public PublishBuildToolEventStreamRequest streamFinished() { + /** Utility method used to create a OrderedBuildEvent that delimits the end of the stream. */ + public OrderedBuildEvent streamFinished() { return streamFinished(streamSequenceNumber.getAndIncrement()); } - /** - * Utility method used to create a PublishBuildToolEventStreamRequest from an packed bazel event - */ - public PublishBuildToolEventStreamRequest bazelEvent(Any packedEvent) { + /** Utility method used to create a OrderedBuildEvent from an packed bazel event */ + public OrderedBuildEvent bazelEvent(Any packedEvent) { return bazelEvent(streamSequenceNumber.getAndIncrement(), packedEvent); } @VisibleForTesting - public PublishBuildToolEventStreamRequest bazelEvent(int sequenceNumber, Any packedEvent) { - return publishBuildToolEventStreamRequest( + public OrderedBuildEvent bazelEvent(int sequenceNumber, Any packedEvent) { + return orderedBuildEvent( sequenceNumber, com.google.devtools.build.v1.BuildEvent.newBuilder().setBazelEvent(packedEvent)); } @VisibleForTesting - public PublishBuildToolEventStreamRequest streamFinished(int sequenceNumber) { - return publishBuildToolEventStreamRequest( + public OrderedBuildEvent streamFinished(int sequenceNumber) { + return orderedBuildEvent( sequenceNumber, BuildEvent.newBuilder() .setComponentStreamFinished( @@ -124,9 +118,8 @@ public final class BuildEventServiceProtoUtil { } @VisibleForTesting - public PublishBuildToolEventStreamRequest publishBuildToolEventStreamRequest( - int sequenceNumber, BuildEvent.Builder besEvent) { - return PublishBuildToolEventStreamRequest.newBuilder() + public OrderedBuildEvent orderedBuildEvent(int sequenceNumber, BuildEvent.Builder besEvent) { + return OrderedBuildEvent.newBuilder() .setSequenceNumber(sequenceNumber) .setEvent(besEvent.setEventTime(Timestamps.fromMillis(clock.currentTimeMillis()))) .setStreamId(streamId(besEvent.getEventCase())) diff --git a/src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceTransport.java b/src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceTransport.java index ce2053c8b7..b7c8ce770e 100644 --- a/src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceTransport.java +++ b/src/main/java/com/google/devtools/build/lib/buildeventservice/BuildEventServiceTransport.java @@ -49,7 +49,7 @@ import com.google.devtools.build.lib.util.AbruptExitException; import com.google.devtools.build.lib.util.Clock; import com.google.devtools.build.lib.util.ExitCode; import com.google.devtools.build.v1.BuildStatus.Result; -import com.google.devtools.build.v1.PublishBuildToolEventStreamRequest; +import com.google.devtools.build.v1.OrderedBuildEvent; import com.google.devtools.build.v1.PublishBuildToolEventStreamResponse; import com.google.devtools.build.v1.PublishLifecycleEventRequest; import com.google.protobuf.Any; @@ -93,9 +93,9 @@ public class BuildEventServiceTransport implements BuildEventTransport { private final PathConverter pathConverter; /** Contains all pendingAck events that might be retried in case of failures. */ - private ConcurrentLinkedDeque<PublishBuildToolEventStreamRequest> pendingAck; + private ConcurrentLinkedDeque<OrderedBuildEvent> pendingAck; /** Contains all events should be sent ordered by sequence number. */ - private final BlockingDeque<PublishBuildToolEventStreamRequest> pendingSend; + private final BlockingDeque<OrderedBuildEvent> pendingSend; /** Holds the result status of the BuildEventStreamProtos BuildFinished event. */ private Result invocationResult; /** Used to block until all events have been uploaded. */ @@ -304,8 +304,7 @@ public class BuildEventServiceTransport implements BuildEventTransport { } } - private synchronized void sendOrderedBuildEvent( - PublishBuildToolEventStreamRequest serialisedEvent) { + private synchronized void sendOrderedBuildEvent(OrderedBuildEvent serialisedEvent) { if (uploadComplete != null && uploadComplete.isDone()) { maybeReportUploadError(); return; @@ -400,7 +399,7 @@ public class BuildEventServiceTransport implements BuildEventTransport { */ private Status publishEventStream() throws Exception { // Reschedule unacked messages if required, keeping its original order. - PublishBuildToolEventStreamRequest unacked; + OrderedBuildEvent unacked; while ((unacked = pendingAck.pollLast()) != null) { pendingSend.addFirst(unacked); } @@ -412,11 +411,11 @@ public class BuildEventServiceTransport implements BuildEventTransport { /** Method responsible for a single Streaming RPC. */ private static ListenableFuture<Status> publishEventStream( - final ConcurrentLinkedDeque<PublishBuildToolEventStreamRequest> pendingAck, - final BlockingDeque<PublishBuildToolEventStreamRequest> pendingSend, + final ConcurrentLinkedDeque<OrderedBuildEvent> pendingAck, + final BlockingDeque<OrderedBuildEvent> pendingSend, final BuildEventServiceClient besClient) throws Exception { - PublishBuildToolEventStreamRequest event; + OrderedBuildEvent event; ListenableFuture<Status> streamDone = besClient.openStream(ackCallback(pendingAck, besClient)); try { do { @@ -433,13 +432,12 @@ public class BuildEventServiceTransport implements BuildEventTransport { return streamDone; } - private static boolean isLastEvent(PublishBuildToolEventStreamRequest event) { + private static boolean isLastEvent(OrderedBuildEvent event) { return event != null && event.getEvent().getEventCase() == COMPONENT_STREAM_FINISHED; } private static Function<PublishBuildToolEventStreamResponse, Void> ackCallback( - final Deque<PublishBuildToolEventStreamRequest> pendingAck, - final BuildEventServiceClient besClient) { + final Deque<OrderedBuildEvent> pendingAck, final BuildEventServiceClient besClient) { return ack -> { long pendingSeq = pendingAck.isEmpty() ? -1 : pendingAck.peekFirst().getSequenceNumber(); long ackSeq = ack.getSequenceNumber(); diff --git a/src/main/java/com/google/devtools/build/lib/buildeventservice/client/BuildEventServiceClient.java b/src/main/java/com/google/devtools/build/lib/buildeventservice/client/BuildEventServiceClient.java index 5721118352..6feb53c808 100644 --- a/src/main/java/com/google/devtools/build/lib/buildeventservice/client/BuildEventServiceClient.java +++ b/src/main/java/com/google/devtools/build/lib/buildeventservice/client/BuildEventServiceClient.java @@ -16,7 +16,7 @@ package com.google.devtools.build.lib.buildeventservice.client; import com.google.common.base.Function; import com.google.common.util.concurrent.ListenableFuture; -import com.google.devtools.build.v1.PublishBuildToolEventStreamRequest; +import com.google.devtools.build.v1.OrderedBuildEvent; import com.google.devtools.build.v1.PublishBuildToolEventStreamResponse; import com.google.devtools.build.v1.PublishLifecycleEventRequest; import io.grpc.Status; @@ -38,7 +38,7 @@ public interface BuildEventServiceClient { * guarantee that all callback calls have been received. * * @param ackCallback Consumer called every time a ack message is received. - * @return Listenable future that blocks until the onDone callback is called. + * @return Listenable future that blocks until the the onDone callback is called. * @throws Exception */ ListenableFuture<Status> openStream( @@ -50,7 +50,7 @@ public interface BuildEventServiceClient { * @param buildEvent Event that should be sent. * @throws Exception */ - void sendOverStream(PublishBuildToolEventStreamRequest buildEvent) throws Exception; + void sendOverStream(OrderedBuildEvent buildEvent) throws Exception; /** * Closes the currently opened opened stream. This method does not block. Callers should block on diff --git a/src/main/java/com/google/devtools/build/lib/buildeventservice/client/BuildEventServiceGrpcClient.java b/src/main/java/com/google/devtools/build/lib/buildeventservice/client/BuildEventServiceGrpcClient.java index 583837992d..86e33e09e8 100644 --- a/src/main/java/com/google/devtools/build/lib/buildeventservice/client/BuildEventServiceGrpcClient.java +++ b/src/main/java/com/google/devtools/build/lib/buildeventservice/client/BuildEventServiceGrpcClient.java @@ -27,10 +27,10 @@ import com.google.common.base.Throwables; import com.google.common.collect.ImmutableList; import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.SettableFuture; +import com.google.devtools.build.v1.OrderedBuildEvent; import com.google.devtools.build.v1.PublishBuildEventGrpc; import com.google.devtools.build.v1.PublishBuildEventGrpc.PublishBuildEventBlockingStub; import com.google.devtools.build.v1.PublishBuildEventGrpc.PublishBuildEventStub; -import com.google.devtools.build.v1.PublishBuildToolEventStreamRequest; import com.google.devtools.build.v1.PublishBuildToolEventStreamResponse; import com.google.devtools.build.v1.PublishLifecycleEventRequest; import io.grpc.CallCredentials; @@ -71,7 +71,7 @@ public class BuildEventServiceGrpcClient implements BuildEventServiceClient { private final PublishBuildEventStub besAsync; private final PublishBuildEventBlockingStub besBlocking; private final ManagedChannel channel; - private final AtomicReference<StreamObserver<PublishBuildToolEventStreamRequest>> streamReference; + private final AtomicReference<StreamObserver<OrderedBuildEvent>> streamReference; public BuildEventServiceGrpcClient(String serverSpec, boolean tlsEnabled, @Nullable String tlsCertificateFile, @Nullable String tlsAuthorityOverride, @@ -116,7 +116,7 @@ public class BuildEventServiceGrpcClient implements BuildEventServiceClient { return streamFinished; } - private StreamObserver<PublishBuildToolEventStreamRequest> createStream( + private StreamObserver<OrderedBuildEvent> createStream( final Function<PublishBuildToolEventStreamResponse, Void> ack, final SettableFuture<Status> streamFinished) { return besAsync.publishBuildToolEventStream( @@ -141,14 +141,14 @@ public class BuildEventServiceGrpcClient implements BuildEventServiceClient { } @Override - public void sendOverStream(PublishBuildToolEventStreamRequest buildEvent) throws Exception { + public void sendOverStream(OrderedBuildEvent buildEvent) throws Exception { checkNotNull(streamReference.get(), "Attempting to send over a closed or unopened stream") .onNext(buildEvent); } @Override public void closeStream() { - StreamObserver<PublishBuildToolEventStreamRequest> stream; + StreamObserver<OrderedBuildEvent> stream; if ((stream = streamReference.getAndSet(null)) != null) { stream.onCompleted(); } @@ -156,7 +156,7 @@ public class BuildEventServiceGrpcClient implements BuildEventServiceClient { @Override public void abortStream(Status status) { - StreamObserver<PublishBuildToolEventStreamRequest> stream; + StreamObserver<OrderedBuildEvent> stream; if ((stream = streamReference.getAndSet(null)) != null) { stream.onError(status.asException()); } |