goldcollection
/
muwire
mirror of https://github.com/zlatinb/muwire
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

continuously update the Markov chain, purge old records

pull/53/head
Zlatin Balevsky 2020-10-22 07:20:16 +01:00
parent b2a98f6ce8
commit 6107d1e298
No known key found for this signature in database
GPG Key ID: A72832072D525E41
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
core/src/main/groovy/com/muwire/core/hostcache/H2HostCache.groovy
View File

@ -64,18 +64,14 @@ class H2HostCache extends HostCache {
if (status == ConnectionAttemptStatus.SUCCESSFUL) if (status == ConnectionAttemptStatus.SUCCESSFUL)
profiles.get(d).successfulAttempt = true profiles.get(d).successfulAttempt = true
int historyItems = profiles.get(d).hasHistory ? settings.hostProfileHistory : 1
// record into db // record into db
def timestamp = new Date(System.currentTimeMillis()) def timestamp = new Date(System.currentTimeMillis())
timestamp = SDF.format(timestamp) timestamp = SDF.format(timestamp)
sql.execute("insert into HOST_ATTEMPTS values ('${d.toBase64()}', '$timestamp', '${status.name()}');") sql.execute("insert into HOST_ATTEMPTS values ('${d.toBase64()}', '$timestamp', '${status.name()}');")
def count = sql.firstRow("select count(*) as COUNT from HOST_ATTEMPTS where DESTINATION=${d.toBase64()}") def count = sql.firstRow("select count(*) as COUNT from HOST_ATTEMPTS where DESTINATION=${d.toBase64()}")
if (count.COUNT < historyItems)
return
log.fine("recomputing Markov for ${d.toBase32()} from history items $count.COUNT / $historyItems") log.fine("recomputing Markov for ${d.toBase32()} from history items $count.COUNT")
int ss = 0 int ss = 0
int sr = 0 int sr = 0
@ -164,7 +160,13 @@ class H2HostCache extends HostCache {
profiles.put(d, new HostMCProfile(newProfile)) profiles.put(d, new HostMCProfile(newProfile))
log.fine("profile updated ${d.toBase32()} ${profiles.get(d)}") log.fine("profile updated ${d.toBase32()} ${profiles.get(d)}")
sql.execute("delete from HOST_ATTEMPTS where DESTINATION=${d.toBase64()}") def rows = sql.rows("select TSTAMP from HOST_ATTEMPTS where DESTINATION=${d.toBase64()} order by TSTAMP desc limit ${settings.hostProfileHistory}")
if (rows.size() < settings.hostProfileHistory)
return
def lastTstamp = rows[rows.size() - 1].TSTAMP
sql.execute("delete from HOST_ATTEMPTS where DESTINATION=${d.toBase64()} and TSTAMP < $lastTstamp")
log.fine("deleted $sql.updateCount old attempts")
} }
@Override @Override