zzz/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

* PRNG, LogWriter: Use I2PThread to catch OOM

Browse Source
This commit is contained in:
zzz
2012-10-02 12:38:05 +00:00
parent 83fe635438
commit 07b3c8a7b4
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
core/java/src/gnu/crypto/prng/AsyncFortunaStandalone.java
View File

@@ -5,6 +5,7 @@ import java.util.Map;
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.LinkedBlockingQueue;
import net.i2p.I2PAppContext; import net.i2p.I2PAppContext;
import net.i2p.util.I2PThread;
import net.i2p.util.Log; import net.i2p.util.Log;
/** /**
@@ -53,7 +54,7 @@ public class AsyncFortunaStandalone extends FortunaStandalone implements Runnabl
for (int i = 0; i < _bufferCount; i++) for (int i = 0; i < _bufferCount; i++)
_emptyBuffers.offer(new AsyncBuffer(_bufferSize)); _emptyBuffers.offer(new AsyncBuffer(_bufferSize));
_isRunning = true; _isRunning = true;
_refillThread = new Thread(this, "PRNG"); _refillThread = new I2PThread(this, "PRNG");
_refillThread.setDaemon(true); _refillThread.setDaemon(true);
_refillThread.setPriority(Thread.MIN_PRIORITY+1); _refillThread.setPriority(Thread.MIN_PRIORITY+1);
_refillThread.start(); _refillThread.start();

4
core/java/src/net/i2p/util/LogManager.java
View File

@@ -159,8 +159,8 @@ public class LogManager {
if (_writer != null) if (_writer != null)
return; return;
_writer = new LogWriter(this); _writer = new LogWriter(this);
// NOT an I2PThread, as it contains logging and we end up with problems // if you enable logging in I2PThread again, you MUST change this back to Thread
Thread t = new Thread(_writer, "LogWriter"); Thread t = new I2PThread(_writer, "LogWriter");
t.setDaemon(true); t.setDaemon(true);
t.start(); t.start();
} }