github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Tidy up

Browse Source 
1. Rename TestNameToConsoleRunListener to RedissonTestRunListener
2. Moved Test stats processing code to RedissonTestRunListener from RedissonRuntimeEnvironment.
pull/509/head
jackygurui 9 years ago
parent eaa64c879c
commit 128dd665dc
4 changed files with 101 additions and 84 deletions
Show Stats Download Patch File Download Diff File

2
pom.xml
Unescape Escape View File

@ -356,7 +356,7 @@
<properties>
<property>
<name>listener</name>
<value>org.redisson.TestNameToConsoleRunListener</value>
<value>org.redisson.RedissonTestRunListener</value>
</property>
</properties>
</configuration>

25
src/test/java/org/redisson/RedissonRuntimeEnvironment.java
Unescape Escape View File

@ -19,30 +19,5 @@ public class RedissonRuntimeEnvironment {
static {
OS = System.getProperty("os.name", "generic");
isWindows = OS.toLowerCase(Locale.ENGLISH).contains("win");
if (RedissonRuntimeEnvironment.isTravis) {
final AtomicBoolean running = new AtomicBoolean(Boolean.TRUE);
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
running.set(Boolean.FALSE);
}));
new Thread(() -> {
final RuntimeMXBean runtimeBean = ManagementFactory.getRuntimeMXBean();
final AtomicLong u = new AtomicLong(runtimeBean.getUptime());
while (running.get()) {
try {
long upTime = runtimeBean.getUptime();
if (upTime >= u.get() + 10000) {
u.set(upTime);
System.out.printf("Test Up Time = %.3f (s)%n", upTime / 1000d);
System.out.printf("Heap Usage = %.3f (MB)%n", ManagementFactory.getMemoryMXBean().getHeapMemoryUsage().getUsed() / 1024d / 1024d);
System.out.printf("None Heap Usage = %.3f (MB)%n", ManagementFactory.getMemoryMXBean().getNonHeapMemoryUsage().getUsed() / 1024d / 1024d);
System.out.println("=============================");
}
Thread.currentThread().sleep(10000l);
} catch (InterruptedException ex) {
Logger.getLogger(RedissonRuntimeEnvironment.class.getName()).log(Level.SEVERE, null, ex);
}
}
}).start();
}
}
}

100
src/test/java/org/redisson/RedissonTestRunListener.java
Unescape Escape View File

@ -0,0 +1,100 @@
package org.redisson;
import java.lang.management.ManagementFactory;
import java.lang.management.RuntimeMXBean;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.stream.IntStream;
import org.junit.runner.Description;
import org.junit.runner.Result;
import org.junit.runner.notification.Failure;
import org.junit.runner.notification.RunListener;
public class RedissonTestRunListener extends RunListener {
private final AtomicBoolean running = new AtomicBoolean(Boolean.TRUE);
@Override
public void testRunStarted(Description description) throws Exception {
super.testRunStarted(description);
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
running.set(Boolean.FALSE);
}));
new Thread(() -> {
final RuntimeMXBean runtimeBean = ManagementFactory.getRuntimeMXBean();
final AtomicLong u = new AtomicLong(runtimeBean.getUptime());
while (running.get()) {
try {
long upTime = runtimeBean.getUptime();
if (upTime >= u.get() + 10000) {
u.set(upTime);
System.out.printf("Test Up Time = %.3f (s)%n", upTime / 1000d);
System.out.printf("Heap Usage = %.3f (MB)%n", ManagementFactory.getMemoryMXBean().getHeapMemoryUsage().getUsed() / 1024d / 1024d);
System.out.printf("None Heap Usage = %.3f (MB)%n", ManagementFactory.getMemoryMXBean().getNonHeapMemoryUsage().getUsed() / 1024d / 1024d);
System.out.println("=============================");
}
Thread.currentThread().sleep(10000l);
} catch (InterruptedException ex) {
Logger.getLogger(RedissonTestRunListener.class.getName()).log(Level.SEVERE, null, ex);
}
}
}).start();
}
@Override
public void testRunFinished(Result result) throws Exception {
super.testRunFinished(result);
running.set(Boolean.FALSE);
}
@Override
public void testStarted(Description d) throws Exception {
super.testStarted(d);
printTestName("Started", d.getDisplayName(), '*');
}
@Override
public void testFinished(Description d) throws Exception {
super.testFinished(d);
printTestName("Finished", d.getDisplayName());
}
@Override
public void testIgnored(Description d) throws Exception {
super.testIgnored(d);
printTestName("Ignored", d.getDisplayName());
}
@Override
public void testFailure(Failure f) throws Exception {
super.testFailure(f);
printTestName("Failed", f.getTestHeader());
}
@Override
public void testAssumptionFailure(Failure f) {
super.testAssumptionFailure(f);
printTestName("Assumption Failed", f.getTestHeader());
}
private static void printTestName(String action, String test) {
printTestName(action, test, '=');
}
private static void printTestName(String action, String test, char c) {
int dividers = 16 + action.length() + test.length();
aBeautifulDivider(dividers, c);
System.out.println(" " + action + " Test: " + test);
aBeautifulDivider(dividers, c);
}
private static void aBeautifulDivider(int times, char c) {
System.out.println("");
IntStream.iterate(0, n -> n++)
.limit(times)
.forEach((i) -> System.out.print(c));
System.out.println("\n");
}
}

58
src/test/java/org/redisson/TestNameToConsoleRunListener.java
Unescape Escape View File

@ -1,58 +0,0 @@
package org.redisson;
import java.util.stream.IntStream;
import org.junit.runner.Description;
import org.junit.runner.notification.Failure;
import org.junit.runner.notification.RunListener;
public class TestNameToConsoleRunListener extends RunListener {
@Override
public void testStarted(Description d) throws Exception {
super.testStarted(d);
printTestName("Started", d.getDisplayName(), '*');
}
@Override
public void testFinished(Description d) throws Exception {
super.testFinished(d);
printTestName("Finished", d.getDisplayName());
}
@Override
public void testIgnored(Description d) throws Exception {
super.testIgnored(d);
printTestName("Ignored", d.getDisplayName());
}
@Override
public void testFailure(Failure f) throws Exception {
super.testFailure(f);
printTestName("Failed", f.getTestHeader());
}
@Override
public void testAssumptionFailure(Failure f) {
super.testAssumptionFailure(f);
printTestName("Assumption Failed", f.getTestHeader());
}
private static void printTestName(String action, String test) {
printTestName(action, test, '=');
}
private static void printTestName(String action, String test, char c) {
int dividers = 16 + action.length() + test.length();
aBeautifulDivider(dividers, c);
System.out.println(" " + action + " Test: " + test);
aBeautifulDivider(dividers, c);
}
private static void aBeautifulDivider(int times, char c) {
System.out.println("");
IntStream.iterate(0, n -> n++)
.limit(times)
.forEach((i) -> System.out.print(c));
System.out.println("\n");
}
}
Write Preview
Loading…
Cancel
Save