Author: jflesch
Date: 2007-07-22 22:55:17 +0000 (Sun, 22 Jul 2007)
New Revision: 14271
Modified:
trunk/apps/Thaw/src/thaw/plugins/miniFrost/frostKSK/KSKBoard.java
Log:
Fix once again the board refreshing
Modified: trunk/apps/Thaw/src/thaw/plugins/miniFrost/frostKSK/KSKBoard.java
===================================================================
--- trunk/apps/Thaw/src/thaw/plugins/miniFrost/frostKSK/KSKBoard.java
2007-07-22 22:40:23 UTC (rev 14270)
+++ trunk/apps/Thaw/src/thaw/plugins/miniFrost/frostKSK/KSKBoard.java
2007-07-22 22:55:17 UTC (rev 14271)
@@ -112,13 +112,6 @@
protected int getNextNonDownloadedRev(Date daDate, int rev) {
java.sql.Date date = new java.sql.Date(daDate.getTime());
- /* just a check */
- for (int i = 0 ; i < runningDownloads.length ; i++) {
- if (runningDownloads[i] != null
- && runningDownloads[i].getRev() > rev)
- rev = runningDownloads[i].getRev();
- }
-
try {
Hsqldb db = factory.getDb();
@@ -126,7 +119,7 @@
PreparedStatement st;
st =
db.getConnection().prepareStatement("SELECT rev FROM frostKSKMessages "+
- "WHERE
date >= ? AND date <= ? "+
+ "WHERE
date >= ? AND date < ? "+
"AND
rev > ? ORDER by rev");
st.setDate(1, date);
st.setDate(2, new java.sql.Date(date.getTime()
+ 24*60*60*1000));
@@ -178,13 +171,16 @@
int rev = getNextNonDownloadedRev(lastDate, lastRev);
+ Logger.debug(this, "Rev : "+Integer.toString(lastRev)+
+ " ; "+Integer.toString(rev));
+
runningDownloads[slot] = new KSKMessage(this, lastDate, rev);
runningDownloads[slot].addObserver(this);
runningDownloads[slot].download(factory.getCore().getQueueManager(),
factory.getDb());
+ if (lastRev < rev)
+ lastRev = rev;
- lastRev = rev;
-
}
protected void notifyChange() {
