final File to = new File(
configDir, String.format(SIM_DEVICE_CFG_PREFIX + "%d-%d.xml", batchStart, openDevice));
generatedConfigs.add(to);
- Files.write(builder.toString(), to, StandardCharsets.UTF_8);
+ Files.asCharSink(to, StandardCharsets.UTF_8).write(builder.toString());
connectorCount = 0;
builder = new StringBuilder();
builder.append(before);
final File to = new File(configDir, String.format(
SIM_DEVICE_CFG_PREFIX + "%d-%d.xml", batchStart, openDevices.get(openDevices.size() - 1)));
generatedConfigs.add(to);
- Files.write(builder.toString(), to, StandardCharsets.UTF_8);
+ Files.asCharSink(to, StandardCharsets.UTF_8).write(builder.toString());
}
LOG.info("Config files generated in {}", configDir);
while (true) {
root.warn("Starting scale test with {} devices", params.deviceCount);
- final ScheduledFuture timeoutGuardFuture = EXECUTOR.schedule(new TimeoutGuard(), TIMEOUT, TimeUnit.MINUTES);
+ final ScheduledFuture<?> timeoutGuardFuture = EXECUTOR.schedule(new TimeoutGuard(), TIMEOUT,
+ TimeUnit.MINUTES);
final Configuration configuration = new ConfigurationBuilder().from(params).build();
final NetconfDeviceSimulator netconfDeviceSimulator = new NetconfDeviceSimulator(configuration);
try {
private static class ScaleVerifyCallable implements Callable<Void> {
private static final Logger LOG = LoggerFactory.getLogger(ScaleVerifyCallable.class);
- private static final String RESTCONF_URL
- = "http://127.0.0.1:8181/restconf/operational/network-topology:network-topology/topology/topology-netconf/";
+ private static final String RESTCONF_URL = "http://127.0.0.1:8181/restconf/operational/"
+ + "network-topology:network-topology/topology/topology-netconf/";
private static final Pattern PATTERN = Pattern.compile("connected");
private final AsyncHttpClient asyncHttpClient = new AsyncHttpClient(new Builder()
final String editContentString;
try {
if (stream == null) {
- editContentString = Files.toString(editContent, StandardCharsets.UTF_8);
+ editContentString = Files.asCharSource(editContent, StandardCharsets.UTF_8).read();
} else {
editContentString = CharStreams.toString(new InputStreamReader(stream, StandardCharsets.UTF_8));
}
private final String destination;
private final String payload;
- DestToPayload(String destination, String payload) {
+ DestToPayload(final String destination, final String payload) {
this.destination = destination;
this.payload = payload;
}
}
- public static void main(String[] args) {
+ public static void main(final String[] args) {
Parameters parameters = parseArgs(args, Parameters.getParser());
parameters.validate();
final String editContentString;
try {
- editContentString = Files.toString(parameters.editContent, StandardCharsets.UTF_8);
+ editContentString = Files.asCharSource(parameters.editContent, StandardCharsets.UTF_8).read();
} catch (final IOException e) {
throw new IllegalArgumentException("Cannot read content of " + parameters.editContent, e);
}
final String editContentString;
try {
- editContentString = Files.toString(params.editContent, StandardCharsets.UTF_8);
+ editContentString = Files.asCharSource(params.editContent, StandardCharsets.UTF_8).read();
} catch (final IOException e) {
throw new IllegalArgumentException("Cannot read content of " + params.editContent, e);
}