ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-25 19:11:45 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

no private

Browse Source
This commit is contained in:
Zoltan Kiss 2019-10-08 15:30:57 +01:00
parent b4e5967dc1
commit 3857f092cd
2 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.idea/codeStyles/codeStyleConfig.xml generated
View File

@ -1,6 +1,5 @@
<component name="ProjectCodeStyleConfiguration">
<state>
<option name="USE_PER_PROJECT_SETTINGS" value="true" />
<option name="PREFERRED_PROJECT_CODE_STYLE" value="Default" />
</state>
</component>

12
buildSrc/src/main/groovy/net/corda/testing/KubesTest.groovy
View File

@ -89,19 +89,19 @@ class KubesTest extends DefaultTask {
List<Future<KubePodResult>> futures = IntStream.range(0, numberOfPods).mapToObj({ i ->
String podName = "$taskToExecuteName-$stableRunId-$random-$i"
runBuild(client, namespace, numberOfPods, i, podName, printOutput, 3)
submitBuild(client, namespace, numberOfPods, i, podName, printOutput, 3)
}).collect(Collectors.toList())
this.testOutput = Collections.synchronizedList(futures.collect { it -> it.get().binaryResults }.flatten())
this.containerResults = futures.collect { it -> it.get() }
}
private static def rnd64Base36(Random rnd) {
static def rnd64Base36(Random rnd) {
return new BigInteger(64, rnd)
.toString(36)
.toLowerCase()
}
private Future<KubePodResult> runBuild(
Future<KubePodResult> submitBuild(
KubernetesClient client,
String namespace,
int numberOfPods,
@ -119,7 +119,7 @@ class KubesTest extends DefaultTask {
})
}
private def createPvc(KubernetesClient client, String name) {
def createPvc(KubernetesClient client, String name) {
def pvc = client.persistentVolumeClaims()
.inNamespace(namespace)
.createNew()
@ -140,7 +140,7 @@ class KubesTest extends DefaultTask {
return pvc
}
private KubePodResult buildRunPodWithRetriesOrThrow(
KubePodResult buildRunPodWithRetriesOrThrow(
KubernetesClient client,
String namespace,
PersistentVolumeClaim pvc,
@ -261,7 +261,7 @@ class KubesTest extends DefaultTask {
}
}
private Watch attachStatusListenerToPod(KubernetesClient client, Pod pod) {
Watch attachStatusListenerToPod(KubernetesClient client, Pod pod) {
client.pods().inNamespace(pod.metadata.namespace).withName(pod.metadata.name).watch(new Watcher<Pod>() {
@Override
void eventReceived(Watcher.Action action, Pod resource) {