|
|
@ -15,6 +15,7 @@ |
|
|
|
package org.hyperledger.besu.tests.acceptance.dsl.node; |
|
|
|
package org.hyperledger.besu.tests.acceptance.dsl.node; |
|
|
|
|
|
|
|
|
|
|
|
import static org.hyperledger.besu.cli.config.NetworkName.DEV; |
|
|
|
import static org.hyperledger.besu.cli.config.NetworkName.DEV; |
|
|
|
|
|
|
|
import static org.hyperledger.besu.controller.BesuController.DATABASE_PATH; |
|
|
|
|
|
|
|
|
|
|
|
import org.hyperledger.besu.Runner; |
|
|
|
import org.hyperledger.besu.Runner; |
|
|
|
import org.hyperledger.besu.RunnerBuilder; |
|
|
|
import org.hyperledger.besu.RunnerBuilder; |
|
|
@ -57,7 +58,6 @@ import java.util.concurrent.Executors; |
|
|
|
import java.util.concurrent.TimeUnit; |
|
|
|
import java.util.concurrent.TimeUnit; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
|
|
|
|
import com.google.common.io.Files; |
|
|
|
|
|
|
|
import io.vertx.core.Vertx; |
|
|
|
import io.vertx.core.Vertx; |
|
|
|
import org.apache.logging.log4j.LogManager; |
|
|
|
import org.apache.logging.log4j.LogManager; |
|
|
|
import org.apache.logging.log4j.Logger; |
|
|
|
import org.apache.logging.log4j.Logger; |
|
|
@ -107,8 +107,9 @@ public class ThreadBesuNodeRunner implements BesuNodeRunner { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
final StorageServiceImpl storageService = new StorageServiceImpl(); |
|
|
|
final StorageServiceImpl storageService = new StorageServiceImpl(); |
|
|
|
final Path path = Files.createTempDir().toPath(); |
|
|
|
final Path dataDir = node.homeDirectory(); |
|
|
|
final BesuConfiguration commonPluginConfiguration = new BesuConfigurationImpl(path, path); |
|
|
|
final BesuConfiguration commonPluginConfiguration = |
|
|
|
|
|
|
|
new BesuConfigurationImpl(dataDir, dataDir.resolve(DATABASE_PATH)); |
|
|
|
final BesuPluginContextImpl besuPluginContext = |
|
|
|
final BesuPluginContextImpl besuPluginContext = |
|
|
|
besuPluginContextMap.computeIfAbsent( |
|
|
|
besuPluginContextMap.computeIfAbsent( |
|
|
|
node, n -> buildPluginContext(node, storageService, commonPluginConfiguration)); |
|
|
|
node, n -> buildPluginContext(node, storageService, commonPluginConfiguration)); |
|
|
|