aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/main/java/com
diff options
context:
space:
mode:
authorGravatar Nathan Harmata <nharmata@google.com>2016-11-21 16:20:41 +0000
committerGravatar Dmitry Lomov <dslomov@google.com>2016-11-21 19:42:15 +0000
commitc4e965e920e1fb6328407147c478513769d0a2c7 (patch)
tree92b74b2e5a0db9b1fb05b8745454ab4634a6db74 /src/main/java/com
parentf75878dcaa97733abe984aea8e9b65554683aa18 (diff)
Enable parallel evaluation of 'e' in query expressions of the form 'buildfiles(e)'.
-- MOS_MIGRATED_REVID=139787078
Diffstat (limited to 'src/main/java/com')
-rw-r--r--src/main/java/com/google/devtools/build/lib/query2/engine/BuildFilesFunction.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/main/java/com/google/devtools/build/lib/query2/engine/BuildFilesFunction.java b/src/main/java/com/google/devtools/build/lib/query2/engine/BuildFilesFunction.java
index 81f20d4a74..0e65cbdf05 100644
--- a/src/main/java/com/google/devtools/build/lib/query2/engine/BuildFilesFunction.java
+++ b/src/main/java/com/google/devtools/build/lib/query2/engine/BuildFilesFunction.java
@@ -52,7 +52,7 @@ class BuildFilesFunction implements QueryFunction {
env.eval(
args.get(0).getExpression(),
context,
- new Callback<T>() {
+ new ThreadSafeCallback<T>() {
@Override
public void process(Iterable<T> partialResult)
throws QueryException, InterruptedException {
@@ -73,6 +73,7 @@ class BuildFilesFunction implements QueryFunction {
List<Argument> args,
ThreadSafeCallback<T> callback,
ForkJoinPool forkJoinPool) throws QueryException, InterruptedException {
+ // 'eval' is written in such a way that it enables parallel evaluation of 'expression'.
eval(env, context, expression, args, callback);
}