ConnectionsToadlet.java
| Index Score | ||
|---|---|---|
 |
 |
freenet.clients.http |
 |
 |
Freenet |
View: Reasons, Metrics, Source Code
These are the metrics that contribute to the Enerjy Score for this file, ranked by impact. So the metrics listed at the top influence the score to a greater extent that the metrics listed at the bottom.
| Metric | Description | |
|---|---|---|
| JAVA0144 | JAVA0144 Line exceeds maximum M characters |  |
| OPERANDS | Number of operands | |
| EXITS | Procedure exits | |
| PROGRAM_LENGTH | Halstead program length | |
| OPERATORS | Number of operators | |
| UNIQUE_OPERANDS | Number of unique operands | |
| COMPARISONS | Number of comparison operators | |
| JAVA0034 | JAVA0034 Missing braces in if statement | |
| PROGRAM_VOCAB | Halstead program vocabulary | |
| EXEC_COMMENTS | Comments in executable code | |
| SIZE | Size of the file in bytes | |
| LOGICAL_LINES | Number of statements | |
| ELOC | Effective lines of code | |
| CYCLOMATIC | Cyclomatic complexity | |
| JAVA0076 | JAVA0076 Use of magic number | |
| LOC | Lines of code | |
| INTERFACE_COMPLEXITY | Interface complexity | |
| JAVA0108 | JAVA0108 Incorrect javadoc: no @param tag for 'parameter' | |
| PARAMS | Number of formal parameter declarations | |
| LINE_COMMENT | Number of line comments | |
| BLOCKS | Number of blocks | |
| RETURNS | Number of return points from functions | |
| JAVA0068 | JAVA0068 Modifiers not declared in recommended order | |
| LINES | Number of lines in the source file | |
| JAVA0173 | JAVA0173 Unused method parameter | |
| JAVA0145 | JAVA0145 Tab character used in source file | |
| JAVA0110 | JAVA0110 Incorrect javadoc: no @return tag | |
| JAVA0117 | JAVA0117 Missing javadoc: method 'method' | |
| JAVA0177 | JAVA0177 Variable declaration missing initializer | |
| FUNCTIONS | Number of function declarations | |
| JAVA0254 | JAVA0254 Use enhanced for loop construct instead of Iterator | |
| JAVA0270 | JAVA0270 Use Java 5.0 enhanced for loop construct to iterate over all elements in an array | |
| JAVA0130 | JAVA0130 Non-static method does not use instance fields | |
| LOOPS | Number of loops | |
| UNIQUE_OPERATORS | Number of unique operators | |
| JAVA0170 | JAVA0170 Caught exception not derived from java.lang.Exception | |
| JAVA0166 | JAVA0166 Generic exception caught | |
| NEST_DEPTH | Maximum nesting depth | |
| PROGRAM_VOLUME | Halstead program volume | |
| JAVA0136 | JAVA0136 N methods defined in class (maximum: M) | |
| JAVA0126 | JAVA0126 Method declares unchecked exception in throws | |
| JAVA0179 | JAVA0179 Local variable hides visible field | |
| JAVA0043 | JAVA0043 Inner class does not use outer class | |
| JAVA0264 | JAVA0264 Integer math in long context - check for overflow | |
| DOC_COMMENT | Number of javadoc comment lines | |
| JAVA0075 | JAVA0075 Method parameter hides field | |
package freenet.clients.http;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.StringWriter;
import java.net.URI;
import java.net.URL;
import java.net.URLConnection;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import freenet.client.HighLevelSimpleClient;
import freenet.io.comm.PeerParseException;
import freenet.io.comm.ReferenceSignatureVerificationException;
import freenet.io.xfer.PacketThrottle;
import freenet.l10n.L10n;
import freenet.node.DarknetPeerNode;
import freenet.node.FSParseException;
import freenet.node.Node;
import freenet.node.NodeClientCore;
import freenet.node.NodeStats;
import freenet.node.PeerManager;
import freenet.node.PeerNode;
import freenet.node.PeerNodeStatus;
import freenet.node.Version;
import freenet.support.HTMLNode;
import freenet.support.Logger;
import freenet.support.MultiValueTable;
import freenet.support.SimpleFieldSet;
import freenet.support.SizeUtil;
import freenet.support.TimeUtil;
import freenet.support.api.HTTPRequest;
public abstract class ConnectionsToadlet extends Toadlet {
protected class ComparatorByStatus implements Comparator {
protected final String sortBy;
protected final boolean reversed;
ComparatorByStatus(String sortBy, boolean reversed) {
this.sortBy = sortBy;
this.reversed = reversed;
}
public int compare(Object first, Object second) {
int result = 0;
boolean isSet = true;
PeerNodeStatus firstNode = (PeerNodeStatus) first;
PeerNodeStatus secondNode = (PeerNodeStatus) second;
if(sortBy != null){
result = customCompare(firstNode, secondNode, sortBy);
isSet = (result != 0);
}else
isSet=false;
if(!isSet){
int statusDifference = firstNode.getStatusValue() - secondNode.getStatusValue();
if (statusDifference != 0)
result = (statusDifference < 0 ? -1 : 1);
else
result = lastResortCompare(firstNode, secondNode);
}
if(result == 0){
return 0;
}else if(reversed){
isReversed = true;
return result > 0 ? -1 : 1;
}else{
isReversed = false;
return result < 0 ? -1 : 1;
}
}
// TODO: use Long.valueOf().compare when we switch to 1.5
private int compareLongs(long long1, long long2) {
long diff = long1 - long2;
if(diff == 0)
return 0;
else
return (diff > 0 ? 1 : -1);
}
private int compareInts(int int1, int int2) {
int diff = int1 -int2;
if(diff == 0)
return 0;
else
return (diff > 0 ? 1 : -1);
}
protected int customCompare(PeerNodeStatus firstNode, PeerNodeStatus secondNode, String sortBy2) {
if(sortBy.equals("address")){
return firstNode.getPeerAddress().compareToIgnoreCase(secondNode.getPeerAddress());
}else if(sortBy.equals("location")){
return compareLocations(firstNode, secondNode);
}else if(sortBy.equals("version")){
return Version.getArbitraryBuildNumber(firstNode.getVersion(), -1) - Version.getArbitraryBuildNumber(secondNode.getVersion(), -1);
}else if(sortBy.equals("backoff")){
return Double.compare(firstNode.getBackedOffPercent(), secondNode.getBackedOffPercent());
}else if(sortBy.equals(("overload_p"))){
return Double.compare(firstNode.getPReject(), secondNode.getPReject());
}else if(sortBy.equals(("idle"))){
return compareLongs(firstNode.getTimeLastConnectionCompleted(), secondNode.getTimeLastConnectionCompleted());
}else if(sortBy.equals("time_routable")){
return Double.compare(firstNode.getPercentTimeRoutableConnection(), secondNode.getPercentTimeRoutableConnection());
}else if(sortBy.equals("total_traffic")){
long total1 = firstNode.getTotalInputBytes()+firstNode.getTotalOutputBytes();
long total2 = secondNode.getTotalInputBytes()+secondNode.getTotalOutputBytes();
return compareLongs(total1, total2);
}else if(sortBy.equals("selection_percentage")){
long sinceWhen = System.currentTimeMillis() - PeerNode.SELECTION_SAMPLING_PERIOD;
return compareInts(firstNode.getNumberOfSelections().headSet(sinceWhen).size(), secondNode.getNumberOfSelections().headSet(sinceWhen).size());
}else if(sortBy.equals("time_delta")){
return compareLongs(firstNode.getClockDelta(), secondNode.getClockDelta());
}else if(sortBy.equals(("uptime"))){
return compareInts(firstNode.getReportedUptimePercentage(), secondNode.getReportedUptimePercentage());
}else
return 0;
}
private int compareLocations(PeerNodeStatus firstNode, PeerNodeStatus secondNode) {
double diff = firstNode.getLocation() - secondNode.getLocation(); // Can occasionally be the same, and we must have a consistent sort order
if(Double.MIN_VALUE*2 > Math.abs(diff)) return 0;
return diff > 0 ? 1 : -1;
}
/** Default comparison, after taking into account status */
protected int lastResortCompare(PeerNodeStatus firstNode, PeerNodeStatus secondNode) {
return compareLocations(firstNode, secondNode);
}
}
protected final Node node;
protected final NodeClientCore core;
protected final NodeStats stats;
protected final PeerManager peers;
protected boolean isReversed = false;
protected final DecimalFormat fix1 = new DecimalFormat("##0.0%");
public String supportedMethods() {
if(this.acceptRefPosts())
return "GET, POST";
else
return "GET";
}
protected ConnectionsToadlet(Node n, NodeClientCore core, HighLevelSimpleClient client) {
super(client);
this.node = n;
this.core = core;
this.stats = n.nodeStats;
this.peers = n.peers;
}
abstract SimpleColumn[] endColumnHeaders(boolean advancedModeEnabled);
abstract class SimpleColumn {
abstract protected void drawColumn(HTMLNode peerRow, PeerNodeStatus peerNodeStatus);
abstract public String getSortString();
abstract public String getTitleKey();
abstract public String getExplanationKey();
}
public void handleGet(URI uri, final HTTPRequest request, ToadletContext ctx) throws ToadletContextClosedException, IOException, RedirectException {
String path = uri.getPath();
if(path.endsWith("myref.fref")) {
SimpleFieldSet fs = getNoderef();
StringWriter sw = new StringWriter();
fs.writeTo(sw);
MultiValueTable extraHeaders = new MultiValueTable();
// Force download to disk
extraHeaders.put("Content-Disposition", "attachment; filename=myref.fref");
this.writeReply(ctx, 200, "application/x-freenet-reference", "OK", extraHeaders, sw.toString());
return;
}
if(path.endsWith("myref.txt")) {
SimpleFieldSet fs = getNoderef();
StringWriter sw = new StringWriter();
fs.writeTo(sw);
this.writeTextReply(ctx, 200, "OK", sw.toString());
return;
}
if(!ctx.isAllowedFullAccess()) {
super.sendErrorPage(ctx, 403, L10n.getString("Toadlet.unauthorizedTitle"), L10n.getString("Toadlet.unauthorized"));
return;
}
final boolean fProxyJavascriptEnabled = node.isFProxyJavascriptEnabled();
boolean drawMessageTypes = path.endsWith("displaymessagetypes.html");
/* gather connection statistics */
PeerNodeStatus[] peerNodeStatuses = getPeerNodeStatuses(!drawMessageTypes);
Arrays.sort(peerNodeStatuses, comparator(request.getParam("sortBy", null), request.isParameterSet("reversed")));
int numberOfConnected = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_CONNECTED);
int numberOfRoutingBackedOff = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_ROUTING_BACKED_OFF);
int numberOfTooNew = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_TOO_NEW);
int numberOfTooOld = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_TOO_OLD);
int numberOfDisconnected = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_DISCONNECTED);
int numberOfNeverConnected = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_NEVER_CONNECTED);
int numberOfDisabled = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_DISABLED);
int numberOfBursting = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_BURSTING);
int numberOfListening = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_LISTENING);
int numberOfListenOnly = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_LISTEN_ONLY);
int numberOfClockProblem = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_CLOCK_PROBLEM);
int numberOfConnError = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_CONN_ERROR);
int numberOfDisconnecting = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_DISCONNECTING);
int numberOfRoutingDisabled = PeerNodeStatus.getPeerStatusCount(peerNodeStatuses, PeerManager.PEER_NODE_STATUS_ROUTING_DISABLED);
int numberOfSimpleConnected = numberOfConnected + numberOfRoutingBackedOff;
int numberOfNotConnected = numberOfTooNew + numberOfTooOld + numberOfDisconnected + numberOfNeverConnected + numberOfDisabled + numberOfBursting + numberOfListening + numberOfListenOnly + numberOfClockProblem + numberOfConnError;
String titleCountString = null;
if(node.isAdvancedModeEnabled()) {
titleCountString = "(" + numberOfConnected + '/' + numberOfRoutingBackedOff + '/' + numberOfTooNew + '/' + numberOfTooOld + '/' + numberOfRoutingDisabled + '/' + numberOfNotConnected + ')';
} else {
titleCountString = (numberOfNotConnected + numberOfSimpleConnected)>0 ? String.valueOf(numberOfSimpleConnected) : "";
}
HTMLNode pageNode = ctx.getPageMaker().getPageNode(getPageTitle(titleCountString, node.getMyName()), ctx);
HTMLNode contentNode = ctx.getPageMaker().getContentNode(pageNode);
// FIXME! We need some nice images
long now = System.currentTimeMillis();
if(ctx.isAllowedFullAccess())
contentNode.addChild(core.alerts.createSummary());
final int mode = ctx.getPageMaker().drawModeSelectionArray(core, request, contentNode);
if(peerNodeStatuses.length>0){
/* node status values */
long nodeUptimeSeconds = (now - node.startupTime) / 1000;
int bwlimitDelayTime = (int) stats.getBwlimitDelayTime();
int nodeAveragePingTime = (int) stats.getNodeAveragePingTime();
int networkSizeEstimateSession = stats.getNetworkSizeEstimate(-1);
int networkSizeEstimateRecent = 0;
if(nodeUptimeSeconds > (48*60*60)) { // 48 hours
networkSizeEstimateRecent = stats.getNetworkSizeEstimate(now - (48*60*60*1000)); // 48 hours
}
DecimalFormat fix4 = new DecimalFormat("0.0000");
double routingMissDistance = stats.routingMissDistance.currentValue();
double backedOffPercent = stats.backedOffPercent.currentValue();
String nodeUptimeString = TimeUtil.formatTime(nodeUptimeSeconds * 1000); // *1000 to convert to milliseconds
// BEGIN OVERVIEW TABLE
HTMLNode overviewTable = contentNode.addChild("table", "class", "column");
HTMLNode overviewTableRow = overviewTable.addChild("tr");
HTMLNode nextTableCell = overviewTableRow.addChild("td", "class", "first");
/* node status overview box */
if(mode >= PageMaker.MODE_ADVANCED) {
HTMLNode overviewInfobox = nextTableCell.addChild("div", "class", "infobox");
overviewInfobox.addChild("div", "class", "infobox-header", "Node status overview");
HTMLNode overviewInfoboxContent = overviewInfobox.addChild("div", "class", "infobox-content");
HTMLNode overviewList = overviewInfoboxContent.addChild("ul");
overviewList.addChild("li", "bwlimitDelayTime:\u00a0" + bwlimitDelayTime + "ms");
overviewList.addChild("li", "nodeAveragePingTime:\u00a0" + nodeAveragePingTime + "ms");
overviewList.addChild("li", "networkSizeEstimateSession:\u00a0" + networkSizeEstimateSession + "\u00a0nodes");
if(nodeUptimeSeconds > (48*60*60)) { // 48 hours
overviewList.addChild("li", "networkSizeEstimateRecent:\u00a0" + networkSizeEstimateRecent + "\u00a0nodes");
}
overviewList.addChild("li", "nodeUptime:\u00a0" + nodeUptimeString);
overviewList.addChild("li", "routingMissDistance:\u00a0" + fix4.format(routingMissDistance));
overviewList.addChild("li", "backedOffPercent:\u00a0" + fix1.format(backedOffPercent));
overviewList.addChild("li", "pInstantReject:\u00a0" + fix1.format(stats.pRejectIncomingInstantly()));
nextTableCell = overviewTableRow.addChild("td");
}
// Activity box
int numARKFetchers = node.getNumARKFetchers();
HTMLNode activityInfobox = nextTableCell.addChild("div", "class", "infobox");
activityInfobox.addChild("div", "class", "infobox-header", l10n("activityTitle"));
HTMLNode activityInfoboxContent = activityInfobox.addChild("div", "class", "infobox-content");
HTMLNode activityList = StatisticsToadlet.drawActivity(activityInfoboxContent, node);
if ((mode >= PageMaker.MODE_ADVANCED) && (activityList != null)) {
if (numARKFetchers > 0) {
activityList.addChild("li", "ARK\u00a0Fetch\u00a0Requests:\u00a0" + numARKFetchers);
}
StatisticsToadlet.drawBandwidth(activityList, node, nodeUptimeSeconds, mode >= PageMaker.MODE_ADVANCED);
}
nextTableCell = (mode >= PageMaker.MODE_ADVANCED) ? overviewTableRow.addChild("td") : overviewTableRow.addChild("td", "class", "last");
// Peer statistics box
HTMLNode peerStatsInfobox = nextTableCell.addChild("div", "class", "infobox");
StatisticsToadlet.drawPeerStatsBox(peerStatsInfobox, mode >= PageMaker.MODE_ADVANCED, numberOfConnected, numberOfRoutingBackedOff, numberOfTooNew, numberOfTooOld, numberOfDisconnected, numberOfNeverConnected, numberOfDisabled, numberOfBursting, numberOfListening, numberOfListenOnly, 0, 0, numberOfRoutingDisabled, numberOfClockProblem, numberOfConnError, numberOfDisconnecting);
// Peer routing backoff reason box
if(mode >= PageMaker.MODE_ADVANCED) {
nextTableCell = overviewTableRow.addChild("td", "class", "last");
HTMLNode backoffReasonInfobox = nextTableCell.addChild("div", "class", "infobox");
backoffReasonInfobox.addChild("div", "class", "infobox-header", "Peer backoff reasons");
HTMLNode backoffReasonContent = backoffReasonInfobox.addChild("div", "class", "infobox-content");
String [] routingBackoffReasons = peers.getPeerNodeRoutingBackoffReasons();
if(routingBackoffReasons.length == 0) {
backoffReasonContent.addChild("#", "Good, your node is not backed off from any peers!");
} else {
HTMLNode reasonList = backoffReasonContent.addChild("ul");
for(int i=0;i<routingBackoffReasons.length;i++) {
int reasonCount = peers.getPeerNodeRoutingBackoffReasonSize(routingBackoffReasons[i]);
if(reasonCount > 0) {
reasonList.addChild("li", routingBackoffReasons[i] + '\u00a0' + reasonCount);
}
}
}
}
// END OVERVIEW TABLE
boolean enablePeerActions = showPeerActionsBox();
// BEGIN PEER TABLE
if(fProxyJavascriptEnabled) {
StringBuffer jsBuf = new StringBuffer();
// FIXME: There's probably some icky Javascript in here (this is the first thing that worked for me); feel free to fix up to Javascript guru standards
jsBuf.append( " function peerNoteChange() {\n" );
jsBuf.append( " var theobj = document.getElementById( \"action\" );\n" );
jsBuf.append( " var length = theobj.options.length;\n" );
jsBuf.append( " for (var i = 0; i < length; i++) {\n" );
jsBuf.append( " if(theobj.options[i] == \"update_notes\") {\n" );
jsBuf.append( " theobj.options[i].select = true;\n" );
jsBuf.append( " } else {\n" );
jsBuf.append( " theobj.options[i].select = false;\n" );
jsBuf.append( " }\n" );
jsBuf.append( " }\n" );
jsBuf.append( " theobj.value=\"update_notes\";\n" );
//jsBuf.append( " document.getElementById( \"peersForm\" ).submit();\n" );
jsBuf.append( " document.getElementById( \"peersForm\" ).doAction.click();\n" );
jsBuf.append( " }\n" );
jsBuf.append( " function peerNoteBlur() {\n" );
jsBuf.append( " var theobj = document.getElementById( \"action\" );\n" );
jsBuf.append( " var length = theobj.options.length;\n" );
jsBuf.append( " for (var i = 0; i < length; i++) {\n" );
jsBuf.append( " if(theobj.options[i] == \"update_notes\") {\n" );
jsBuf.append( " theobj.options[i].select = true;\n" );
jsBuf.append( " } else {\n" );
jsBuf.append( " theobj.options[i].select = false;\n" );
jsBuf.append( " }\n" );
jsBuf.append( " }\n" );
jsBuf.append( " theobj.value=\"update_notes\";\n" );
jsBuf.append( " }\n" );
contentNode.addChild("script", "type", "text/javascript").addChild("%", jsBuf.toString());
}
HTMLNode peerTableInfobox = contentNode.addChild("div", "class", "infobox infobox-normal");
HTMLNode peerTableInfoboxHeader = peerTableInfobox.addChild("div", "class", "infobox-header");
peerTableInfoboxHeader.addChild("#", getPeerListTitle());
if (mode >= PageMaker.MODE_ADVANCED) {
if (!path.endsWith("displaymessagetypes.html")) {
peerTableInfoboxHeader.addChild("#", " ");
peerTableInfoboxHeader.addChild("a", "href", "displaymessagetypes.html", "(more detailed)");
}
}
HTMLNode peerTableInfoboxContent = peerTableInfobox.addChild("div", "class", "infobox-content");
if (peerNodeStatuses.length == 0) {
L10n.addL10nSubstitution(peerTableInfoboxContent, "DarknetConnectionsToadlet.noPeersWithHomepageLink",
new String[] { "link", "/link" }, new String[] { "<a href=\"/\">", "</a>" });
} else {
HTMLNode peerForm = null;
HTMLNode peerTable;
if(enablePeerActions) {
peerForm = ctx.addFormChild(peerTableInfoboxContent, ".", "peersForm");
peerTable = peerForm.addChild("table", "class", "darknet_connections");
} else {
peerTable = peerTableInfoboxContent.addChild("table", "class", "darknet_connections");
}
HTMLNode peerTableHeaderRow = peerTable.addChild("tr");
if(enablePeerActions)
peerTableHeaderRow.addChild("th");
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "status")).addChild("#", l10n("statusTitle"));
if(hasNameColumn())
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "name")).addChild("span", new String[] { "title", "style" }, new String[] { l10n("nameClickToMessage"), "border-bottom: 1px dotted; cursor: help;" }, l10n("nameTitle"));
if (mode >= PageMaker.MODE_ADVANCED) {
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "address")).addChild("span", new String[] { "title", "style" }, new String[] { l10n("ipAddress"), "border-bottom: 1px dotted; cursor: help;" }, l10n("ipAddressTitle"));
}
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "version")).addChild("#", l10n("versionTitle"));
if (mode >= PageMaker.MODE_ADVANCED) {
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "location")).addChild("#", "Location");
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "backoff")).addChild("span", new String[] { "title", "style" }, new String[] { "Other node busy? Display: Percentage of time the node is overloaded, Current wait time remaining (0=not overloaded)/total/last overload reason", "border-bottom: 1px dotted; cursor: help;" }, "Backoff");
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "overload_p")).addChild("span", new String[] { "title", "style" }, new String[] { "Probability of the node rejecting a request due to overload or causing a timeout.", "border-bottom: 1px dotted; cursor: help;" }, "Overload Probability");
}
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "idle")).addChild("span", new String[] { "title", "style" }, new String[] { l10n("idleTime"), "border-bottom: 1px dotted; cursor: help;" }, l10n("idleTimeTitle"));
if(hasPrivateNoteColumn())
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "privnote")).addChild("span", new String[] { "title", "style" }, new String[] { l10n("privateNote"), "border-bottom: 1px dotted; cursor: help;" }, l10n("privateNoteTitle"));
if(mode >= PageMaker.MODE_ADVANCED) {
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "time_routable")).addChild("#", "%\u00a0Time Routable");
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "selection_percentage")).addChild("#", "%\u00a0Selection");
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "total_traffic")).addChild("#", "Total\u00a0Traffic\u00a0(in/out/resent)");
peerTableHeaderRow.addChild("th", "Congestion\u00a0Control");
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "time_delta")).addChild("#", "Time\u00a0Delta");
peerTableHeaderRow.addChild("th").addChild("a", "href", sortString(isReversed, "uptime")).addChild("#", "Reported\u00a0Uptime");
}
SimpleColumn[] endCols = endColumnHeaders(mode >= PageMaker.MODE_ADVANCED);
if(endCols != null) {
for(int i=0;i<endCols.length;i++) {
SimpleColumn col = endCols[i];
HTMLNode header = peerTableHeaderRow.addChild("th");
String sortString = col.getSortString();
if(sortString != null)
header = header.addChild("a", "href", sortString(isReversed, sortString));
header.addChild("span", new String[] { "title", "style" }, new String[] { L10n.getString(col.getExplanationKey()), "border-bottom: 1px dotted; cursor: help;" }, L10n.getString(col.getTitleKey()));
}
}
int numberOfSelectionSamples = peers.getNumberOfSelectionSamples().tailSet(now - PeerNode.SELECTION_SAMPLING_PERIOD).size();
for (int peerIndex = 0, peerCount = peerNodeStatuses.length; peerIndex < peerCount; peerIndex++) {
PeerNodeStatus peerNodeStatus = peerNodeStatuses[peerIndex];
drawRow(peerTable, peerNodeStatus, mode >= PageMaker.MODE_ADVANCED, fProxyJavascriptEnabled, now, path, enablePeerActions, endCols, drawMessageTypes, numberOfSelectionSamples);
}
if(peerForm != null) {
drawPeerActionSelectBox(peerForm, mode >= PageMaker.MODE_ADVANCED);
}
}
// END PEER TABLE
}
// our reference
if(shouldDrawNoderefBox(mode >= PageMaker.MODE_ADVANCED)) {
drawAddPeerBox(contentNode, ctx);
drawNoderefBox(contentNode, ctx);
}
// our ports
HTMLNode portInfobox = contentNode.addChild("div", "class", "infobox infobox-normal");
portInfobox.addChild("div", "class", "infobox-header", l10n("nodePortsTitle"));
HTMLNode portInfoboxContent = portInfobox.addChild("div", "class", "infobox-content");
HTMLNode portInfoList = portInfoboxContent.addChild("ul");
SimpleFieldSet fproxyConfig = node.config.get("fproxy").exportFieldSet(true);
SimpleFieldSet fcpConfig = node.config.get("fcp").exportFieldSet(true);
SimpleFieldSet tmciConfig = node.config.get("console").exportFieldSet(true);
portInfoList.addChild("li", L10n.getString("DarknetConnectionsToadlet.darknetFnpPort", new String[] { "port" }, new String[] { Integer.toString(node.getFNPPort()) }));
int opennetPort = node.getOpennetFNPPort();
if(opennetPort > 0)
portInfoList.addChild("li", L10n.getString("DarknetConnectionsToadlet.opennetFnpPort", new String[] { "port" }, new String[] { Integer.toString(opennetPort) }));
try {
if(fproxyConfig.getBoolean("enabled", false)) {
portInfoList.addChild("li", L10n.getString("DarknetConnectionsToadlet.fproxyPort", new String[] { "port" }, new String[] { Integer.toString(fproxyConfig.getInt("port")) }));
} else {
portInfoList.addChild("li", l10n("fproxyDisabled"));
}
if(fcpConfig.getBoolean("enabled", false)) {
portInfoList.addChild("li", L10n.getString("DarknetConnectionsToadlet.fcpPort", new String[] { "port" }, new String[] { Integer.toString(fcpConfig.getInt("port")) }));
} else {
portInfoList.addChild("li", l10n("fcpDisabled"));
}
if(tmciConfig.getBoolean("enabled", false)) {
portInfoList.addChild("li", L10n.getString("DarknetConnectionsToadlet.tmciPort", new String[] { "port" }, new String[] { Integer.toString(tmciConfig.getInt("port")) }));
} else {
portInfoList.addChild("li", l10n("tmciDisabled"));
}
} catch (FSParseException e) {
// ignore
}
this.writeHTMLReply(ctx, 200, "OK", pageNode.generate());
}
protected abstract boolean acceptRefPosts();
/** Where to redirect to if there is an error */
protected abstract String defaultRedirectLocation();
public void handlePost(URI uri, final HTTPRequest request, ToadletContext ctx) throws ToadletContextClosedException, IOException, RedirectException {
boolean logMINOR = Logger.shouldLog(Logger.MINOR, this);
if(!acceptRefPosts()) {
super.sendErrorPage(ctx, 403, "Unauthorized", L10n.getString("Toadlet.unauthorized"));
return;
}
if(!ctx.isAllowedFullAccess()) {
super.sendErrorPage(ctx, 403, "Unauthorized", L10n.getString("Toadlet.unauthorized"));
return;
}
String pass = request.getPartAsString("formPassword", 32);
if((pass == null) || !pass.equals(core.formPassword)) {
MultiValueTable headers = new MultiValueTable();
headers.put("Location", defaultRedirectLocation());
ctx.sendReplyHeaders(302, "Found", headers, null, 0);
if(logMINOR) Logger.minor(this, "No password ("+pass+" should be "+core.formPassword+ ')');
return;
}
if (request.isPartSet("add")) {
// add a new node
String urltext = request.getPartAsString("url", 200);
urltext = urltext.trim();
String reftext = request.getPartAsString("ref", Integer.MAX_VALUE);
reftext = reftext.trim();
if (reftext.length() < 200) {
reftext = request.getPartAsString("reffile", 2000);
reftext = reftext.trim();
}
String privateComment = null;
if(!isOpennet())
privateComment = request.getPartAsString("peerPrivateNote", 250).trim();
StringBuffer ref = new StringBuffer(1024);
if (urltext.length() > 0) {
// fetch reference from a URL
BufferedReader in = null;
try {
URL url = new URL(urltext);
URLConnection uc = url.openConnection();
// FIXME get charset encoding from uc.getContentType()
in = new BufferedReader(new InputStreamReader(uc.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
ref.append( line ).append('\n');
}
} catch (IOException e) {
this.sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"), L10n.getString("DarknetConnectionsToadlet.cantFetchNoderefURL", new String[] { "url" }, new String[] { urltext }));
return;
} finally {
if( in != null ){
in.close();
}
}
} else if (reftext.length() > 0) {
// read from post data or file upload
// this slightly scary looking regexp chops any extra characters off the beginning or ends of lines and removes extra line breaks
ref = new StringBuffer(reftext.replaceAll(".*?((?:[\\w,\\.]+\\=[^\r\n]+?)|(?:End))[ \\t]*(?:\\r?\\n)+", "$1\n"));
} else {
this.sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"), l10n("noRefOrURL"));
request.freeParts();
return;
}
ref = new StringBuffer(ref.toString().trim());
request.freeParts();
// we have a node reference in ref
SimpleFieldSet fs;
try {
fs = new SimpleFieldSet(ref.toString(), false, true);
if(!fs.getEndMarker().endsWith("End")) {
sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"),
L10n.getString("DarknetConnectionsToadlet.cantParseWrongEnding", new String[] { "end" }, new String[] { fs.getEndMarker() }));
return;
}
fs.setEndMarker("End"); // It's always End ; the regex above doesn't always grok this
} catch (IOException e) {
this.sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"),
L10n.getString("DarknetConnectionsToadlet.cantParseTryAgain", new String[] { "error" }, new String[] { e.toString() }));
return;
} catch (Throwable t) {
this.sendErrorPage(ctx, l10n("failedToAddNodeInternalErrorTitle"), l10n("failedToAddNodeInternalError"), t);
return;
}
PeerNode pn;
try {
if(isOpennet()) {
pn = node.createNewOpennetNode(fs);
} else {
pn = node.createNewDarknetNode(fs);
((DarknetPeerNode)pn).setPrivateDarknetCommentNote(privateComment);
}
} catch (FSParseException e1) {
this.sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"),
L10n.getString("DarknetConnectionsToadlet.cantParseTryAgain", new String[] { "error" }, new String[] { e1.toString() }));
return;
} catch (PeerParseException e1) {
this.sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"),
L10n.getString("DarknetConnectionsToadlet.cantParseTryAgain", new String[] { "error" }, new String[] { e1.toString() }));
return;
} catch (ReferenceSignatureVerificationException e1){
HTMLNode node = new HTMLNode("div");
node.addChild("#", L10n.getString("DarknetConnectionsToadlet.invalidSignature", new String[] { "error" }, new String[] { e1.toString() }));
node.addChild("br");
this.sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"), node);
return;
} catch (Throwable t) {
this.sendErrorPage(ctx, l10n("failedToAddNodeInternalErrorTitle"), l10n("failedToAddNodeInternalError"), t);
return;
}
if(Arrays.equals(pn.getIdentity(), node.getDarknetIdentity())) {
this.sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"), l10n("triedToAddSelf"));
return;
}
if(!this.node.addPeerConnection(pn)) {
this.sendErrorPage(ctx, 200, l10n("failedToAddNodeTitle"), l10n("alreadyInReferences"));
return;
}
MultiValueTable headers = new MultiValueTable();
headers.put("Location", defaultRedirectLocation());
ctx.sendReplyHeaders(302, "Found", headers, null, 0);
return;
} else handleAltPost(uri, request, ctx, logMINOR);
}
/** Adding a darknet node or an opennet node? */
protected abstract boolean isOpennet();
/**
* Rest of handlePost() method - supplied by subclass.
* @throws IOException
* @throws ToadletContextClosedException
* @throws RedirectException
*/
protected void handleAltPost(URI uri, HTTPRequest request, ToadletContext ctx, boolean logMINOR) throws ToadletContextClosedException, IOException, RedirectException {
// Do nothing - we only support adding nodes
handleGet(uri, new HTTPRequestImpl(uri), ctx);
}
/**
* What should the heading (before "(more detailed)") be on the peers table?
*/
protected abstract String getPeerListTitle();
/** Should there be a checkbox for each peer, and drawPeerActionSelectBox() be called directly
* after drawing the peers list? */
protected abstract boolean showPeerActionsBox();
/** If showPeerActionsBox() is true, this will be called directly after drawing the peers table.
* A form has been added, and checkboxes added for each peer. This function should draw the rest
* of the form - any additional controls and one or more submit buttons.
*/
protected abstract void drawPeerActionSelectBox(HTMLNode peerForm, boolean advancedModeEnabled);
protected abstract boolean shouldDrawNoderefBox(boolean advancedModeEnabled);
private void drawNoderefBox(HTMLNode contentNode, ToadletContext ctx) {
HTMLNode referenceInfobox = contentNode.addChild("div", "class", "infobox infobox-normal");
HTMLNode headerReferenceInfobox = referenceInfobox.addChild("div", "class", "infobox-header");
// FIXME better way to deal with this sort of thing???
L10n.addL10nSubstitution(headerReferenceInfobox, "DarknetConnectionsToadlet.myReferenceHeader",
new String[] { "linkref", "/linkref", "linktext", "/linktext" },
new String[] { "<a href=\"myref.fref\">", "</a>", "<a href=\"myref.txt\">", "</a>" });
HTMLNode referenceInfoboxContent = referenceInfobox.addChild("div", "class", "infobox-content");
HTMLNode warningSentence = referenceInfoboxContent.addChild("p");
L10n.addL10nSubstitution(warningSentence, "DarknetConnectionsToadlet.referenceCopyWarning",
new String[] { "bold", "/bold" },
new String[] { "<b>", "</b>" });
referenceInfoboxContent.addChild("pre", "id", "reference", getNoderef().toString() + '\n');
}
protected abstract String getPageTitle(String titleCountString, String myName);
/** Draw the add a peer box. This comes immediately after the main peers table and before the noderef box.
* Implementors may skip it by not doing anything in this method. */
protected void drawAddPeerBox(HTMLNode contentNode, ToadletContext ctx) {
// BEGIN PEER ADDITION BOX
HTMLNode peerAdditionInfobox = contentNode.addChild("div", "class", "infobox infobox-normal");
peerAdditionInfobox.addChild("div", "class", "infobox-header", l10n("addPeerTitle"));
HTMLNode peerAdditionContent = peerAdditionInfobox.addChild("div", "class", "infobox-content");
HTMLNode peerAdditionForm = ctx.addFormChild(peerAdditionContent, ".", "addPeerForm");
peerAdditionForm.addChild("#", l10n("pasteReference"));
peerAdditionForm.addChild("br");
peerAdditionForm.addChild("textarea", new String[] { "id", "name", "rows", "cols" }, new String[] { "reftext", "ref", "8", "74" });
peerAdditionForm.addChild("br");
peerAdditionForm.addChild("#", (l10n("urlReference") + ' '));
peerAdditionForm.addChild("input", new String[] { "id", "type", "name" }, new String[] { "refurl", "text", "url" });
peerAdditionForm.addChild("br");
peerAdditionForm.addChild("#", (l10n("fileReference") + ' '));
peerAdditionForm.addChild("input", new String[] { "id", "type", "name" }, new String[] { "reffile", "file", "reffile" });
peerAdditionForm.addChild("br");
if(!isOpennet()) {
peerAdditionForm.addChild("#", (l10n("enterDescription") + ' '));
peerAdditionForm.addChild("input", new String[] { "id", "type", "name", "size", "maxlength", "value" }, new String[] { "peerPrivateNote", "text", "peerPrivateNote", "16", "250", "" });
peerAdditionForm.addChild("br");
}
peerAdditionForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "add", l10n("add") });
}
protected Comparator comparator(String sortBy, boolean reversed) {
return new ComparatorByStatus(sortBy, reversed);
}
abstract protected PeerNodeStatus[] getPeerNodeStatuses(boolean noHeavy);
abstract protected SimpleFieldSet getNoderef();
private void drawRow(HTMLNode peerTable, PeerNodeStatus peerNodeStatus, boolean advancedModeEnabled, boolean fProxyJavascriptEnabled, long now, String path, boolean enablePeerActions, SimpleColumn[] endCols, boolean drawMessageTypes, int numberOfSelectionSamples) {
int peerSelectionCount = peerNodeStatus.getNumberOfSelections().tailSet(now - PeerNode.SELECTION_SAMPLING_PERIOD).size();
int peerSelectionPercentage = (numberOfSelectionSamples > 0 ? (peerSelectionCount*100/numberOfSelectionSamples) : 0);
HTMLNode peerRow = peerTable.addChild("tr", "class", "darknet_connections_"+(peerSelectionPercentage > PeerNode.SELECTION_PERCENTAGE_WARNING ? "warning" : "normal"));
if(enablePeerActions) {
// check box column
peerRow.addChild("td", "class", "peer-marker").addChild("input", new String[] { "type", "name" }, new String[] { "checkbox", "node_" + peerNodeStatus.hashCode() });
}
// status column
String statusString = peerNodeStatus.getStatusName();
if (!advancedModeEnabled && (peerNodeStatus.getStatusValue() == PeerManager.PEER_NODE_STATUS_ROUTING_BACKED_OFF)) {
statusString = "BUSY";
}
peerRow.addChild("td", "class", "peer-status").addChild("span", "class", peerNodeStatus.getStatusCSSName(), L10n.getString("ConnectionsToadlet.nodeStatus." + statusString) + (peerNodeStatus.isFetchingARK() ? "*" : ""));
drawNameColumn(peerRow, peerNodeStatus);
// address column
if (advancedModeEnabled) {
String pingTime = "";
if (peerNodeStatus.isConnected()) {
pingTime = " (" + (int) peerNodeStatus.getAveragePingTime() + "ms)";
}
peerRow.addChild("td", "class", "peer-address").addChild("#", ((peerNodeStatus.getPeerAddress() != null) ? (peerNodeStatus.getPeerAddress() + ':' + peerNodeStatus.getPeerPort()) : (l10n("unknownAddress"))) + pingTime);
}
// version column
if (peerNodeStatus.getStatusValue() != PeerManager.PEER_NODE_STATUS_NEVER_CONNECTED && (peerNodeStatus.isPublicInvalidVersion() || peerNodeStatus.isPublicReverseInvalidVersion())) { // Don't draw attention to a version problem if NEVER CONNECTED
peerRow.addChild("td", "class", "peer-version").addChild("span", "class", "peer_version_problem", Integer.toString(peerNodeStatus.getSimpleVersion()));
} else {
peerRow.addChild("td", "class", "peer-version").addChild("#", Integer.toString(peerNodeStatus.getSimpleVersion()));
}
// location column
if (advancedModeEnabled) {
HTMLNode locationNode = peerRow.addChild("td", "class", "peer-location");
locationNode.addChild("b", String.valueOf(peerNodeStatus.getLocation()));
locationNode.addChild("br");
double[] peersLoc = peerNodeStatus.getPeersLocation();
if(peersLoc != null) {
for(double loc : peersLoc)
locationNode.addChild("i", String.valueOf(loc)).addChild("br");
}
}
if (advancedModeEnabled) {
// backoff column
HTMLNode backoffCell = peerRow.addChild("td", "class", "peer-backoff");
backoffCell.addChild("#", fix1.format(peerNodeStatus.getBackedOffPercent()));
int backoff = (int) (Math.max(peerNodeStatus.getRoutingBackedOffUntil() - now, 0));
// Don't list the backoff as zero before it's actually zero
if ((backoff > 0) && (backoff < 1000)) {
backoff = 1000;
}
backoffCell.addChild("#", ' ' + String.valueOf(backoff / 1000) + '/' + String.valueOf(peerNodeStatus.getRoutingBackoffLength() / 1000));
backoffCell.addChild("#", (peerNodeStatus.getLastBackoffReason() == null) ? "" : ('/' + (peerNodeStatus.getLastBackoffReason())));
// overload probability column
HTMLNode pRejectCell = peerRow.addChild("td", "class", "peer-backoff"); // FIXME
pRejectCell.addChild("#", fix1.format(peerNodeStatus.getPReject()));
}
// idle column
long idle = peerNodeStatus.getTimeLastRoutable();
if (peerNodeStatus.isRoutable()) {
idle = peerNodeStatus.getTimeLastConnectionCompleted();
} else if (peerNodeStatus.getStatusValue() == PeerManager.PEER_NODE_STATUS_NEVER_CONNECTED) {
idle = peerNodeStatus.getPeerAddedTime();
}
if(!peerNodeStatus.isConnected() && (now - idle) > (2 * 7 * 24 * 60 * 60 * (long) 1000)) { // 2 weeks
peerRow.addChild("td", "class", "peer-idle").addChild("span", "class", "peer_idle_old", idleToString(now, idle));
} else {
peerRow.addChild("td", "class", "peer-idle", idleToString(now, idle));
}
if(hasPrivateNoteColumn())
drawPrivateNoteColumn(peerRow, peerNodeStatus, fProxyJavascriptEnabled);
if(advancedModeEnabled) {
// percent of time connected column
peerRow.addChild("td", "class", "peer-idle" /* FIXME */).addChild("#", fix1.format(peerNodeStatus.getPercentTimeRoutableConnection()));
// selection stats
peerRow.addChild("td", "class", "peer-idle" /* FIXME */).addChild("#", (numberOfSelectionSamples > 0 ? (peerSelectionPercentage+"%") : "N/A"));
// total traffic column
peerRow.addChild("td", "class", "peer-idle" /* FIXME */).addChild("#", SizeUtil.formatSize(peerNodeStatus.getTotalInputBytes())+" / "+SizeUtil.formatSize(peerNodeStatus.getTotalOutputBytes())+"/"+SizeUtil.formatSize(peerNodeStatus.getResendBytesSent()));
// congestion control
PacketThrottle t = peerNodeStatus.getThrottle();
String val;
if(t == null)
val = "none";
else
val = (int)((1000.0 / t.getDelay()) * 1024.0)+"B/sec delay "+
t.getDelay()+"ms (RTT "+t.getRoundTripTime()+"ms window "+t.getWindowSize()+')';
peerRow.addChild("td", "class", "peer-idle" /* FIXME */).addChild("#", val);
// time delta
peerRow.addChild("td", "class", "peer-idle" /* FIXME */).addChild("#", TimeUtil.formatTime(peerNodeStatus.getClockDelta()));
peerRow.addChild("td", "class", "peer-idle" /* FIXME */).addChild("#", peerNodeStatus.getReportedUptimePercentage()+"%");
}
if(endCols != null) {
for(int i=0;i<endCols.length;i++) {
endCols[i].drawColumn(peerRow, peerNodeStatus);
}
}
if (drawMessageTypes) {
drawMessageTypes(peerTable, peerNodeStatus);
}
}
/** Is there a name column? */
abstract protected boolean hasNameColumn();
/**
* Draw the name column, if there is one. This will be directly after the status column.
*/
abstract protected void drawNameColumn(HTMLNode peerRow, PeerNodeStatus peerNodeStatus);
/**
* Is there a private note column?
*/
abstract protected boolean hasPrivateNoteColumn();
/**
* Draw the private note column.
*/
abstract protected void drawPrivateNoteColumn(HTMLNode peerRow, PeerNodeStatus peerNodeStatus, boolean fProxyJavascriptEnabled);
private void drawMessageTypes(HTMLNode peerTable, PeerNodeStatus peerNodeStatus) {
HTMLNode messageCountRow = peerTable.addChild("tr", "class", "message-status");
messageCountRow.addChild("td", "colspan", "2");
HTMLNode messageCountCell = messageCountRow.addChild("td", "colspan", "9"); // = total table row width - 2 from above colspan
HTMLNode messageCountTable = messageCountCell.addChild("table", "class", "message-count");
HTMLNode countHeaderRow = messageCountTable.addChild("tr");
countHeaderRow.addChild("th", "Message");
countHeaderRow.addChild("th", "Incoming");
countHeaderRow.addChild("th", "Outgoing");
List messageNames = new ArrayList();
Map messageCounts = new HashMap();
for (Iterator incomingMessages = peerNodeStatus.getLocalMessagesReceived().keySet().iterator(); incomingMessages.hasNext(); ) {
String messageName = (String) incomingMessages.next();
messageNames.add(messageName);
Long messageCount = (Long) peerNodeStatus.getLocalMessagesReceived().get(messageName);
messageCounts.put(messageName, new Long[] { messageCount, new Long(0) });
}
for (Iterator outgoingMessages = peerNodeStatus.getLocalMessagesSent().keySet().iterator(); outgoingMessages.hasNext(); ) {
String messageName = (String) outgoingMessages.next();
if (!messageNames.contains(messageName)) {
messageNames.add(messageName);
}
Long messageCount = (Long) peerNodeStatus.getLocalMessagesSent().get(messageName);
Long[] existingCounts = (Long[]) messageCounts.get(messageName);
if (existingCounts == null) {
messageCounts.put(messageName, new Long[] { new Long(0), messageCount });
} else {
existingCounts[1] = messageCount;
}
}
Collections.sort(messageNames, new Comparator() {
public int compare(Object first, Object second) {
return ((String) first).compareToIgnoreCase((String) second);
}
});
for (Iterator messageNamesIterator = messageNames.iterator(); messageNamesIterator.hasNext(); ) {
String messageName = (String) messageNamesIterator.next();
Long[] messageCount = (Long[]) messageCounts.get(messageName);
HTMLNode messageRow = messageCountTable.addChild("tr");
messageRow.addChild("td", messageName);
messageRow.addChild("td", "class", "right-align", String.valueOf(messageCount[0]));
messageRow.addChild("td", "class", "right-align", String.valueOf(messageCount[1]));
}
}
private String idleToString(long now, long idle) {
if (idle <= 0) {
return " ";
}
long idleMilliseconds = now - idle;
return TimeUtil.formatTime(idleMilliseconds);
}
private static String l10n(String string) {
return L10n.getString("DarknetConnectionsToadlet."+string);
}
private String sortString(boolean isReversed, String type) {
return (isReversed ? ("?sortBy="+type) : ("?sortBy="+type+"&reversed"));
}
}
The table below shows all metrics for ConnectionsToadlet.java.
| Metric | Value | Description | |
|---|---|---|---|
| BLOCKS | 128.00 | Number of blocks | |
| BLOCK_COMMENT | 3.00 | Number of block comment lines | |
| COMMENTS | 71.00 | Comment lines | |
| COMMENT_DENSITY | 0.11 | Comment density | |
| COMPARISONS | 150.00 | Number of comparison operators | |
| CYCLOMATIC | 147.00 | Cyclomatic complexity | |
| DECL_COMMENTS | 13.00 | Comments in declarations | |
| DOC_COMMENT | 30.00 | Number of javadoc comment lines | |
| ELOC | 623.00 | Effective lines of code | |
| EXEC_COMMENTS | 39.00 | Comments in executable code | |
| EXITS | 184.00 | Procedure exits | |
| FUNCTIONS | 40.00 | Number of function declarations | |
| HALSTEAD_DIFFICULTY | 105.21 | Halstead difficulty | |
| HALSTEAD_EFFORT | 0.00 | Halstead effort | |
| INTERFACE_COMPLEXITY | 149.00 | Interface complexity | |
| JAVA0001 | 0.00 | JAVA0001 Package name does not contain only lower case letters | |
| JAVA0002 | 1.00 | JAVA0002 Package name does not begin with a top level domain name or country code | |
| JAVA0003 | 0.00 | JAVA0003 Minimize use of on-demand (.*) imports | |
| JAVA0004 | 0.00 | JAVA0004 Unnecessary import from java.lang | |
| JAVA0005 | 0.00 | JAVA0005 Imports not in specified order | |
| JAVA0006 | 0.00 | JAVA0006 Empty finally block | |
| JAVA0007 | 0.00 | JAVA0007 Should not declare public field | |
| JAVA0008 | 0.00 | JAVA0008 Empty catch block | |
| JAVA0009 | 0.00 | JAVA0009 Protected member in final class | |
| JAVA0010 | 0.00 | JAVA0010 Non-instantiable class does not contain a non-private static member | |
| JAVA0011 | 0.00 | JAVA0011 Abstract class does not contain an abstract method | |
| JAVA0012 | 0.00 | JAVA0012 Non-constructor method with same name as declaring class | |
| JAVA0013 | 0.00 | JAVA0013 Non-blank final field is not static | |
| JAVA0014 | 0.00 | JAVA0014 Class with only static members has non-private constructor | |
| JAVA0015 | 0.00 | JAVA0015 Package class contains public nested type | |
| JAVA0016 | 0.00 | JAVA0016 Abstract class contains public constructor | |
| JAVA0017 | 0.00 | JAVA0017 Class name does not have required form | |
| JAVA0018 | 0.00 | JAVA0018 Method name does not have required form | |
| JAVA0019 | 0.00 | JAVA0019 Interface name does not have required form | |
| JAVA0020 | 0.00 | JAVA0020 Field name does not have required form | |
| JAVA0021 | 0.00 | JAVA0021 Interface method name does not have required form | |
| JAVA0022 | 0.00 | JAVA0022 Static final field name does not have required form | |
| JAVA0023 | 0.00 | JAVA0023 Empty finalize method | |
| JAVA0024 | 0.00 | JAVA0024 Empty class | |
| JAVA0025 | 0.00 | JAVA0025 Method override is empty | |
| JAVA0026 | 0.00 | JAVA0026 Finalize method with parameters | |
| JAVA0029 | 0.00 | JAVA0029 Private method not used | |
| JAVA0030 | 0.00 | JAVA0030 Private field not used | |
| JAVA0031 | 0.00 | JAVA0031 Case statement not properly closed | |
| JAVA0032 | 0.00 | JAVA0032 Switch statement missing default | |
| JAVA0033 | 0.00 | JAVA0033 default: not last case in switch statement | |
| JAVA0034 | 23.00 | JAVA0034 Missing braces in if statement | |
| JAVA0035 | 0.00 | JAVA0035 Missing braces in for statement | |
| JAVA0036 | 0.00 | JAVA0036 Missing braces in while statement | |
| JAVA0038 | 0.00 | JAVA0038 Non-case label in switch statement | |
| JAVA0039 | 0.00 | JAVA0039 Break statement with label | |
| JAVA0040 | 0.00 | JAVA0040 Switch statement contains N cases (maximum: M) | |
| JAVA0041 | 0.00 | JAVA0041 Nested synchronized block | |
| JAVA0042 | 0.00 | JAVA0042 Empty synchronized statement | |
| JAVA0043 | 1.00 | JAVA0043 Inner class does not use outer class | |
| JAVA0044 | 0.00 | JAVA0044 Serializable class with no instance variables | |
| JAVA0045 | 0.00 | JAVA0045 Serializable class with only transient fields | |
| JAVA0046 | 0.00 | JAVA0046 Name of class not derived from Exception ends with 'Exception' | |
| JAVA0047 | 0.00 | JAVA0047 Serializable class derives from invalid base class | |
| JAVA0048 | 0.00 | JAVA0048 Name of class derived from Exception does not end with 'Exception' | |
| JAVA0049 | 1.00 | JAVA0049 Nested block at depth N (maximum: M) | |
| JAVA0050 | 0.00 | JAVA0050 Class derives from java.lang.Error | |
| JAVA0051 | 0.00 | JAVA0051 Class derives from java.lang.RuntimeException | |
| JAVA0052 | 0.00 | JAVA0052 Class derives from java.lang.Throwable | |
| JAVA0053 | 0.00 | JAVA0053 Unused label | |
| JAVA0054 | 0.00 | JAVA0054 Inheritance depth N exceeds maximum M | |
| JAVA0055 | 0.00 | JAVA0055 Class should be interface | |
| JAVA0056 | 0.00 | JAVA0056 Unnecessary abstract modifier for interface or annotation | |
| JAVA0057 | 0.00 | JAVA0057 Unnecessary default constructor | |
| JAVA0058 | 0.00 | JAVA0058 Constructor calls super() | |
| JAVA0059 | 0.00 | JAVA0059 Method override only calls super() | |
| JAVA0061 | 0.00 | JAVA0061 Inaccessible member in anonymous class | |
| JAVA0062 | 0.00 | JAVA0062 Public class missing public member or protected constructor | |
| JAVA0063 | 0.00 | JAVA0063 Identifier name should not contain '$' | |
| JAVA0064 | 0.00 | JAVA0064 N variations of identifier name (maximum: M) | |
| JAVA0065 | 0.00 | JAVA0065 Unnecessary final modifier for method in final class | |
| JAVA0066 | 0.00 | JAVA0066 Unnecessary modifier for interface nested type | |
| JAVA0067 | 0.00 | JAVA0067 Array descriptor on identifier name | |
| JAVA0068 | 10.00 | JAVA0068 Modifiers not declared in recommended order | |
| JAVA0071 | 0.00 | JAVA0071 Strings compared with == | |
| JAVA0073 | 0.00 | JAVA0073 Integer division in floating-point context | |
| JAVA0074 | 0.00 | JAVA0074 Use of Object.notify() | |
| JAVA0075 | 1.00 | JAVA0075 Method parameter hides field | |
| JAVA0076 | 38.00 | JAVA0076 Use of magic number | |
| JAVA0077 | 0.00 | JAVA0077 Private field not used in declaring class | |
| JAVA0078 | 0.00 | JAVA0078 Floating point values compared with == | |
| JAVA0079 | 0.00 | JAVA0079 Use of instance to reference static member | |
| JAVA0080 | 0.00 | JAVA0080 Import declaration not used | |
| JAVA0081 | 0.00 | JAVA0081 Boolean literal in comparison | |
| JAVA0082 | 0.00 | JAVA0082 Unnecessary widening cast | |
| JAVA0083 | 0.00 | JAVA0083 Unnecessary instanceof test | |
| JAVA0084 | 0.00 | JAVA0084 Should use compound assignment operator | |
| JAVA0085 | 0.00 | JAVA0085 Use of sun.* class | |
| JAVA0087 | 0.00 | JAVA0087 Use of Thread.sleep() | |
| JAVA0089 | 0.00 | JAVA0089 Use of restricted package | |
| JAVA0092 | 0.00 | JAVA0092 Use of restricted type | |
| JAVA0093 | 0.00 | JAVA0093 Redundant assignment | |
| JAVA0094 | 0.00 | JAVA0094 Field hides a superclass field | |
| JAVA0095 | 0.00 | JAVA0095 Uninitialized private field | |
| JAVA0096 | 0.00 | JAVA0096 Field in nested class hides outer field | |
| JAVA0098 | 0.00 | JAVA0098 Minimize use of implicit field initializers | |
| JAVA0100 | 0.00 | JAVA0100 Class contains N non-final fields (maximum: M) | |
| JAVA0101 | 0.00 | JAVA0101 Unnecessary modifier for field in interface | |
| JAVA0102 | 0.00 | JAVA0102 Last statement in finalize() not super.finalize() | |
| JAVA0103 | 0.00 | JAVA0103 Explicit call to finalize() | |
| JAVA0104 | 0.00 | JAVA0104 finalize() only calls super.finalize() | |
| JAVA0105 | 0.00 | JAVA0105 Duplicate import declaration | |
| JAVA0106 | 0.00 | JAVA0106 Unnecessary import from current package | |
| JAVA0108 | 15.00 | JAVA0108 Incorrect javadoc: no @param tag for 'parameter' | |
| JAVA0109 | 0.00 | JAVA0109 Incorrect javadoc: no parameter 'parameter' | |
| JAVA0110 | 7.00 | JAVA0110 Incorrect javadoc: no @return tag | |
| JAVA0111 | 0.00 | JAVA0111 Incorrect javadoc: @return tag for void method | |
| JAVA0112 | 0.00 | JAVA0112 Incorrect javadoc: no exception 'exception' in throws | |
| JAVA0113 | 0.00 | JAVA0113 Incorrect javadoc: no @author tag | |
| JAVA0114 | 0.00 | JAVA0114 Incorrect javadoc: no @version tag | |
| JAVA0115 | 0.00 | JAVA0115 Incorrect javadoc: no @throws or @exception tag for 'exception' | |
| JAVA0116 | 0.00 | JAVA0116 Missing javadoc: field 'field' | |
| JAVA0117 | 12.00 | JAVA0117 Missing javadoc: method 'method' | |
| JAVA0118 | 1.00 | JAVA0118 Missing javadoc: type 'type' | |
| JAVA0119 | 0.00 | JAVA0119 Control variable changed within body of for loop | |
| JAVA0123 | 0.00 | JAVA0123 Use all three components of for loop | |
| JAVA0125 | 0.00 | JAVA0125 Continue statement with label | |
| JAVA0126 | 0.00 | JAVA0126 Method declares unchecked exception in throws | |
| JAVA0128 | 0.00 | JAVA0128 Public constructor in non-public class | |
| JAVA0130 | 3.00 | JAVA0130 Non-static method does not use instance fields | |
| JAVA0131 | 0.00 | JAVA0131 Compatible method does not override base | |
| JAVA0132 | 0.00 | JAVA0132 Method overload with compatible signature | |
| JAVA0133 | 0.00 | JAVA0133 Non-synchronized method overrides synchronized method | |
| JAVA0135 | 0.00 | JAVA0135 Only one of Object.equals and Object.hashCode defined: missing 'method' | |
| JAVA0136 | 1.00 | JAVA0136 N methods defined in class (maximum: M) | |
| JAVA0137 | 0.00 | JAVA0137 Non-abstract class missing constructor | |
| JAVA0138 | 1.00 | JAVA0138 N parameters defined for method (maximum: M) | |
| JAVA0139 | 0.00 | JAVA0139 Definition of main other than public static void main(java.lang.String[]) | |
| JAVA0141 | 0.00 | JAVA0141 Unnecessary modifier for method in interface | |
| JAVA0143 | 0.00 | JAVA0143 Synchronized method | |
| JAVA0144 | 61.00 | JAVA0144 Line exceeds maximum M characters | |
| JAVA0145 | 2326.00 | JAVA0145 Tab character used in source file | |
| JAVA0150 | 0.00 | JAVA0150 java.lang.Error (or subclass) thrown | |
| JAVA0153 | 0.00 | JAVA0153 Inefficient conversion of integer to string | |
| JAVA0159 | 0.00 | JAVA0159 Inefficient conversion of string to integer | |
| JAVA0160 | 0.00 | JAVA0160 Method does not throw specified exception | |
| JAVA0161 | 0.00 | JAVA0161 Conditional wait() not in loop | |
| JAVA0163 | 0.00 | JAVA0163 Empty statement | |
| JAVA0165 | 0.00 | JAVA0165 Conflicting return statement in finally block | |
| JAVA0166 | 2.00 | JAVA0166 Generic exception caught | |
| JAVA0167 | 0.00 | JAVA0167 ThreadDeath not rethrown | |
| JAVA0169 | 0.00 | JAVA0169 Unnecessary catch block: exception 'exception' | |
| JAVA0170 | 2.00 | JAVA0170 Caught exception not derived from java.lang.Exception | |
| JAVA0171 | 0.00 | JAVA0171 Unused local variable | |
| JAVA0173 | 5.00 | JAVA0173 Unused method parameter | |
| JAVA0174 | 0.00 | JAVA0174 Assigned local variable never used | |
| JAVA0175 | 0.00 | JAVA0175 Successive assignment to variable | |
| JAVA0176 | 0.00 | JAVA0176 Local variable name does not have required form | |
| JAVA0177 | 5.00 | JAVA0177 Variable declaration missing initializer | |
| JAVA0179 | 1.00 | JAVA0179 Local variable hides visible field | |
| JAVA0233 | 0.00 | JAVA0233 Definition of serialVersionUID other than 'private static final long serialVersionUID' | |
| JAVA0234 | 0.00 | JAVA0234 Class is Serializable but does not define serialVersionUID | |
| JAVA0235 | 0.00 | JAVA0235 Class defines serialVersionUID but does not implement Serializable | |
| JAVA0236 | 0.00 | JAVA0236 Attempt to clone an object which does not implement Cloneable | |
| JAVA0237 | 0.00 | JAVA0237 Class implements Cloneable but does not have public clone method | |
| JAVA0238 | 0.00 | JAVA0238 Clone method does not call super.clone() | |
| JAVA0239 | 0.00 | JAVA0239 Class declares 'readObject' or 'writeObject' but does not implement Serializable | |
| JAVA0240 | 0.00 | JAVA0240 Serializable class which declares readObject or writeObject but not both | |
| JAVA0241 | 0.00 | JAVA0241 'readObject' or 'writeObject' should be declared private in Serializable class | |
| JAVA0242 | 0.00 | JAVA0242 Transient field in non-Serializable class | |
| JAVA0243 | 0.00 | JAVA0243 'readResolve' or 'writeReplace' should be declared private or protected | |
| JAVA0244 | 0.00 | JAVA0244 Field or method name in subclass differs only by case from inherited field or method | |
| JAVA0245 | 0.00 | JAVA0245 JUnit TestCase with non-trivial constructor | |
| JAVA0246 | 0.00 | JAVA0246 JUnit assertXXX statement missing message parameter | |
| JAVA0247 | 0.00 | JAVA0247 JUnit 'setUp()' and 'tearDown()' should call super method | |
| JAVA0248 | 0.00 | JAVA0248 JUnit method 'setUp' or 'tearDown' with incorrect signature | |
| JAVA0249 | 0.00 | JAVA0249 JUnit TestCase 'suite()' should be declared static | |
| JAVA0250 | 0.00 | JAVA0250 JUnit TestCase declares testXXX method with incorrect signature | |
| JAVA0251 | 0.00 | JAVA0251 Use '%n' for line breaks in printf/format for platform independence | |
| JAVA0252 | 0.00 | JAVA0252 'enum' is a Java 1.5 reserved word | |
| JAVA0253 | 0.00 | JAVA0253 Not all enum constants consumed in switch statement | |
| JAVA0254 | 3.00 | JAVA0254 Use enhanced for loop construct instead of Iterator | |
| JAVA0255 | 0.00 | JAVA0255 Result of method invocation not used | |
| JAVA0256 | 0.00 | JAVA0256 Assignment of external collection/array to field | |
| JAVA0257 | 0.00 | JAVA0257 Use of 'Constant Interface' anti-pattern | |
| JAVA0258 | 0.00 | JAVA0258 Implement Iterable for foreach compatibility | |
| JAVA0259 | 0.00 | JAVA0259 Return of collection/array field | |
| JAVA0260 | 0.00 | JAVA0260 Use 'enum' instead of Enumerated Type pattern | |
| JAVA0261 | 0.00 | JAVA0261 Use specialized Enum collection types | |
| JAVA0262 | 0.00 | JAVA0262 Use of char in integer context | |
| JAVA0263 | 0.00 | JAVA0263 Long literal ends with 'l' instead of 'L' | |
| JAVA0264 | 1.00 | JAVA0264 Integer math in long context - check for overflow | |
| JAVA0265 | 0.00 | JAVA0265 Use of Throwable.printStackTrace() | |
| JAVA0266 | 0.00 | JAVA0266 Use of System.out | |
| JAVA0267 | 0.00 | JAVA0267 Use of System.err | |
| JAVA0269 | 0.00 | JAVA0269 Contents of StringBuffer never used | |
| JAVA0270 | 3.00 | JAVA0270 Use Java 5.0 enhanced for loop construct to iterate over all elements in an array | |
| JAVA0271 | 0.00 | JAVA0271 Minimize use of on-demand (.*) static imports | |
| JAVA0272 | 0.00 | JAVA0272 Thread.run() called | |
| JAVA0273 | 0.00 | JAVA0273 Non-final derivative of Thread calls start() in constructor | |
| JAVA0274 | 0.00 | JAVA0274 Serializable class has a synchronized readObject() | |
| JAVA0275 | 0.00 | JAVA0275 Serializable class has a synchronized writeObject() and no other synchronized methods | |
| JAVA0276 | 0.00 | JAVA0276 Unnecessary use of String constructor | |
| JAVA0277 | 0.00 | JAVA0277 Iterator.next() implementation does not throw NoSuchElementException | |
| JAVA0278 | 0.00 | JAVA0278 Unnecessary use of Boolean constructor | |
| JAVA0279 | 0.00 | JAVA0279 Serialization method readObject or readObjectNoData calls an overridable method | |
| JAVA0280 | 0.00 | JAVA0280 IllegalMonitorStateException caught | |
| JAVA0281 | 0.00 | JAVA0281 Iterator.next() not called in loop | |
| JAVA0282 | 0.00 | JAVA0282 Call to Iterator.next() in loop which does not test Iterator.hasNext() | |
| JAVA0283 | 0.00 | JAVA0283 Control variable not updated in loop body | |
| JAVA0284 | 0.00 | JAVA0284 Explicit garbage collection | |
| JAVA0285 | 0.00 | JAVA0285 Dereference of potentially null variable | |
| JAVA0286 | 0.00 | JAVA0286 Dereference of null variable | |
| JAVA0287 | 0.00 | JAVA0287 Unnecessary null check | |
| JAVA0288 | 0.00 | JAVA0288 Inconsistent null check | |
| LINES | 888.00 | Number of lines in the source file | |
| LINE_COMMENT | 38.00 | Number of line comments | |
| LOC | 716.00 | Lines of code | |
| LOGICAL_LINES | 474.00 | Number of statements | |
| LOOPS | 8.00 | Number of loops | |
| NEST_DEPTH | 6.00 | Maximum nesting depth | |
| OPERANDS | 2872.00 | Number of operands | |
| OPERATORS | 4880.00 | Number of operators | |
| PARAMS | 67.00 | Number of formal parameter declarations | |
| PROGRAM_LENGTH | 7752.00 | Halstead program length | |
| PROGRAM_VOCAB | 835.00 | Halstead program vocabulary | |
| PROGRAM_VOLUME | 0.00 | Halstead program volume | |
| RETURNS | 82.00 | Number of return points from functions | |
| SIZE | 44002.00 | Size of the file in bytes | |
| UNIQUE_OPERANDS | 778.00 | Number of unique operands | |
| UNIQUE_OPERATORS | 57.00 | Number of unique operators | |
| WHITESPACE | 101.00 | Number of whitespace lines | |