Changeset d9775a5

Timestamp:

Jun 9, 2019 4:42:43 PM (12 months ago)

Author:

zzz <zzz@…>

Branches:

master

Children:

b0bca2f

Parents:

ea2ef7b

Message:

INMP refactor

File:

• router/java/src/net/i2p/router/InNetMessagePool.java (modified) (6 diffs)

router/java/src/net/i2p/router/InNetMessagePool.java

@@ -87 +87 @@
         _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 });
         _context.statManager().createRateStat("inNetPool.duplicate", "How often do we receive a duplicate message", "InNetPool", new long[] { 60*60*1000l });
-        //_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 });
         _context.statManager().createRateStat("inNetPool.droppedDbLookupResponseMessage", "How often we drop a slow-to-arrive db search response", "InNetPool", new long[] { 60*60*1000l });
     }
@@ -176 +175 @@
         boolean allowMatches = true;
         
-        if (type == TunnelGatewayMessage.MESSAGE_TYPE) {
+        switch (type) { 
+          case TunnelGatewayMessage.MESSAGE_TYPE:
             shortCircuitTunnelGateway(messageBody);
             allowMatches = false;
-        } else if (type == TunnelDataMessage.MESSAGE_TYPE) {
+            break;
+
+          case TunnelDataMessage.MESSAGE_TYPE:
             shortCircuitTunnelData(messageBody, fromRouterHash);
             allowMatches = false;
-        } else {
+            break;
+
+          default:
             // why don't we allow type 0? There used to be a message of type 0 long ago...
             if ( (type > 0) && (type < _handlerJobBuilders.length) ) {
@@ -204 +208 @@
                 }
             }
-        }
+            break;
+        } // switch
 
         if (allowMatches) {
@@ -214 +219 @@
                     // was not handled via HandlerJobBuilder
                     _context.messageHistory().droppedOtherMessage(messageBody, (fromRouter != null ? fromRouter.calculateHash() : fromRouterHash));
-                    if (type == DeliveryStatusMessage.MESSAGE_TYPE) {
+
+                    switch (type) { 
+                      case DeliveryStatusMessage.MESSAGE_TYPE:
                         // Avoid logging side effect from a horrible UDP EstablishmentManager hack
                         // We could set up a separate stat for it but don't bother for now
@@ -224 +231 @@
                             _context.statManager().addRateData("inNetPool.droppedDeliveryStatusDelay", timeSinceSent);
                         }
-                    //} else if (type == TunnelCreateStatusMessage.MESSAGE_TYPE) {
-                    //    if (_log.shouldLog(Log.INFO))
-                    //        _log.info("Dropping slow tunnel create request response: " + messageBody);
-                    //    _context.statManager().addRateData("inNetPool.droppedTunnelCreateStatusMessage", 1, 0);
-                    } else if (type == DatabaseSearchReplyMessage.MESSAGE_TYPE) {
+                        break;
+
+                      case DatabaseSearchReplyMessage.MESSAGE_TYPE:
                         if (_log.shouldLog(Log.INFO))
                             _log.info("Dropping slow db lookup response: " + messageBody);
                         _context.statManager().addRateData("inNetPool.droppedDbLookupResponseMessage", 1);
-                    } else if (type == DatabaseLookupMessage.MESSAGE_TYPE) {
+                        break;
+
+                      case DatabaseLookupMessage.MESSAGE_TYPE:
                         if (_log.shouldLog(Log.DEBUG))
                             _log.debug("Dropping netDb lookup due to throttling");
-                    } else {
+                        break;
+
+                      default:
                         if (_log.shouldLog(Log.WARN))
                             _log.warn("Message expiring on " 
@@ -242 +251 @@
                                       new Exception("f00!"));
                         _context.statManager().addRateData("inNetPool.dropped", 1);
-                    }
+                        break;
+                    }  // switch
                 } else {
                     String mtype = messageBody.getClass().getName();