Changeset d9775a5 for router


Ignore:
Timestamp:
Jun 9, 2019 4:42:43 PM (10 months ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
b0bca2f
Parents:
ea2ef7b
Message:

INMP refactor

File:
1 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/InNetMessagePool.java

    rea2ef7b rd9775a5  
    8787        _context.statManager().createRateStat("inNetPool.droppedDeliveryStatusDelay", "How long after a delivery status message is created do we receive it back again (for messages that are too slow to be handled)", "InNetPool", new long[] { 60*60*1000l });
    8888        _context.statManager().createRateStat("inNetPool.duplicate", "How often do we receive a duplicate message", "InNetPool", new long[] { 60*60*1000l });
    89         //_context.statManager().createRateStat("inNetPool.droppedTunnelCreateStatusMessage", "How often we drop a slow-to-arrive tunnel request response", "InNetPool", new long[] { 60*60*1000l, 24*60*60*1000l });
    9089        _context.statManager().createRateStat("inNetPool.droppedDbLookupResponseMessage", "How often we drop a slow-to-arrive db search response", "InNetPool", new long[] { 60*60*1000l });
    9190    }
     
    176175        boolean allowMatches = true;
    177176       
    178         if (type == TunnelGatewayMessage.MESSAGE_TYPE) {
     177        switch (type) {
     178          case TunnelGatewayMessage.MESSAGE_TYPE:
    179179            shortCircuitTunnelGateway(messageBody);
    180180            allowMatches = false;
    181         } else if (type == TunnelDataMessage.MESSAGE_TYPE) {
     181            break;
     182
     183          case TunnelDataMessage.MESSAGE_TYPE:
    182184            shortCircuitTunnelData(messageBody, fromRouterHash);
    183185            allowMatches = false;
    184         } else {
     186            break;
     187
     188          default:
    185189            // why don't we allow type 0? There used to be a message of type 0 long ago...
    186190            if ( (type > 0) && (type < _handlerJobBuilders.length) ) {
     
    204208                }
    205209            }
    206         }
     210            break;
     211        } // switch
    207212
    208213        if (allowMatches) {
     
    214219                    // was not handled via HandlerJobBuilder
    215220                    _context.messageHistory().droppedOtherMessage(messageBody, (fromRouter != null ? fromRouter.calculateHash() : fromRouterHash));
    216                     if (type == DeliveryStatusMessage.MESSAGE_TYPE) {
     221
     222                    switch (type) {
     223                      case DeliveryStatusMessage.MESSAGE_TYPE:
    217224                        // Avoid logging side effect from a horrible UDP EstablishmentManager hack
    218225                        // We could set up a separate stat for it but don't bother for now
     
    224231                            _context.statManager().addRateData("inNetPool.droppedDeliveryStatusDelay", timeSinceSent);
    225232                        }
    226                     //} else if (type == TunnelCreateStatusMessage.MESSAGE_TYPE) {
    227                     //    if (_log.shouldLog(Log.INFO))
    228                     //        _log.info("Dropping slow tunnel create request response: " + messageBody);
    229                     //    _context.statManager().addRateData("inNetPool.droppedTunnelCreateStatusMessage", 1, 0);
    230                     } else if (type == DatabaseSearchReplyMessage.MESSAGE_TYPE) {
     233                        break;
     234
     235                      case DatabaseSearchReplyMessage.MESSAGE_TYPE:
    231236                        if (_log.shouldLog(Log.INFO))
    232237                            _log.info("Dropping slow db lookup response: " + messageBody);
    233238                        _context.statManager().addRateData("inNetPool.droppedDbLookupResponseMessage", 1);
    234                     } else if (type == DatabaseLookupMessage.MESSAGE_TYPE) {
     239                        break;
     240
     241                      case DatabaseLookupMessage.MESSAGE_TYPE:
    235242                        if (_log.shouldLog(Log.DEBUG))
    236243                            _log.debug("Dropping netDb lookup due to throttling");
    237                     } else {
     244                        break;
     245
     246                      default:
    238247                        if (_log.shouldLog(Log.WARN))
    239248                            _log.warn("Message expiring on "
     
    242251                                      new Exception("f00!"));
    243252                        _context.statManager().addRateData("inNetPool.dropped", 1);
    244                     }
     253                        break;
     254                    }  // switch
    245255                } else {
    246256                    String mtype = messageBody.getClass().getName();
Note: See TracChangeset for help on using the changeset viewer.