Changeset c8c1090


Ignore:
Timestamp:
Sep 13, 2005 1:12:43 AM (15 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
9865af4
Parents:
b5784d6
git-author:
jrandom <jrandom> (09/13/05 01:12:43)
git-committer:
zzz <zzz@…> (09/13/05 01:12:43)
Message:

2005-09-12 jrandom

  • Bugfix for skewed store which could kill a UDP thread (causing complete comm failure and eventual OOM)
Files:
5 edited

Legend:

Unmodified
Added
Removed
  • history.txt

    rb5784d6 rc8c1090  
    1 $Id: history.txt,v 1.244 2005/09/10 22:22:52 jrandom Exp $
     1$Id: history.txt,v 1.245 2005/09/12 19:12:04 jrandom Exp $
     2
     32005-09-12  jrandom
     4    * Bugfix for skewed store which could kill a UDP thread (causing complete
     5      comm failure and eventual OOM)
    26
    372005-09-12  jrandom
  • router/java/src/net/i2p/router/RouterVersion.java

    rb5784d6 rc8c1090  
    1616 */
    1717public class RouterVersion {
    18     public final static String ID = "$Revision: 1.231 $ $Date: 2005/09/10 22:22:52 $";
     18    public final static String ID = "$Revision: 1.232 $ $Date: 2005/09/12 19:12:00 $";
    1919    public final static String VERSION = "0.6.0.5";
    20     public final static long BUILD = 6;
     20    public final static long BUILD = 7;
    2121    public static void main(String args[]) {
    2222        System.out.println("I2P Router version: " + VERSION + "-" + BUILD);
  • router/java/src/net/i2p/router/transport/TransportManager.java

    rb5784d6 rc8c1090  
    215215        if (_log.shouldLog(Log.DEBUG))
    216216            _log.debug("I2NPMessage received: " + message.getClass().getName(), new Exception("Where did I come from again?"));
    217         int num = _context.inNetMessagePool().add(message, fromRouter, fromRouterHash);
    218         if (_log.shouldLog(Log.DEBUG))
    219             _log.debug("Added to in pool: "+ num);
     217        try {
     218            int num = _context.inNetMessagePool().add(message, fromRouter, fromRouterHash);
     219            if (_log.shouldLog(Log.DEBUG))
     220                _log.debug("Added to in pool: "+ num);
     221        } catch (IllegalArgumentException iae) {
     222            if (_log.shouldLog(Log.WARN))
     223                _log.warn("Error receiving message", iae);
     224        }
    220225    }
    221226   
  • router/java/src/net/i2p/router/transport/udp/UDPAddress.java

    rb5784d6 rc8c1090  
    4343    public String toString() {
    4444        StringBuffer rv = new StringBuffer(64);
    45         rv.append("[SSU ");
    46         if (_host != null)
    47             rv.append("host: ").append(_host).append(' ');
    48         if (_port > 0)
    49             rv.append("port: ").append(_port).append(' ');
    50         if (_introKey != null)
    51             rv.append("key: ").append(Base64.encode(_introKey)).append(' ');
    5245        if (_introHosts != null) {
    5346            for (int i = 0; i < _introHosts.length; i++) {
    54                 rv.append("intro[" + i + "]: ").append(_introHosts[i]);
    55                 rv.append(':').append(_introPorts[i]);
    56                 rv.append('/').append(Base64.encode(_introKeys[i])).append(' ');
     47                rv.append("ssu://");
     48                rv.append(_introTags[i]).append('@');
     49                rv.append(_introHosts[i]).append(':').append(_introPorts[i]);
     50                //rv.append('/').append(Base64.encode(_introKeys[i]));
     51                if (i + 1 < _introKeys.length)
     52                    rv.append(", ");
    5753            }
    58         }   
     54        } else {
     55            if ( (_host != null) && (_port > 0) )
     56                rv.append("ssu://").append(_host).append(':').append(_port);//.append('/').append(Base64.encode(_introKey));
     57            else
     58                rv.append("ssu://autodetect.not.yet.complete:").append(_port);
     59        }
    5960        return rv.toString();
    6061    }
  • router/java/src/net/i2p/router/tunnel/InboundMessageDistributor.java

    rb5784d6 rc8c1090  
    115115                        // unnecessarily
    116116                        DatabaseStoreMessage dsm = (DatabaseStoreMessage)data;
    117                         if (dsm.getValueType() == DatabaseStoreMessage.KEY_TYPE_LEASESET)
    118                             _context.netDb().store(dsm.getKey(), dsm.getLeaseSet());
    119                         else
    120                             _context.netDb().store(dsm.getKey(), dsm.getRouterInfo());
     117                        try {
     118                            if (dsm.getValueType() == DatabaseStoreMessage.KEY_TYPE_LEASESET)
     119                                _context.netDb().store(dsm.getKey(), dsm.getLeaseSet());
     120                            else
     121                                _context.netDb().store(dsm.getKey(), dsm.getRouterInfo());
     122                        } catch (IllegalArgumentException iae) {
     123                            if (_log.shouldLog(Log.WARN))
     124                                _log.warn("Bad store attempt", iae);
     125                        }
    121126                    } else {
    122127                        _context.inNetMessagePool().add(data, null, null);
Note: See TracChangeset for help on using the changeset viewer.