Changeset 825af3e

Timestamp:

Sep 12, 2008 1:37:22 PM (12 years ago)

Author:

zzz <zzz@…>

Branches:

master

Children:

e734a558

Parents:

cf54dd1

Message:

• HarvesterJob?: Don't instantiate if disabled
• NetDb?: Add netDb.exploreKeySet stat
• netdb.jsp: Add parameter ?r=xxxxxx to view a single routerinfo, and ?r=. to view our own; change links on other pages too

Files:

• apps/routerconsole/java/src/net/i2p/router/web/NetDbHelper.java (modified) (2 diffs)
• apps/routerconsole/jsp/netdb.jsp (modified) (1 diff)
• apps/routerconsole/jsp/summary.jsp (modified) (1 diff)
• history.txt (modified) (1 diff)
• router/java/src/net/i2p/router/NetworkDatabaseFacade.java (modified) (1 diff)
• router/java/src/net/i2p/router/RouterVersion.java (modified) (1 diff)
• router/java/src/net/i2p/router/Shitlist.java (modified) (1 diff)
• router/java/src/net/i2p/router/networkdb/kademlia/HarvesterJob.java (modified) (1 diff)
• router/java/src/net/i2p/router/networkdb/kademlia/KademliaNetworkDatabaseFacade.java (modified) (5 diffs)
• router/java/src/net/i2p/router/peermanager/ProfileOrganizerRenderer.java (modified) (1 diff)
• router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java (modified) (1 diff)
• router/java/src/net/i2p/router/transport/udp/UDPTransport.java (modified) (1 diff)

apps/routerconsole/java/src/net/i2p/router/web/NetDbHelper.java

@@ -11 +11 @@
     private RouterContext _context;
     private Writer _out;
+    private String _routerPrefix;
+
     /**
      * Configure this bean to query a particular router context
@@ -28 +30 @@
     
     public void setWriter(Writer writer) { _out = writer; }
+    public void setRouter(String r) { _routerPrefix = r; }
     
     public String getNetDbSummary() {
         try {
             if (_out != null) {
-                _context.netDb().renderStatusHTML(_out);
+                if (_routerPrefix != null)
+                    _context.netDb().renderRouterInfoHTML(_out, _routerPrefix);
+                else
+                    _context.netDb().renderStatusHTML(_out);
                 return "";
             } else {
                 ByteArrayOutputStream baos = new ByteArrayOutputStream(32*1024);
-                _context.netDb().renderStatusHTML(new OutputStreamWriter(baos));
+                if (_routerPrefix != null)
+                    _context.netDb().renderRouterInfoHTML(new OutputStreamWriter(baos), _routerPrefix);
+                else
+                    _context.netDb().renderStatusHTML(new OutputStreamWriter(baos));
                 return new String(baos.toByteArray());
             }

apps/routerconsole/jsp/netdb.jsp

@@ -15 +15 @@
  <jsp:setProperty name="netdbHelper" property="contextId" value="<%=(String)session.getAttribute("i2p.contextId")%>" />
  <jsp:setProperty name="netdbHelper" property="writer" value="<%=out%>" />
+ <jsp:setProperty name="netdbHelper" property="router" value="<%=request.getParameter("r")%>" />
  <jsp:getProperty name="netdbHelper" property="netDbSummary" />
 </div>

apps/routerconsole/jsp/summary.jsp

@@ -11 +11 @@
 <div class="routersummary">
  <u><b>General</b></u><br />
- <b>Ident:</b> (<a title="Your router identity is <jsp:getProperty name="helper" property="ident" />, never reveal it to anyone" href="netdb.jsp#our-info">view</a>)<br />
+ <b>Ident:</b> (<a title="Your router identity is <jsp:getProperty name="helper" property="ident" />, never reveal it to anyone" href="netdb.jsp?r=.">view</a>)<br />
  <b>Version:</b> <jsp:getProperty name="helper" property="version" /><br />
  <b>Uptime:</b> <jsp:getProperty name="helper" property="uptime" /><br />

history.txt

@@ +1 @@
+2008-09-11 zzz
+    * Blocklist: Fix a log message format
+    * HarvesterJob: Don't instantiate if disabled
+    * i2psnark:
+      - Add config i2psnark.linkPrefix to enable access to completed
+        torrents from a different machine - examples:
+           i2psnark.linkPrefix=file://///localserver/path/to/files/
+           i2psnark.linkPrefix=http://localwebserver/path/
+        (Stop i2psnark, add to i2psnark.config, restart)
+      - Remove Galen and NickyB trackers
+    * NetDb: Add netDb.exploreKeySet stat
+    * netdb.jsp: Add parameter ?r=xxxxxx to view a single routerinfo,
+      and ?r=. to view our own; change links on other pages too
+    * Transport: Make 0.0.0.0/8 and 169.254.0.0/16 private
+
 2008-09-06 zzz
     * EepGet command line: Fix byte counts after a failed resume

router/java/src/net/i2p/router/NetworkDatabaseFacade.java

@@ -62 +62 @@
     public int getKnownRouters() { return 0; }
     public int getKnownLeaseSets() { return 0; }
+    public void renderRouterInfoHTML(Writer out, String s) throws IOException {}
 }
 

router/java/src/net/i2p/router/RouterVersion.java

@@ -18 +18 @@
     public final static String ID = "$Revision: 1.548 $ $Date: 2008-06-07 23:00:00 $";
     public final static String VERSION = "0.6.3";
-    public final static long BUILD = 3;
+    public final static long BUILD = 4;
     public static void main(String args[]) {
         System.out.println("I2P Router version: " + VERSION + "-" + BUILD);

router/java/src/net/i2p/router/Shitlist.java

@@ -281 +281 @@
             Entry entry = (Entry)entries.get(key);
             buf.append("<li><b>").append(key.toBase64()).append("</b>");
-            buf.append(" (<a href=\"netdb.jsp#").append(key.toBase64().substring(0, 6)).append("\">netdb</a>)");
+            buf.append(" (<a href=\"netdb.jsp?r=").append(key.toBase64().substring(0, 6)).append("\">netdb</a>)");
             buf.append(" expiring in ");
             buf.append(DataHelper.formatDuration(entry.expireOn-_context.clock().now()));

router/java/src/net/i2p/router/networkdb/kademlia/HarvesterJob.java

@@ -42 +42 @@
     private static final int PRIORITY = 100;
     
-    private static final String PROP_ENABLED = "netDb.shouldHarvest";
+    public static final String PROP_ENABLED = "netDb.shouldHarvest";
 
     private boolean harvestDirectly() { 

router/java/src/net/i2p/router/networkdb/kademlia/KademliaNetworkDatabaseFacade.java

@@ -131 +131 @@
         _enforceNetId = DEFAULT_ENFORCE_NETID;
         context.statManager().createRateStat("netDb.lookupLeaseSetDeferred", "how many lookups are deferred for a single leaseSet lookup?", "NetworkDatabase", new long[] { 60*1000, 5*60*1000 });
+        context.statManager().createRateStat("netDb.exploreKeySet", "how many keys are queued for exploration?", "NetworkDatabase", new long[] { 10*60*1000 });
     }
     
@@ -204 +205 @@
         synchronized (_exploreKeys) {
             _exploreKeys.removeAll(toRemove);
+            _context.statManager().addRateData("netDb.exploreKeySet", _exploreKeys.size(), 0);
         }
     }
@@ -210 +212 @@
         synchronized (_exploreKeys) {
             _exploreKeys.addAll(keys);
+            _context.statManager().addRateData("netDb.exploreKeySet", _exploreKeys.size(), 0);
         }
     }
@@ -298 +301 @@
             _context.jobQueue().addJob(_exploreJob);
             // if configured to do so, periodically try to get newer routerInfo stats
-            if (_harvestJob == null)
+            if (_harvestJob == null && "true".equals(_context.getProperty(HarvesterJob.PROP_ENABLED)))
                 _harvestJob = new HarvesterJob(_context, this);
             _context.jobQueue().addJob(_harvestJob);
@@ -944 +947 @@
     }
 
+    public void renderRouterInfoHTML(Writer out, String routerPrefix) throws IOException {
+        StringBuffer buf = new StringBuffer(4*1024);
+        buf.append("<h2>Network Database RouterInfo Lookup</h2>\n");
+        if (".".equals(routerPrefix)) {
+            renderRouterInfo(buf, _context.router().getRouterInfo(), true);
+        } else {
+            boolean notFound = true;
+            Set routers = getRouters();
+            for (Iterator iter = routers.iterator(); iter.hasNext(); ) {
+                RouterInfo ri = (RouterInfo)iter.next();
+                Hash key = ri.getIdentity().getHash();
+                if (key.toBase64().startsWith(routerPrefix)) {
+                    renderRouterInfo(buf, ri, false);
+                    notFound = false;
+                }
+            }
+            if (notFound)
+                buf.append("Router ").append(routerPrefix).append(" not found in network database");
+        }
+        out.write(buf.toString());
+        out.flush();
+    }
+
     public void renderStatusHTML(Writer out) throws IOException {
-        StringBuffer buf = new StringBuffer(10*1024);
-        buf.append("<h2>Kademlia Network DB Contents</h2>\n");
+        StringBuffer buf = new StringBuffer(getKnownRouters() * 2048);
+        buf.append("<h2>Network Database Contents</h2>\n");
         if (!_initialized) {
             buf.append("<i>Not initialized</i>\n");

router/java/src/net/i2p/router/peermanager/ProfileOrganizerRenderer.java

@@ -164 +164 @@
             //buf.append("<td><a href=\"/profile/").append(prof.getPeer().toBase64().substring(0, 32)).append("\">profile.txt</a> ");
             //buf.append("    <a href=\"#").append(prof.getPeer().toBase64().substring(0, 32)).append("\">netDb</a></td>");
-            buf.append("<td nowrap><a href=\"netdb.jsp#").append(peer.toBase64().substring(0,6)).append("\">netDb</a>");
+            buf.append("<td nowrap><a href=\"netdb.jsp?r=").append(peer.toBase64().substring(0,6)).append("\">netDb</a>");
             buf.append("/<a href=\"dumpprofile.jsp?peer=").append(peer.toBase64().substring(0,6)).append("\">profile</a>");
             buf.append("/<a href=\"configpeer.jsp?peer=").append(peer.toBase64()).append("\">+-</a></td>\n");

router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java

@@ -601 +601 @@
             NTCPConnection con = (NTCPConnection)iter.next();
             String name = con.getRemotePeer().calculateHash().toBase64().substring(0,6);
-            buf.append("<tr><td><code><a href=\"netdb.jsp#").append(name).append("\">").append(name);
+            buf.append("<tr><td><code><a href=\"netdb.jsp?r=").append(name).append("\">").append(name);
             buf.append("</code></td><td align=\"center\"><code>");
             if (con.isInbound())

router/java/src/net/i2p/router/transport/udp/UDPTransport.java

@@ -1688 +1688 @@
             String name = peer.getRemotePeer().toBase64().substring(0,6);
             buf.append("<td valign=\"top\" nowrap=\"nowrap\"><code>");
-            buf.append("<a href=\"netdb.jsp#");
+            buf.append("<a href=\"netdb.jsp?r=");
             buf.append(name);
             buf.append("\">");