Nemcio/SCM-Manager
1
0
Fork 0
mirror of https://github.com/scm-manager/scm-manager.git synced 2025-12-23 16:59:48 +01:00
Code Issues Packages Projects Releases Activity

Mark files aborted recursively

Browse Source
This commit is contained in:
Rene Pfeuffer
2019-12-13 08:20:26 +01:00
parent ee0972ef34
commit c8a115a373
1 changed files with 16 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
scm-plugins/scm-git-plugin/src/main/java/sonia/scm/repository/spi/GitBrowseCommand.java
View File

@@ -185,7 +185,7 @@ public class GitBrowseCommand extends AbstractGitCommand
file.setPartialResult(true);
executor.execute(
new CompleteFileInformation(path, revId, repo, treeWalk, file, loader, request),
new AbortFileInformation(file, request)
new AbortFileInformation(request)
);
}
}
@@ -422,27 +422,32 @@ public class GitBrowseCommand extends AbstractGitCommand
}
private class AbortFileInformation implements Runnable {
private final FileObject file;
private final BrowseCommandRequest request;
public AbortFileInformation(FileObject file, BrowseCommandRequest request) {
this.file = file;
public AbortFileInformation(BrowseCommandRequest request) {
this.request = request;
}
@Override
public void run() {
synchronized (asyncMonitor) {
if (browserResult.getFile().getChildren().stream().anyMatch(FileObject::isPartialResult)) {
browserResult.getFile().getChildren().stream().filter(FileObject::isPartialResult).forEach(
f -> {
f.setPartialResult(false);
f.setComputationAborted(true);
}
);
if (markPartialAsAborted(browserResult.getFile())) {
updateCache(request);
}
}
}
private boolean markPartialAsAborted(FileObject file) {
boolean changed = false;
if (file.isPartialResult()) {
file.setPartialResult(false);
file.setComputationAborted(true);
changed = true;
}
for (FileObject child : file.getChildren()) {
changed |= markPartialAsAborted(child);
}
return changed;
}
}
}