提交 fcedb332 authored 作者: Thomas Mueller's avatar Thomas Mueller

H2 Console: The progress display when opening a database has been improved.

上级 b6826c56
...@@ -1115,16 +1115,16 @@ class WebThread extends Thread implements DatabaseEventListener { ...@@ -1115,16 +1115,16 @@ class WebThread extends Thread implements DatabaseEventListener {
} }
public void setProgress(int state, String name, int x, int max) { public void setProgress(int state, String name, int x, int max) {
name = PageParser.escapeHtml(name);
if (state == listenerLastState) { if (state == listenerLastState) {
long time = System.currentTimeMillis(); long time = System.currentTimeMillis();
if (listenerLastEvent + 500 < time) { if (time < listenerLastEvent + 1000) {
return; return;
} }
listenerLastEvent = time; listenerLastEvent = time;
} else { } else {
listenerLastState = state; listenerLastState = state;
} }
name = PageParser.escapeHtml(name);
switch (state) { switch (state) {
case DatabaseEventListener.STATE_BACKUP_FILE: case DatabaseEventListener.STATE_BACKUP_FILE:
log("Backing up " + name + " " + (100L * x / max) + "%"); log("Backing up " + name + " " + (100L * x / max) + "%");
......
...@@ -187,7 +187,7 @@ public class TableData extends Table implements RecordReader { ...@@ -187,7 +187,7 @@ public class TableData extends Table implements RecordReader {
int bufferSize = Constants.DEFAULT_MAX_MEMORY_ROWS; int bufferSize = Constants.DEFAULT_MAX_MEMORY_ROWS;
ObjectArray buffer = new ObjectArray(bufferSize); ObjectArray buffer = new ObjectArray(bufferSize);
while (cursor.next()) { while (cursor.next()) {
database.setProgress(DatabaseEventListener.STATE_CREATE_INDEX, getName(), MathUtils database.setProgress(DatabaseEventListener.STATE_CREATE_INDEX, getName() + ":" + index.getName(), MathUtils
.convertLongToInt(i++), MathUtils.convertLongToInt(total)); .convertLongToInt(i++), MathUtils.convertLongToInt(total));
Row row = cursor.get(); Row row = cursor.get();
// index.add(session, row); // index.add(session, row);
......
...@@ -164,7 +164,7 @@ public class TestOpenClose extends TestBase implements DatabaseEventListener { ...@@ -164,7 +164,7 @@ public class TestOpenClose extends TestBase implements DatabaseEventListener {
break; break;
case STATE_CREATE_INDEX: case STATE_CREATE_INDEX:
stateName = "Create Index " + name + " " + current + "/" + max; stateName = "Create Index " + name + " " + current + "/" + max;
if (!"SYS".equals(name)) { if (!"SYS:SYS_ID".equals(name)) {
throw new Error("unexpected: " + stateName); throw new Error("unexpected: " + stateName);
} }
break; break;
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论