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

do not log warning on SocketTimeoutExceptions

pull/4/head
Zlatin Balevsky 2018-07-28 22:19:16 +01:00
parent c98248f8b5
commit 2dc26cf7bf
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core/src/main/groovy/com/muwire/core/Core.groovy
View File

@ -20,6 +20,7 @@ import net.i2p.client.I2PClientFactory
import net.i2p.client.I2PSession import net.i2p.client.I2PSession
import net.i2p.client.streaming.I2PSocketManager import net.i2p.client.streaming.I2PSocketManager
import net.i2p.client.streaming.I2PSocketManagerFactory import net.i2p.client.streaming.I2PSocketManagerFactory
import net.i2p.client.streaming.I2PSocketOptions
@Log @Log
class Core { class Core {
@ -63,6 +64,8 @@ class Core {
keyDat.withInputStream { keyDat.withInputStream {
socketManager = new I2PSocketManagerFactory().createManager(it, sysProps) socketManager = new I2PSocketManagerFactory().createManager(it, sysProps)
} }
socketManager.getDefaultOptions().setReadTimeout(60000)
socketManager.getDefaultOptions().setConnectTimeout(30000)
i2pSession = socketManager.getSession() i2pSession = socketManager.getSession()

2
core/src/main/groovy/com/muwire/core/connection/Connection.groovy
View File

@ -73,6 +73,8 @@ abstract class Connection implements Closeable {
while(running.get()) { while(running.get()) {
read() read()
} }
} catch (SocketTimeoutException e) {
close()
} catch (Exception e) { } catch (Exception e) {
if (running.get()) { if (running.get()) {
log.log(Level.WARNING,"unhandled exception in reader",e) log.log(Level.WARNING,"unhandled exception in reader",e)