mirror of
https://github.com/corda/corda.git
synced 2025-02-06 11:09:18 +00:00
Moved a bunch of tests that were in the integration bucket into unit (#3576)
This commit is contained in:
parent
92f59f2ad2
commit
1d91272698
@ -1,4 +1,4 @@
|
|||||||
package net.corda.node
|
package net.corda.node.internal.cordapp
|
||||||
|
|
||||||
import com.typesafe.config.Config
|
import com.typesafe.config.Config
|
||||||
import com.typesafe.config.ConfigException
|
import com.typesafe.config.ConfigException
|
||||||
@ -6,7 +6,6 @@ import com.typesafe.config.ConfigFactory
|
|||||||
import com.typesafe.config.ConfigRenderOptions
|
import com.typesafe.config.ConfigRenderOptions
|
||||||
import net.corda.core.internal.div
|
import net.corda.core.internal.div
|
||||||
import net.corda.core.internal.writeText
|
import net.corda.core.internal.writeText
|
||||||
import net.corda.node.internal.cordapp.CordappConfigFileProvider
|
|
||||||
import org.assertj.core.api.Assertions.assertThat
|
import org.assertj.core.api.Assertions.assertThat
|
||||||
import org.junit.Test
|
import org.junit.Test
|
||||||
import java.nio.file.Paths
|
import java.nio.file.Paths
|
@ -45,7 +45,6 @@ import org.junit.Test
|
|||||||
import org.slf4j.MDC
|
import org.slf4j.MDC
|
||||||
import java.security.PublicKey
|
import java.security.PublicKey
|
||||||
import java.util.concurrent.Future
|
import java.util.concurrent.Future
|
||||||
import java.util.concurrent.TimeUnit
|
|
||||||
import java.util.concurrent.atomic.AtomicInteger
|
import java.util.concurrent.atomic.AtomicInteger
|
||||||
import kotlin.test.assertNotEquals
|
import kotlin.test.assertNotEquals
|
||||||
|
|
||||||
@ -198,7 +197,7 @@ class TimedFlowTests {
|
|||||||
val stx = requestPayload.signedTransaction
|
val stx = requestPayload.signedTransaction
|
||||||
subFlow(ResolveTransactionsFlow(stx, otherSideSession))
|
subFlow(ResolveTransactionsFlow(stx, otherSideSession))
|
||||||
|
|
||||||
if (TimedFlowTests.requestsReceived.getAndIncrement() == 0) {
|
if (requestsReceived.getAndIncrement() == 0) {
|
||||||
logger.info("Ignoring")
|
logger.info("Ignoring")
|
||||||
// Waiting forever
|
// Waiting forever
|
||||||
stateMachine.suspend(FlowIORequest.WaitForLedgerCommit(SecureHash.randomSHA256()), false)
|
stateMachine.suspend(FlowIORequest.WaitForLedgerCommit(SecureHash.randomSHA256()), false)
|
Loading…
x
Reference in New Issue
Block a user