提交 412311f3 authored 作者: Thomas Mueller's avatar Thomas Mueller

Test.

上级 c595aa4e
...@@ -65,7 +65,7 @@ public class TestCrashAPI extends TestBase implements Runnable { ...@@ -65,7 +65,7 @@ public class TestCrashAPI extends TestBase implements Runnable {
private ArrayList<String> statements = New.arrayList(); private ArrayList<String> statements = New.arrayList();
private int openCount; private int openCount;
private long callCount; private long callCount;
private volatile long maxWait = 5 * 60; private volatile long maxWait = 60;
private volatile boolean stopped; private volatile boolean stopped;
private volatile boolean running; private volatile boolean running;
private Thread mainThread; private Thread mainThread;
...@@ -90,15 +90,15 @@ public class TestCrashAPI extends TestBase implements Runnable { ...@@ -90,15 +90,15 @@ public class TestCrashAPI extends TestBase implements Runnable {
maxWait++; maxWait++;
// ignore // ignore
} }
if (maxWait > 0 && maxWait <= 10) {
println("stopping...");
stopped = true;
}
} }
if (maxWait > 0 && maxWait <= 10) { if (maxWait == 0 && running) {
println("stopping...");
stopped = true;
} else if (maxWait == 0) {
println("stopping (force)...");
objects.clear(); objects.clear();
if (running) { if (running) {
System.out.println("stopping main thread:"); println("stopping (force)...");
for (StackTraceElement e : mainThread.getStackTrace()) { for (StackTraceElement e : mainThread.getStackTrace()) {
System.out.println(e.toString()); System.out.println(e.toString());
} }
...@@ -289,9 +289,14 @@ public class TestCrashAPI extends TestBase implements Runnable { ...@@ -289,9 +289,14 @@ public class TestCrashAPI extends TestBase implements Runnable {
// Thread.sleep(1); // Thread.sleep(1);
// } // }
if (objects.size() == 0 && !stopped) { if (objects.size() == 0) {
try { try {
long start = System.currentTimeMillis();
conn = getConnection(seed, false); conn = getConnection(seed, false);
long connectTime = System.currentTimeMillis() - start;
if (connectTime > 2000) {
System.out.println("??? connected in " + connectTime);
}
} catch (SQLException e) { } catch (SQLException e) {
if ("08004".equals(e.getSQLState())) { if ("08004".equals(e.getSQLState())) {
// Wrong user/password [08004] // Wrong user/password [08004]
...@@ -302,7 +307,12 @@ public class TestCrashAPI extends TestBase implements Runnable { ...@@ -302,7 +307,12 @@ public class TestCrashAPI extends TestBase implements Runnable {
break; break;
} }
try { try {
long start = System.currentTimeMillis();
conn = getConnection(seed, false); conn = getConnection(seed, false);
long connectTime = System.currentTimeMillis() - start;
if (connectTime > 2000) {
System.out.println("??? connected2 in " + connectTime);
}
} catch (Throwable t) { } catch (Throwable t) {
printIfBad(seed, -i, -1, t); printIfBad(seed, -i, -1, t);
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论