ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-04-10 12:50:37 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Merge branch 'release/os/4.5' into rfowler-os-4.5-os-4.6-20200511

Browse Source
This commit is contained in:
Ryan Fowler 2020-05-11 15:42:46 +01:00
commit c8d3d22841
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
client/rpc/src/integration-test/kotlin/net/corda/client/rpc/RPCStabilityTests.kt
View File

@ -70,7 +70,11 @@ class RPCStabilityTests {
private fun waitUntilNumberOfThreadsStable(executorService: ScheduledExecutorService): Map<Thread, List<StackTraceElement>> {
val values = ConcurrentLinkedQueue<Map<Thread, List<StackTraceElement>>>()
return poll(executorService, "number of threads to become stable", 250.millis) {
values.add(Thread.getAllStackTraces().mapValues { it.value.toList() })
// Exclude threads which we don't use for timing our tests
val map: Map<Thread, List<StackTraceElement>> = Thread.getAllStackTraces()
.filterKeys { !it.name.contains("ForkJoinPool.commonPool") }
.mapValues { it.value.toList() }
values.add(map)
if (values.size > 5) {
values.poll()
}