diff options
author | 2016-03-03 22:21:11 +0000 | |
---|---|---|
committer | 2016-03-04 12:16:48 +0000 | |
commit | e873ec880e198e7e8f403743e04de4c64aa5dffe (patch) | |
tree | a195dd974f8a6d6838166d07bb090020fc6ada15 /src/main/java/com/google/devtools/build/lib/skyframe/SkyframeIncrementalBuildMonitor.java | |
parent | 191d9804047fe2d19c6ca561b6f8de6ccbdc93fb (diff) |
Include the file count in ChangedFilesMessage.
--
MOS_MIGRATED_REVID=116292374
Diffstat (limited to 'src/main/java/com/google/devtools/build/lib/skyframe/SkyframeIncrementalBuildMonitor.java')
-rw-r--r-- | src/main/java/com/google/devtools/build/lib/skyframe/SkyframeIncrementalBuildMonitor.java | 12 |
1 files changed, 8 insertions, 4 deletions
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<PathFragment> files = new HashSet<>(); private static final int MAX_FILES = 100; + private Set<PathFragment> files = new HashSet<>(); + private int fileCount; + public void accrue(Iterable<SkyKey> 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<PathFragment> changedFiles = (files != null) ? files : ImmutableSet.<PathFragment>of(); + eventBus.post(new ChangedFilesMessage(changedFiles, fileCount)); } } |