I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

reduce the job pipeline to send a message by fetching the bids and adding the message to the connection queue synchronously

Browse Source 
these had been broken out into seperate jobs before to reduce thread and lock contention, but that isn't as serious an issue anymore (in these cases) and the non-contention-related delays of these mini-jobs are trivial
This commit is contained in:
jrandom
2004-07-09 03:48:12 +00:00
committed by zzz
parent bdfa6e4af5
commit 94e694fc61
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java
View File

@ -48,7 +48,8 @@ public class CommSystemFacadeImpl extends CommSystemFacade {
} }
public void processMessage(OutNetMessage msg) { public void processMessage(OutNetMessage msg) {
_context.jobQueue().addJob(new GetBidsJob(_context, this, msg)); GetBidsJob j = new GetBidsJob(_context, this, msg);
j.runJob();
} }
public String renderStatusHTML() { return _manager.renderStatusHTML(); } public String renderStatusHTML() { return _manager.renderStatusHTML(); }

4
router/java/src/net/i2p/router/transport/tcp/TCPTransport.java
View File

@ -119,7 +119,9 @@ public class TCPTransport extends TransportImpl {
* and it should not block * and it should not block
*/ */
protected void outboundMessageReady() { protected void outboundMessageReady() {
_context.jobQueue().addJob(new NextJob()); //_context.jobQueue().addJob(new NextJob());
NextJob j = new NextJob();
j.runJob();
} }
private class NextJob extends JobImpl { private class NextJob extends JobImpl {