From e873ec880e198e7e8f403743e04de4c64aa5dffe Mon Sep 17 00:00:00 2001 From: Philipp Wollermann Date: Thu, 3 Mar 2016 22:21:11 +0000 Subject: Include the file count in ChangedFilesMessage. -- MOS_MIGRATED_REVID=116292374 --- .../build/lib/skyframe/SkyframeIncrementalBuildMonitor.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) (limited to 'src/main/java/com/google/devtools/build/lib/skyframe/SkyframeIncrementalBuildMonitor.java') diff --git a/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeIncrementalBuildMonitor.java b/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeIncrementalBuildMonitor.java index a719bec42e..bb277160c1 100644 --- a/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeIncrementalBuildMonitor.java +++ b/src/main/java/com/google/devtools/build/lib/skyframe/SkyframeIncrementalBuildMonitor.java @@ -13,6 +13,7 @@ // limitations under the License. package com.google.devtools.build.lib.skyframe; +import com.google.common.collect.ImmutableSet; import com.google.common.eventbus.EventBus; import com.google.devtools.build.lib.actions.ChangedFilesMessage; import com.google.devtools.build.lib.concurrent.ThreadSafety; @@ -30,9 +31,11 @@ import java.util.Set; */ @ThreadSafety.ThreadCompatible class SkyframeIncrementalBuildMonitor { - private Set files = new HashSet<>(); private static final int MAX_FILES = 100; + private Set files = new HashSet<>(); + private int fileCount; + public void accrue(Iterable invalidatedValues) { for (SkyKey skyKey : invalidatedValues) { if (skyKey.functionName().equals(SkyFunctions.FILE_STATE)) { @@ -49,11 +52,12 @@ class SkyframeIncrementalBuildMonitor { files = null; } } + + fileCount++; } public void alertListeners(EventBus eventBus) { - if (files != null) { - eventBus.post(new ChangedFilesMessage(files)); - } + Set changedFiles = (files != null) ? files : ImmutableSet.of(); + eventBus.post(new ChangedFilesMessage(changedFiles, fileCount)); } } -- cgit v1.2.3