Skip to content

Commit 861c3ca

Browse files
committed
Revert "Remote: Fix a race when reporting action progresses."
This reverts commit 170e57d.
1 parent afb8196 commit 861c3ca

File tree

1 file changed

+3
-13
lines changed

1 file changed

+3
-13
lines changed

src/main/java/com/google/devtools/build/lib/runtime/UiStateTracker.java

Lines changed: 3 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -62,14 +62,12 @@
6262
import java.util.LinkedHashMap;
6363
import java.util.List;
6464
import java.util.Map;
65-
import java.util.Optional;
6665
import java.util.PriorityQueue;
6766
import java.util.Set;
6867
import java.util.TreeMap;
6968
import java.util.concurrent.ConcurrentHashMap;
7069
import java.util.concurrent.atomic.AtomicInteger;
7170
import javax.annotation.Nullable;
72-
import javax.annotation.concurrent.GuardedBy;
7371
import javax.annotation.concurrent.ThreadSafe;
7472

7573
/** Tracks state for the UI. */
@@ -230,7 +228,6 @@ private ProgressState(String id, long nanoStartTime) {
230228
}
231229
}
232230

233-
@GuardedBy("this")
234231
private final LinkedHashMap<String, ProgressState> runningProgresses = new LinkedHashMap<>();
235232

236233
/** Starts tracking the state of an action. */
@@ -336,13 +333,6 @@ synchronized void onProgressEvent(ActionProgressEvent event, long nanoChangeTime
336333
state.latestEvent = event;
337334
}
338335

339-
synchronized Optional<ProgressState> firstProgress() {
340-
if (runningProgresses.isEmpty()) {
341-
return Optional.empty();
342-
}
343-
return Optional.of(runningProgresses.entrySet().iterator().next().getValue());
344-
}
345-
346336
/** Generates a human-readable description of this action's state. */
347337
synchronized String describe() {
348338
if (runningStrategiesBitmap != 0) {
@@ -715,12 +705,12 @@ private String describeTestGroup(
715705
}
716706

717707
private String describeActionProgress(ActionState action, int desiredWidth) {
718-
Optional<ActionState.ProgressState> stateOpt = action.firstProgress();
719-
if (!stateOpt.isPresent()) {
708+
if (action.runningProgresses.isEmpty()) {
720709
return "";
721710
}
722711

723-
ActionState.ProgressState state = stateOpt.get();
712+
ActionState.ProgressState state =
713+
action.runningProgresses.entrySet().iterator().next().getValue();
724714
ActionProgressEvent event = state.latestEvent;
725715
String message = event.progress();
726716
if (message.isEmpty()) {

0 commit comments

Comments
 (0)