2 files changed, 2 insertions, 92 deletions

diff --git a/src/main/java/com/google/devtools/build/lib/skyframe/LoadingProgressReceiver.java b/src/main/java/com/google/devtools/build/lib/skyframe/LoadingProgressReceiver.java
deleted file mode 100644
index e7a4929c26..0000000000
--- a/src/main/java/com/google/devtools/build/lib/skyframe/LoadingProgressReceiver.java
+++ /dev/null
@@ -1,76 +0,0 @@
-// Copyright 2016 The Bazel Authors. All rights reserved.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-//    http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-package com.google.devtools.build.lib.skyframe;
-
-import com.google.common.base.Supplier;
-import com.google.common.collect.Sets;
-import com.google.devtools.build.skyframe.EvaluationProgressReceiver;
-import com.google.devtools.build.skyframe.SkyKey;
-import com.google.devtools.build.skyframe.SkyValue;
-
-import java.util.ArrayDeque;
-import java.util.Deque;
-import java.util.Set;
-
-/**
- * An {@link EvaluationProgressReceiver} used during loading phase
- *
- * It receives updates about progress in the loading phase via the
- * {@link EvaluationProgressReceiver} interface. These updates get aggregated
- * and a summary of the current state of the loading phase can be obtained via
- * and provides a summary about the current state via the {@link #progressState}
- * method.
- */
-public class LoadingProgressReceiver implements EvaluationProgressReceiver {
-
-  private final Set<SkyKey> enqueuedPackages = Sets.newConcurrentHashSet();
-  private final Set<SkyKey> completedPackages = Sets.newConcurrentHashSet();
-  private final Deque<SkyKey> pending = new ArrayDeque<>();
-
-  @Override
-  public void invalidated(SkyKey skyKey, InvalidationState state) {}
-
-  @Override
-  public synchronized void enqueueing(SkyKey skyKey) {
-    if (skyKey.functionName().equals(SkyFunctions.PACKAGE)) {
-      enqueuedPackages.add(skyKey);
-      pending.addLast(skyKey);
-    }
-  }
-
-  @Override
-  public void computed(SkyKey skyKey, long elapsedTimeNanos) {}
-
-  @Override
-  public synchronized void evaluated(
-      SkyKey skyKey, Supplier<SkyValue> valueSupplier, EvaluationState state) {
-    if (skyKey.functionName().equals(SkyFunctions.PACKAGE)) {
-      completedPackages.add(skyKey);
-      pending.remove(skyKey);
-    }
-  }
-
-  public synchronized String progressState() {
-    long completed = completedPackages.size();
-    long enqueued = enqueuedPackages.size();
-    String answer = "" + completed + " / " + enqueued;
-    if (enqueued > completed) {
-      answer += " " + pending.peekFirst().toString();
-      if (enqueued > completed + 1) {
-        answer += " ... (" + pending.size() + " currently loading)";
-      }
-    }
-    return answer;
-  }
-}
diff --git a/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeExecutor.java b/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeExecutor.java
index 2246515a36..1b57421399 100644
--- a/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeExecutor.java
+++ b/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeExecutor.java
@@ -1736,16 +1736,9 @@ public abstract class SkyframeExecutor implements WalkableGraphFactory {
           options.buildTestsOnly, determineTests,
           TestFilter.forOptions(options, eventHandler, ruleClassNames));
       EvaluationResult<TargetPatternPhaseValue> evalResult;
-      LoadingProgressReceiver loadingProgressReceiver = new LoadingProgressReceiver();
       eventBus.post(new LoadingPhaseStartedEvent(packageProgress));
-      progressReceiver.loadingProgressReceiver = loadingProgressReceiver;
-      try {
-        evalResult =
-            buildDriver.evaluate(
-                ImmutableList.of(key), keepGoing, /*numThreads=*/ 10, eventHandler);
-      } finally {
-        progressReceiver.loadingProgressReceiver = null;
-      }
+      evalResult =
+          buildDriver.evaluate(ImmutableList.of(key), keepGoing, /*numThreads=*/ 10, eventHandler);
       if (evalResult.hasError()) {
         ErrorInfo errorInfo = evalResult.getError(key);
         if (!Iterables.isEmpty(errorInfo.getCycleInfo())) {
@@ -1795,7 +1788,6 @@ public abstract class SkyframeExecutor implements WalkableGraphFactory {
     /** This receiver is only needed for execution, so it is null otherwise. */
     @Nullable EvaluationProgressReceiver executionProgressReceiver = null;
     /** This receiver is only needed for loading, so it is null otherwise. */
-    @Nullable EvaluationProgressReceiver loadingProgressReceiver = null;
 
     @Override
     public void invalidated(SkyKey skyKey, InvalidationState state) {
@@ -1811,9 +1803,6 @@ public abstract class SkyframeExecutor implements WalkableGraphFactory {
         return;
       }
       skyframeBuildView.getInvalidationReceiver().enqueueing(skyKey);
-      if (loadingProgressReceiver != null) {
-        loadingProgressReceiver.enqueueing(skyKey);
-      }
       if (executionProgressReceiver != null) {
         executionProgressReceiver.enqueueing(skyKey);
       }
@@ -1828,9 +1817,6 @@ public abstract class SkyframeExecutor implements WalkableGraphFactory {
         return;
       }
       skyframeBuildView.getInvalidationReceiver().evaluated(skyKey, valueSupplier, state);
-      if (loadingProgressReceiver != null) {
-        loadingProgressReceiver.evaluated(skyKey, valueSupplier, state);
-      }
       if (executionProgressReceiver != null) {
         executionProgressReceiver.evaluated(skyKey, valueSupplier, state);
       }