idk/muwire
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

tie in crawler pong handling

Browse Source
This commit is contained in:
Zlatin Balevsky
2018-07-12 05:54:18 +01:00
parent 5a0e7a8080
commit a6131d83b0
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
host-cache/src/main/groovy/com/muwire/hostcache/HostCache.groovy
View File

@@ -61,7 +61,7 @@ public class HostCache {
timer.schedule({hostPool.age()} as TimerTask, 1000,1000) timer.schedule({hostPool.age()} as TimerTask, 1000,1000)
timer.schedule({crawler.startCrawl()} as TimerTask, 10000, 10000) timer.schedule({crawler.startCrawl()} as TimerTask, 10000, 10000)
session.addMuxedSessionListener(new Listener(hostPool: hostPool, toReturn: 2), session.addMuxedSessionListener(new Listener(hostPool: hostPool, toReturn: 2, crawler: crawler),
I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY) I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY)
session.connect() session.connect()
println "INFO: connected, going to sleep" println "INFO: connected, going to sleep"
@@ -73,6 +73,7 @@ public class HostCache {
final def json = new JsonSlurper() final def json = new JsonSlurper()
def hostPool def hostPool
int toReturn int toReturn
def crawler
void reportAbuse(I2PSession sesison, int severity) {} void reportAbuse(I2PSession sesison, int severity) {}
void disconnected(I2PSession session) { void disconnected(I2PSession session) {
@@ -110,6 +111,7 @@ public class HostCache {
break break
case "CrawlerPong": case "CrawlerPong":
println "CrawlerPong" println "CrawlerPong"
crawler.handleCrawlerPong(sender, payload)
break break
default: default:
println "WARN: Unexpected message type ${payload.type}, dropping" println "WARN: Unexpected message type ${payload.type}, dropping"