diff --git a/node/src/main/kotlin/net/corda/node/services/statemachine/ActionExecutorImpl.kt b/node/src/main/kotlin/net/corda/node/services/statemachine/ActionExecutorImpl.kt index 4b86ff8091..925fdc99a7 100644 --- a/node/src/main/kotlin/net/corda/node/services/statemachine/ActionExecutorImpl.kt +++ b/node/src/main/kotlin/net/corda/node/services/statemachine/ActionExecutorImpl.kt @@ -2,13 +2,8 @@ package net.corda.node.services.statemachine import co.paralleluniverse.fibers.Suspendable import com.codahale.metrics.Gauge -import com.codahale.metrics.Histogram -import com.codahale.metrics.MetricRegistry import com.codahale.metrics.Reservoir -import com.codahale.metrics.SlidingTimeWindowArrayReservoir -import com.codahale.metrics.SlidingTimeWindowReservoir import net.corda.core.internal.concurrent.thenMatch -import net.corda.core.serialization.SerializedBytes import net.corda.core.serialization.internal.CheckpointSerializationContext import net.corda.core.serialization.internal.checkpointSerialize import net.corda.core.utilities.contextLogger @@ -19,8 +14,6 @@ import net.corda.nodeapi.internal.persistence.contextDatabase import net.corda.nodeapi.internal.persistence.contextTransaction import net.corda.nodeapi.internal.persistence.contextTransactionOrNull import java.time.Duration -import java.util.concurrent.TimeUnit -import java.util.concurrent.atomic.AtomicLong /** * This is the bottom execution engine of flow side-effects. diff --git a/node/src/test/kotlin/net/corda/node/services/rpc/CheckpointDumperImplTest.kt b/node/src/test/kotlin/net/corda/node/services/rpc/CheckpointDumperImplTest.kt index 4ae38eaf21..4eb5bd5a98 100644 --- a/node/src/test/kotlin/net/corda/node/services/rpc/CheckpointDumperImplTest.kt +++ b/node/src/test/kotlin/net/corda/node/services/rpc/CheckpointDumperImplTest.kt @@ -10,23 +10,17 @@ import net.corda.core.context.InvocationContext import net.corda.core.flows.FlowLogic import net.corda.core.flows.StateMachineRunId import net.corda.core.identity.CordaX500Name -import net.corda.core.internal.FlowIORequest import net.corda.core.internal.createDirectories import net.corda.core.internal.deleteIfExists import net.corda.core.internal.deleteRecursively import net.corda.core.internal.div import net.corda.core.internal.inputStream -import net.corda.core.internal.isRegularFile -import net.corda.core.internal.list import net.corda.core.internal.readFully import net.corda.core.node.ServiceHub import net.corda.core.serialization.SerializeAsToken import net.corda.core.serialization.SerializedBytes import net.corda.core.serialization.internal.CheckpointSerializationDefaults import net.corda.core.serialization.internal.checkpointSerialize -import net.corda.core.utilities.toNonEmptySet -import net.corda.nodeapi.internal.lifecycle.NodeServicesContext -import net.corda.nodeapi.internal.lifecycle.NodeLifecycleEvent import net.corda.node.internal.NodeStartup import net.corda.node.services.persistence.CheckpointPerformanceRecorder import net.corda.node.services.persistence.DBCheckpointStorage @@ -35,6 +29,8 @@ import net.corda.node.services.statemachine.CheckpointState import net.corda.node.services.statemachine.FlowStart import net.corda.node.services.statemachine.FlowState import net.corda.node.services.statemachine.SubFlowVersion +import net.corda.nodeapi.internal.lifecycle.NodeLifecycleEvent +import net.corda.nodeapi.internal.lifecycle.NodeServicesContext import net.corda.nodeapi.internal.persistence.CordaPersistence import net.corda.testing.core.SerializationEnvironmentRule import net.corda.testing.core.TestIdentity @@ -45,12 +41,10 @@ import org.junit.Before import org.junit.Rule import org.junit.Test import java.nio.file.Files -import java.nio.file.Path import java.nio.file.Paths import java.time.Clock import java.time.Instant import java.util.zip.ZipInputStream -import kotlin.test.assertEquals class CheckpointDumperImplTest { diff --git a/node/src/test/kotlin/net/corda/node/services/statemachine/FlowFrameworkTests.kt b/node/src/test/kotlin/net/corda/node/services/statemachine/FlowFrameworkTests.kt index 05955f343b..72ea1fbdd6 100644 --- a/node/src/test/kotlin/net/corda/node/services/statemachine/FlowFrameworkTests.kt +++ b/node/src/test/kotlin/net/corda/node/services/statemachine/FlowFrameworkTests.kt @@ -31,7 +31,6 @@ import net.corda.core.node.services.PartyInfo import net.corda.core.node.services.queryBy import net.corda.core.serialization.SerializedBytes import net.corda.core.serialization.deserialize -import net.corda.core.serialization.internal.CheckpointSerializationDefaults import net.corda.core.serialization.serialize import net.corda.core.toFuture import net.corda.core.transactions.SignedTransaction @@ -45,9 +44,6 @@ import net.corda.node.services.persistence.CheckpointPerformanceRecorder import net.corda.node.services.persistence.DBCheckpointStorage import net.corda.node.services.persistence.checkpoints import net.corda.nodeapi.internal.persistence.DatabaseTransaction -import net.corda.nodeapi.internal.persistence.contextDatabase -import net.corda.nodeapi.internal.persistence.contextTransaction -import net.corda.nodeapi.internal.persistence.contextTransactionOrNull import net.corda.testing.contracts.DummyContract import net.corda.testing.contracts.DummyState import net.corda.testing.core.ALICE_NAME