Changeset 0d622660


Ignore:
Timestamp:
Sep 8, 2012 2:04:01 PM (8 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
98da06c
Parents:
1ae0c2e
Message:
Location:
router/java/src/net/i2p/router/client
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/client/ClientConnectionRunner.java

    r1ae0c2e r0d622660  
    376376        if (_dead) return;
    377377        MessageReceivedJob j = new MessageReceivedJob(_context, this, toDest, fromDest, payload);
    378         _context.jobQueue().addJob(j);//j.runJob();
     378        // This is fast and non-blocking, run in-line
     379        //_context.jobQueue().addJob(j);
     380        j.runJob();
    379381    }
    380382   
  • router/java/src/net/i2p/router/client/MessageReceivedJob.java

    r1ae0c2e r0d622660  
    2626    private final ClientConnectionRunner _runner;
    2727    private final Payload _payload;
     28
    2829    public MessageReceivedJob(RouterContext ctx, ClientConnectionRunner runner, Destination toDest, Destination fromDest, Payload payload) {
    2930        super(ctx);
     
    3435   
    3536    public String getName() { return "Deliver New Message"; }
     37
    3638    public void runJob() {
    3739        if (_runner.isDead()) return;
     
    4547     * Deliver notification to the client that the given message is available.
    4648     */
    47     public void messageAvailable(MessageId id, long size) {
     49    private void messageAvailable(MessageId id, long size) {
    4850        if (_log.shouldLog(Log.DEBUG))
    4951            _log.debug("Sending message available: " + id + " to sessionId " + _runner.getSessionId()
Note: See TracChangeset for help on using the changeset viewer.