1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
// Copyright 2009-2015 Google Inc. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package com.google.devtools.build.lib.exec.util;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Iterables;
import com.google.common.eventbus.EventBus;
import com.google.devtools.build.lib.actions.ActionContextProvider;
import com.google.devtools.build.lib.actions.BlazeExecutor;
import com.google.devtools.build.lib.actions.Executor.ActionContext;
import com.google.devtools.build.lib.actions.ExecutorInitException;
import com.google.devtools.build.lib.actions.SpawnActionContext;
import com.google.devtools.build.lib.analysis.BlazeDirectories;
import com.google.devtools.build.lib.analysis.config.BinTools;
import com.google.devtools.build.lib.events.Reporter;
import com.google.devtools.build.lib.exec.ExecutionOptions;
import com.google.devtools.build.lib.exec.FileWriteStrategy;
import com.google.devtools.build.lib.exec.SymlinkTreeStrategy;
import com.google.devtools.build.lib.runtime.CommonCommandOptions;
import com.google.devtools.build.lib.util.BlazeClock;
import com.google.devtools.common.options.OptionsBase;
import com.google.devtools.common.options.OptionsParser;
import com.google.devtools.common.options.OptionsParsingException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
/**
* Builder for the test instance of the {@link BlazeExecutor} class.
*/
public class TestExecutorBuilder {
public static final List<Class<? extends OptionsBase>> DEFAULT_OPTIONS = ImmutableList.of(
ExecutionOptions.class, CommonCommandOptions.class);
private final BlazeDirectories directories;
private Reporter reporter = new Reporter();
private EventBus bus = new EventBus();
private OptionsParser optionsParser = OptionsParser.newOptionsParser(DEFAULT_OPTIONS);
private List<ActionContext> strategies = new ArrayList<>();
private Map<String, SpawnActionContext> spawnStrategyMap =
new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
public TestExecutorBuilder(BlazeDirectories directories, BinTools binTools) {
this.directories = directories;
strategies.add(new FileWriteStrategy());
strategies.add(new SymlinkTreeStrategy(null, binTools));
}
public TestExecutorBuilder setReporter(Reporter reporter) {
this.reporter = reporter;
return this;
}
public TestExecutorBuilder setBus(EventBus bus) {
this.bus = bus;
return this;
}
public TestExecutorBuilder setOptionsParser(OptionsParser optionsParser) {
this.optionsParser = optionsParser;
return this;
}
public TestExecutorBuilder parseOptions(String... options) throws OptionsParsingException {
this.optionsParser.parse(options);
return this;
}
public TestExecutorBuilder addStrategy(ActionContext strategy) {
strategies.add(strategy);
return this;
}
public TestExecutorBuilder addStrategyFactory(ActionContextProvider factory) {
Iterables.addAll(strategies, factory.getActionContexts());
return this;
}
public TestExecutorBuilder setExecution(String mnemonic, SpawnActionContext strategy) {
spawnStrategyMap.put(mnemonic, strategy);
strategies.add(strategy);
return this;
}
public BlazeExecutor build() throws ExecutorInitException {
return new BlazeExecutor(directories.getExecRoot(), directories.getOutputPath(), reporter, bus,
BlazeClock.instance(), optionsParser,
optionsParser.getOptions(ExecutionOptions.class).verboseFailures,
optionsParser.getOptions(ExecutionOptions.class).showSubcommands,
strategies,
ImmutableMap.copyOf(spawnStrategyMap), ImmutableList.<ActionContextProvider>of());
}
}
|
