QueueToadlet.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 | |
|---|---|---|
| OPERANDS | Number of operands |  |
| PROGRAM_LENGTH | Halstead program length | |
| OPERATORS | Number of operators | |
| JAVA0144 | JAVA0144 Line exceeds maximum M characters | |
| SIZE | Size of the file in bytes | |
| LOGICAL_LINES | Number of statements | |
| CYCLOMATIC | Cyclomatic complexity | |
| COMPARISONS | Number of comparison operators | |
| UNIQUE_OPERANDS | Number of unique operands | |
| BLOCKS | Number of blocks | |
| ELOC | Effective lines of code | |
| RETURNS | Number of return points from functions | |
| JAVA0034 | JAVA0034 Missing braces in if statement | |
| PROGRAM_VOCAB | Halstead program vocabulary | |
| LOC | Lines of code | |
| EXITS | Procedure exits | |
| INTERFACE_COMPLEXITY | Interface complexity | |
| JAVA0145 | JAVA0145 Tab character used in source file | |
| LINES | Number of lines in the source file | |
| LOOPS | Number of loops | |
| PARAMS | Number of formal parameter declarations | |
| JAVA0130 | JAVA0130 Non-static method does not use instance fields | |
| JAVA0076 | JAVA0076 Use of magic number | |
| JAVA0177 | JAVA0177 Variable declaration missing initializer | |
| EXEC_COMMENTS | Comments in executable code | |
| JAVA0039 | JAVA0039 Break statement with label | |
| JAVA0270 | JAVA0270 Use Java 5.0 enhanced for loop construct to iterate over all elements in an array | |
| NEST_DEPTH | Maximum nesting depth | |
| FUNCTIONS | Number of function declarations | |
| JAVA0173 | JAVA0173 Unused method parameter | |
| JAVA0049 | JAVA0049 Nested block at depth N (maximum: M) | |
| JAVA0265 | JAVA0265 Use of Throwable.printStackTrace() | |
| UNIQUE_OPERATORS | Number of unique operators | |
| JAVA0285 | JAVA0285 Dereference of potentially null variable | |
| JAVA0150 | JAVA0150 java.lang.Error (or subclass) thrown | |
| JAVA0138 | JAVA0138 N parameters defined for method (maximum: M) | |
| PROGRAM_VOLUME | Halstead program volume | |
| JAVA0136 | JAVA0136 N methods defined in class (maximum: M) | |
| JAVA0035 | JAVA0035 Missing braces in for statement | |
| JAVA0126 | JAVA0126 Method declares unchecked exception in throws | |
| JAVA0110 | JAVA0110 Incorrect javadoc: no @return tag | |
| JAVA0117 | JAVA0117 Missing javadoc: method 'method' | |
| JAVA0287 | JAVA0287 Unnecessary null check | |
| JAVA0108 | JAVA0108 Incorrect javadoc: no @param tag for 'parameter' | |
| JAVA0254 | JAVA0254 Use enhanced for loop construct instead of Iterator | |
| COMMENTS | Comment lines | |
| DECL_COMMENTS | Comments in declarations | |
| DOC_COMMENT | Number of javadoc comment lines | |
| WHITESPACE | Number of whitespace lines | |
/* This code is part of Freenet. It is distributed under the GNU General
* Public License, version 2 (or at your option any later version). See
* http://www.gnu.org/ for further details of the GPL. */
package freenet.clients.http;
import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.EOFException;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.net.MalformedURLException;
import java.net.URI;
import java.text.NumberFormat;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import freenet.client.DefaultMIMETypes;
import freenet.client.HighLevelSimpleClient;
import freenet.keys.FreenetURI;
import freenet.l10n.L10n;
import freenet.node.NodeClientCore;
import freenet.node.RequestStarter;
import freenet.node.fcp.ClientGet;
import freenet.node.fcp.ClientPut;
import freenet.node.fcp.ClientPutDir;
import freenet.node.fcp.ClientPutMessage;
import freenet.node.fcp.ClientRequest;
import freenet.node.fcp.FCPServer;
import freenet.node.fcp.IdentifierCollisionException;
import freenet.node.fcp.MessageInvalidException;
import freenet.node.fcp.NotAllowedException;
import freenet.node.fcp.RequestCompletionCallback;
import freenet.node.useralerts.SimpleHTMLUserAlert;
import freenet.node.useralerts.UserAlert;
import freenet.support.HTMLNode;
import freenet.support.Logger;
import freenet.support.MultiValueTable;
import freenet.support.SizeUtil;
import freenet.support.api.Bucket;
import freenet.support.api.HTTPRequest;
import freenet.support.api.HTTPUploadedFile;
import freenet.support.io.BucketTools;
import freenet.support.io.Closer;
import freenet.support.io.FileBucket;
public class QueueToadlet extends Toadlet implements RequestCompletionCallback {
private static final int LIST_IDENTIFIER = 1;
private static final int LIST_SIZE = 2;
private static final int LIST_MIME_TYPE = 3;
private static final int LIST_DOWNLOAD = 4;
private static final int LIST_PERSISTENCE = 5;
private static final int LIST_KEY = 6;
private static final int LIST_FILENAME = 7;
private static final int LIST_PRIORITY = 8;
private static final int LIST_FILES = 9;
private static final int LIST_TOTAL_SIZE = 10;
private static final int LIST_PROGRESS = 11;
private static final int LIST_REASON = 12;
private static final int MAX_IDENTIFIER_LENGTH = 1024*1024;
private static final int MAX_FILENAME_LENGTH = 1024*1024;
private static final int MAX_TYPE_LENGTH = 1024;
static final int MAX_KEY_LENGTH = 1024*1024;
private NodeClientCore core;
final FCPServer fcp;
private boolean isReversed = false;
public QueueToadlet(NodeClientCore core, FCPServer fcp, HighLevelSimpleClient client) {
super(client);
this.core = core;
this.fcp = fcp;
if(fcp == null) throw new NullPointerException();
fcp.setCompletionCallback(this);
loadCompletedIdentifiers();
}
public void handlePost(URI uri, HTTPRequest request, ToadletContext ctx) throws ToadletContextClosedException, IOException, RedirectException {
if(!core.hasLoadedQueue()) {
writeError(L10n.getString("QueueToadlet.notLoadedYetTitle"), L10n.getString("QueueToadlet.notLoadedYet"), ctx, false);
return;
}
boolean logMINOR = Logger.shouldLog(Logger.MINOR, this);
try {
// Browse... button
if (request.getPartAsString("insert-local", 128).length() > 0) {
// Preserve the key
FreenetURI insertURI;
String keyType = request.getPartAsString("keytype", 3);
if ("chk".equals(keyType)) {
insertURI = new FreenetURI("CHK@");
} else {
try {
String u = request.getPartAsString("key", 128);
insertURI = new FreenetURI(u);
if(logMINOR)
Logger.minor(this, "Inserting key: "+insertURI+" ("+u+")");
} catch (MalformedURLException mue1) {
writeError(L10n.getString("QueueToadlet.errorInvalidURI"), L10n.getString("QueueToadlet.errorInvalidURIToU"), ctx);
return;
}
}
MultiValueTable responseHeaders = new MultiValueTable();
responseHeaders.put("Location", "/files/?key="+insertURI.toACIIString());
ctx.sendReplyHeaders(302, "Found", responseHeaders, null, 0);
return;
}
String pass = request.getPartAsString("formPassword", 32);
if ((pass.length() == 0) || !pass.equals(core.formPassword)) {
MultiValueTable headers = new MultiValueTable();
headers.put("Location", "/queue/");
ctx.sendReplyHeaders(302, "Found", headers, null, 0);
if(logMINOR) Logger.minor(this, "No formPassword: "+pass);
return;
}
if(request.isPartSet("remove_request") && (request.getPartAsString("remove_request", 32).length() > 0)) {
String identifier = request.getPartAsString("identifier", MAX_IDENTIFIER_LENGTH);
if(logMINOR) Logger.minor(this, "Removing "+identifier);
try {
fcp.removeGlobalRequest(identifier);
} catch (MessageInvalidException e) {
this.sendErrorPage(ctx, 200,
L10n.getString("QueueToadlet.failedToRemoveRequest"),
L10n.getString("QueueToadlet.failedToRemove",
new String[]{ "id", "message" },
new String[]{ identifier, e.getMessage()}
));
return;
}
writePermanentRedirect(ctx, "Done", "/queue/");
return;
} else if(request.isPartSet("restart_request") && (request.getPartAsString("restart_request", 32).length() > 0)) {
String identifier = request.getPartAsString("identifier", MAX_IDENTIFIER_LENGTH);
if(logMINOR) Logger.minor(this, "Restarting "+identifier);
ClientRequest[] clientRequests = fcp.getGlobalRequests();
for (int requestIndex = 0, requestCount = clientRequests.length; requestIndex < requestCount; requestIndex++) {
ClientRequest clientRequest = clientRequests[requestIndex];
if (clientRequest.getIdentifier().equals(identifier)) {
clientRequest.restartAsync();
}
}
fcp.forceStorePersistentRequests();
writePermanentRedirect(ctx, "Done", "/queue/");
return;
} else if(request.isPartSet("remove_AllRequests") && (request.getPartAsString("remove_AllRequests", 32).length() > 0)) {
ClientRequest[] reqs = fcp.getGlobalRequests();
if(logMINOR) Logger.minor(this, "Request count: "+reqs.length);
StringBuffer failedIdentifiers = new StringBuffer();
for(int i=0; i<reqs.length ; i++){
String identifier = reqs[i].getIdentifier();
if(logMINOR) Logger.minor(this, "Removing "+identifier);
try {
fcp.removeGlobalRequest(identifier);
} catch (MessageInvalidException e) {
failedIdentifiers.append(identifier + ' ' + e.getMessage() + ';');
Logger.error(this, "Failed to remove " + identifier + ':' + e.getMessage());
continue;
}
}
if(failedIdentifiers.length() > 0)
this.sendErrorPage(ctx, 200,
L10n.getString("QueueToadlet.failedToRemoveRequest"),
L10n.getString("QueueToadlet.failedToRemoveId",
new String[]{ "id" },
new String[]{ failedIdentifiers.toString() }
));
else
writePermanentRedirect(ctx, "Done", "/queue/");
fcp.forceStorePersistentRequests();
return;
}else if(request.isPartSet("download")) {
// Queue a download
if(!request.isPartSet("key")) {
writeError(L10n.getString("QueueToadlet.errorNoKey"), L10n.getString("QueueToadlet.errorNoKeyToD"), ctx);
return;
}
String expectedMIMEType = null;
if(request.isPartSet("type")) {
expectedMIMEType = request.getPartAsString("type", MAX_TYPE_LENGTH);
}
FreenetURI fetchURI;
try {
fetchURI = new FreenetURI(request.getPartAsString("key", MAX_KEY_LENGTH));
} catch (MalformedURLException e) {
writeError(L10n.getString("QueueToadlet.errorInvalidURI"), L10n.getString("QueueToadlet.errorInvalidURIToD"), ctx);
return;
}
String persistence = request.getPartAsString("persistence", 32);
String returnType = request.getPartAsString("return-type", 32);
try {
fcp.makePersistentGlobalRequest(fetchURI, expectedMIMEType, persistence, returnType);
} catch (NotAllowedException e) {
this.writeError(L10n.getString("QueueToadlet.errorDToDisk"), L10n.getString("QueueToadlet.errorDToDiskConfig"), ctx);
return;
}
writePermanentRedirect(ctx, "Done", "/queue/");
return;
}else if(request.isPartSet("bulkDownloads")) {
String bulkDownloadsAsString = request.getPartAsString("bulkDownloads", Integer.MAX_VALUE);
String[] keys = bulkDownloadsAsString.split("\n");
if(("".equals(bulkDownloadsAsString)) || (keys.length < 1)) {
writePermanentRedirect(ctx, "Done", "/queue/");
return;
}
LinkedList success = new LinkedList(), failure = new LinkedList();
for(int i=0; i<keys.length; i++) {
String currentKey = keys[i];
try {
FreenetURI fetchURI = new FreenetURI(currentKey);
fcp.makePersistentGlobalRequest(fetchURI, null, "forever", "disk");
success.add(currentKey);
} catch (Exception e) {
failure.add(currentKey);
Logger.error(this, "An error occured while attempting to download key("+i+") : "+currentKey+ " : "+e.getMessage());
}
}
boolean displayFailureBox = failure.size() > 0;
boolean displaySuccessBox = success.size() > 0;
HTMLNode pageNode = ctx.getPageMaker().getPageNode(L10n.getString("QueueToadlet.downloadFiles"), ctx);
HTMLNode contentNode = ctx.getPageMaker().getContentNode(pageNode);
HTMLNode alertNode = contentNode.addChild(ctx.getPageMaker().getInfobox((displayFailureBox ? "infobox-warning" : "infobox-info"), L10n.getString("QueueToadlet.downloadFiles")));
HTMLNode alertContent = ctx.getPageMaker().getContentNode(alertNode);
Iterator it;
if(displaySuccessBox) {
HTMLNode successDiv = alertContent.addChild("ul");
successDiv.addChild("#", L10n.getString("QueueToadlet.enqueuedSuccessfully", "number", String.valueOf(success.size())));
it = success.iterator();
while(it.hasNext()) {
HTMLNode line = successDiv.addChild("li");
line.addChild("#", (String) it.next());
}
successDiv.addChild("br");
}
if(displayFailureBox) {
HTMLNode failureDiv = alertContent.addChild("ul");
if(displayFailureBox) {
failureDiv.addChild("#", L10n.getString("QueueToadlet.enqueuedFailure", "number", String.valueOf(failure.size())));
it = failure.iterator();
while(it.hasNext()) {
HTMLNode line = failureDiv.addChild("li");
line.addChild("#", (String) it.next());
}
}
failureDiv.addChild("br");
}
alertContent.addChild("a", "href", "/queue/", L10n.getString("Toadlet.returnToQueuepage"));
writeHTMLReply(ctx, 200, "OK", pageNode.generate());
return;
} else if (request.isPartSet("change_priority")) {
String identifier = request.getPartAsString("identifier", MAX_IDENTIFIER_LENGTH);
short newPriority = Short.parseShort(request.getPartAsString("priority", 32));
ClientRequest[] clientRequests = fcp.getGlobalRequests();
loop: for (int requestIndex = 0, requestCount = clientRequests.length; requestIndex < requestCount; requestIndex++) {
ClientRequest clientRequest = clientRequests[requestIndex];
if (clientRequest.getIdentifier().equals(identifier)) {
clientRequest.modifyRequest(null, newPriority); // no new ClientToken
break loop;
}
}
writePermanentRedirect(ctx, "Done", "/queue/");
fcp.forceStorePersistentRequests();
return;
} else if (request.getPartAsString("insert", 128).length() > 0) {
FreenetURI insertURI;
String keyType = request.getPartAsString("keytype", 3);
if ("chk".equals(keyType)) {
insertURI = new FreenetURI("CHK@");
} else {
try {
String u = request.getPartAsString("key", 128);
insertURI = new FreenetURI(u);
if(logMINOR)
Logger.minor(this, "Inserting key: "+insertURI+" ("+u+")");
} catch (MalformedURLException mue1) {
writeError(L10n.getString("QueueToadlet.errorInvalidURI"), L10n.getString("QueueToadlet.errorInvalidURIToU"), ctx);
return;
}
}
HTTPUploadedFile file = request.getUploadedFile("filename");
if (file == null || file.getFilename().trim().length() == 0) {
writeError(L10n.getString("QueueToadlet.errorNoFileSelected"), L10n.getString("QueueToadlet.errorNoFileSelectedU"), ctx);
return;
}
boolean compress = request.getPartAsString("compress", 128).length() > 0;
String identifier = file.getFilename() + "-fred-" + System.currentTimeMillis();
String fnam;
if(insertURI.getKeyType().equals("CHK"))
fnam = file.getFilename();
else
fnam = null;
/* copy bucket data */
Bucket copiedBucket = core.persistentTempBucketFactory.makeBucket(file.getData().size());
BucketTools.copy(file.getData(), copiedBucket);
try {
ClientPut clientPut = new ClientPut(fcp.getGlobalClient(), insertURI, identifier, Integer.MAX_VALUE, RequestStarter.BULK_SPLITFILE_PRIORITY_CLASS, ClientRequest.PERSIST_FOREVER, null, false, !compress, -1, ClientPutMessage.UPLOAD_FROM_DIRECT, null, file.getContentType(), copiedBucket, null, fnam, false);
clientPut.start();
fcp.forceStorePersistentRequests();
} catch (IdentifierCollisionException e) {
e.printStackTrace();
} catch (NotAllowedException e) {
this.writeError(L10n.getString("QueueToadlet.errorAccessDenied"), L10n.getString("QueueToadlet.errorAccessDeniedFile", new String[]{ "file" }, new String[]{ file.getFilename() }), ctx);
return;
} catch (FileNotFoundException e) {
this.writeError(L10n.getString("QueueToadlet.errorNoFileOrCannotRead"), L10n.getString("QueueToadlet.errorAccessDeniedFile", new String[]{ "file" }, new String[]{ file.getFilename() }), ctx);
return;
} catch (MalformedURLException mue1) {
writeError(L10n.getString("QueueToadlet.errorInvalidURI"), L10n.getString("QueueToadlet.errorInvalidURIToU"), ctx);
return;
}
writePermanentRedirect(ctx, "Done", "/queue/");
return;
} else if (request.isPartSet("insert-local-file")) {
String filename = request.getPartAsString("filename", MAX_FILENAME_LENGTH);
if(logMINOR) Logger.minor(this, "Inserting local file: "+filename);
File file = new File(filename);
String identifier = file.getName() + "-fred-" + System.currentTimeMillis();
String contentType = DefaultMIMETypes.guessMIMEType(filename, false);
FreenetURI furi = new FreenetURI("CHK@");
String key = request.getPartAsString("key", 128);
if(key != null) {
try {
furi = new FreenetURI(key);
} catch (MalformedURLException e) {
writeError(L10n.getString("QueueToadlet.errorInvalidURI"), L10n.getString("QueueToadlet.errorInvalidURIToU"), ctx);
return;
}
}
String target = file.getName();
if(!furi.getKeyType().equals("CHK"))
target = null;
try {
ClientPut clientPut = new ClientPut(fcp.getGlobalClient(), furi, identifier, Integer.MAX_VALUE, RequestStarter.BULK_SPLITFILE_PRIORITY_CLASS, ClientRequest.PERSIST_FOREVER, null, false, false, -1, ClientPutMessage.UPLOAD_FROM_DISK, file, contentType, new FileBucket(file, true, false, false, false, false), null, target, false);
if(logMINOR) Logger.minor(this, "Started global request to insert "+file+" to CHK@ as "+identifier);
clientPut.start();
fcp.forceStorePersistentRequests();
} catch (IdentifierCollisionException e) {
e.printStackTrace();
} catch (MalformedURLException e) {
writeError(L10n.getString("QueueToadlet.errorInvalidURI"), L10n.getString("QueueToadlet.errorInvalidURIToU"), ctx);
return;
} catch (FileNotFoundException e) {
this.writeError(L10n.getString("QueueToadlet.errorNoFileOrCannotRead"), L10n.getString("QueueToadlet.errorAccessDeniedFile", new String[]{ "file" }, new String[]{ target }), ctx);
return;
} catch (NotAllowedException e) {
this.writeError(L10n.getString("QueueToadlet.errorAccessDenied"), L10n.getString("QueueToadlet.errorAccessDeniedFile", new String[]{ "file" }, new String[]{ file.getName() }), ctx);
return;
}
writePermanentRedirect(ctx, "Done", "/queue/");
return;
} else if (request.isPartSet("insert-local-dir")) {
String filename = request.getPartAsString("filename", MAX_FILENAME_LENGTH);
if(logMINOR) Logger.minor(this, "Inserting local directory: "+filename);
File file = new File(filename);
String identifier = file.getName() + "-fred-" + System.currentTimeMillis();
FreenetURI furi = new FreenetURI("CHK@");
String key = request.getPartAsString("key", 128);
if(key != null) {
try {
furi = new FreenetURI(key);
} catch (MalformedURLException e) {
writeError(L10n.getString("QueueToadlet.errorInvalidURI"), L10n.getString("QueueToadlet.errorInvalidURIToU"), ctx);
return;
}
}
try {
ClientPutDir clientPutDir = new ClientPutDir(fcp.getGlobalClient(), furi, identifier, Integer.MAX_VALUE, RequestStarter.BULK_SPLITFILE_PRIORITY_CLASS, ClientRequest.PERSIST_FOREVER, null, false, false, -1, file, null, false, true, false);
if(logMINOR) Logger.minor(this, "Started global request to insert dir "+file+" to "+furi+" as "+identifier);
clientPutDir.start();
fcp.forceStorePersistentRequests();
} catch (IdentifierCollisionException e) {
e.printStackTrace();
} catch (MalformedURLException e) {
writeError(L10n.getString("QueueToadlet.errorInvalidURI"), L10n.getString("QueueToadlet.errorInvalidURIToU"), ctx);
return;
} catch (FileNotFoundException e) {
this.writeError(L10n.getString("QueueToadlet.errorNoFileOrCannotRead"), L10n.getString("QueueToadlet.errorAccessDeniedFile", new String[]{ "file" }, new String[]{ file.toString() }), ctx);
return;
}
writePermanentRedirect(ctx, "Done", "/queue/");
return;
} else if (request.isPartSet("get")) {
String identifier = request.getPartAsString("identifier", MAX_IDENTIFIER_LENGTH);
ClientRequest[] clientRequests = fcp.getGlobalRequests();
loop: for (int requestIndex = 0, requestCount = clientRequests.length; requestIndex < requestCount; requestIndex++) {
ClientRequest clientRequest = clientRequests[requestIndex];
if (clientRequest.getIdentifier().equals(identifier)) {
if (clientRequest instanceof ClientGet) {
ClientGet clientGet = (ClientGet) clientRequest;
if (clientGet.hasSucceeded()) {
Bucket dataBucket = clientGet.getBucket();
if (dataBucket != null) {
String forceDownload = request.getPartAsString("forceDownload", 32);
if (forceDownload.length() > 0) {
long forceDownloadTime = Long.parseLong(forceDownload);
if ((System.currentTimeMillis() - forceDownloadTime) > 60 * 1000) {
break loop;
}
MultiValueTable responseHeaders = new MultiValueTable();
responseHeaders.put("Content-Disposition", "attachment; filename=\"" + clientGet.getURI().getPreferredFilename() + '"');
writeReply(ctx, 200, "application/x-msdownload", "OK", responseHeaders, dataBucket);
return;
}
HTMLNode pageNode = ctx.getPageMaker().getPageNode(L10n.getString("QueueToadlet.warningUnsafeContent"), ctx);
HTMLNode contentNode = ctx.getPageMaker().getContentNode(pageNode);
HTMLNode alertNode = contentNode.addChild(ctx.getPageMaker().getInfobox("infobox-alert", L10n.getString("QueueToadlet.warningUnsafeContent")));
HTMLNode alertContent = ctx.getPageMaker().getContentNode(alertNode);
alertContent.addChild("#", L10n.getString("QueueToadlet.warningUnsafeContentExplanation"));
HTMLNode optionListNode = alertContent.addChild("ul");
HTMLNode optionForm = ctx.addFormChild(optionListNode, "/queue/", "queueDownloadNotFilteredConfirmForm-" + identifier.hashCode());
optionForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "hidden", "identifier", identifier });
optionForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "hidden", "forceDownload", String.valueOf(System.currentTimeMillis()) });
optionForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "get", "Download anyway" });
optionForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "return", "Return to queue page" });
writeHTMLReply(ctx, 200, "OK", pageNode.generate());
return;
}
}
writeError(L10n.getString("QueueToadlet.errorDownloadNotCompleted"), L10n.getString("QueueToadlet.errorDownloadNotCompleted"), ctx);
return;
}
}
}
writeError(L10n.getString("QueueToadlet.errorDownloadNotFound"), L10n.getString("QueueToadlet.errorDownloadNotFoundExplanation"), ctx);
return;
}
} finally {
request.freeParts();
}
this.handleGet(uri, new HTTPRequestImpl(uri), ctx);
}
private void writeError(String header, String message, ToadletContext context) throws ToadletContextClosedException, IOException {
writeError(header, message, context, true);
}
private void writeError(String header, String message, ToadletContext context, boolean returnToQueuePage) throws ToadletContextClosedException, IOException {
PageMaker pageMaker = context.getPageMaker();
HTMLNode pageNode = pageMaker.getPageNode(header, context);
HTMLNode contentNode = pageMaker.getContentNode(pageNode);
if(context.isAllowedFullAccess())
contentNode.addChild(core.alerts.createSummary());
HTMLNode infobox = contentNode.addChild(pageMaker.getInfobox("infobox-error", header));
HTMLNode infoboxContent = pageMaker.getContentNode(infobox);
infoboxContent.addChild("#", message);
if(returnToQueuePage)
infoboxContent.addChild("div").addChildren(new HTMLNode[] { new HTMLNode("#", "Return to "), new HTMLNode("a", "href", "/queue/", "queue page"), new HTMLNode("#", ".") });
writeHTMLReply(context, 400, "Bad request", pageNode.generate());
}
public void handleGet(URI uri, final HTTPRequest request, ToadletContext ctx)
throws ToadletContextClosedException, IOException, RedirectException {
// We ensure that we have a FCP server running
if(!fcp.enabled){
writeError(L10n.getString("QueueToadlet.fcpIsMissing"), L10n.getString("QueueToadlet.pleaseEnableFCP"), ctx, false);
return;
}
if(!core.hasLoadedQueue()) {
writeError(L10n.getString("QueueToadlet.notLoadedYetTitle"), L10n.getString("QueueToadlet.notLoadedYet"), ctx, false);
return;
}
final String requestPath = request.getPath().substring("/queue/".length());
if (requestPath.length() > 0) {
/* okay, there is something in the path, check it. */
try {
FreenetURI key = new FreenetURI(requestPath);
/* locate request */
ClientRequest[] clientRequests = fcp.getGlobalRequests();
for (int requestIndex = 0, requestCount = clientRequests.length; requestIndex < requestCount; requestIndex++) {
ClientRequest clientRequest = clientRequests[requestIndex];
if (clientRequest.hasFinished() && (clientRequest instanceof ClientGet)) {
ClientGet clientGet = (ClientGet) clientRequest;
if (clientGet.getURI().equals(key)) {
Bucket data = clientGet.getBucket();
String mimeType = clientGet.getMIMEType();
String requestedMimeType = request.getParam("type", null);
String forceString = request.getParam("force");
FProxyToadlet.handleDownload(ctx, data, ctx.getBucketFactory(), mimeType, requestedMimeType, forceString, request.isParameterSet("forcedownload"), "/queue/", key, "", "/queue/", false, ctx, core);
return;
}
}
}
} catch (MalformedURLException mue1) {
}
return;
}
PageMaker pageMaker = ctx.getPageMaker();
// First, get the queued requests, and separate them into different types.
LinkedList completedDownloadToDisk = new LinkedList();
LinkedList completedDownloadToTemp = new LinkedList();
LinkedList completedUpload = new LinkedList();
LinkedList completedDirUpload = new LinkedList();
LinkedList failedDownload = new LinkedList();
LinkedList failedUpload = new LinkedList();
LinkedList failedDirUpload = new LinkedList();
LinkedList uncompletedDownload = new LinkedList();
LinkedList uncompletedUpload = new LinkedList();
LinkedList uncompletedDirUpload = new LinkedList();
ClientRequest[] reqs = fcp.getGlobalRequests();
if(Logger.shouldLog(Logger.MINOR, this))
Logger.minor(this, "Request count: "+reqs.length);
if(reqs.length < 1){
HTMLNode pageNode = pageMaker.getPageNode(L10n.getString("QueueToadlet.title", new String[]{ "nodeName" }, new String[]{ core.getMyName() }), ctx);
HTMLNode contentNode = pageMaker.getContentNode(pageNode);
/* add alert summary box */
if(ctx.isAllowedFullAccess())
contentNode.addChild(core.alerts.createSummary());
HTMLNode infobox = contentNode.addChild(pageMaker.getInfobox("infobox-information", L10n.getString("QueueToadlet.globalQueueIsEmpty")));
HTMLNode infoboxContent = pageMaker.getContentNode(infobox);
infoboxContent.addChild("#", L10n.getString("QueueToadlet.noTaskOnGlobalQueue"));
contentNode.addChild(createInsertBox(pageMaker, ctx, core.isAdvancedModeEnabled()));
contentNode.addChild(createBulkDownloadForm(ctx, pageMaker));
writeHTMLReply(ctx, 200, "OK", pageNode.generate());
return;
}
short lowestQueuedPrio = RequestStarter.MINIMUM_PRIORITY_CLASS;
for(int i=0;i<reqs.length;i++) {
ClientRequest req = reqs[i];
if(req instanceof ClientGet) {
ClientGet cg = (ClientGet) req;
if(cg.hasSucceeded()) {
if(cg.isDirect())
completedDownloadToTemp.add(cg);
else if(cg.isToDisk())
completedDownloadToDisk.add(cg);
else
// FIXME
Logger.error(this, "Don't know what to do with "+cg);
} else if(cg.hasFinished()) {
failedDownload.add(cg);
} else {
short prio = cg.getPriority();
if(prio < lowestQueuedPrio)
lowestQueuedPrio = prio;
uncompletedDownload.add(cg);
}
} else if(req instanceof ClientPut) {
ClientPut cp = (ClientPut) req;
if(cp.hasSucceeded()) {
completedUpload.add(cp);
} else if(cp.hasFinished()) {
failedUpload.add(cp);
} else {
short prio = req.getPriority();
if(prio < lowestQueuedPrio)
lowestQueuedPrio = prio;
uncompletedUpload.add(cp);
}
} else if(req instanceof ClientPutDir) {
ClientPutDir cp = (ClientPutDir) req;
if(cp.hasSucceeded()) {
completedDirUpload.add(cp);
} else if(cp.hasFinished()) {
failedDirUpload.add(cp);
} else {
short prio = req.getPriority();
if(prio < lowestQueuedPrio)
lowestQueuedPrio = prio;
uncompletedDirUpload.add(cp);
}
}
}
Comparator jobComparator = new Comparator() {
public int compare(Object first, Object second) {
ClientRequest firstRequest = (ClientRequest) first;
ClientRequest secondRequest = (ClientRequest) second;
int result = 0;
boolean isSet = true;
if(request.isParameterSet("sortBy")){
final String sortBy = request.getParam("sortBy");
if(sortBy.equals("id")){
result = firstRequest.getIdentifier().compareToIgnoreCase(secondRequest.getIdentifier());
}else if(sortBy.equals("size")){
result = (firstRequest.getTotalBlocks() - secondRequest.getTotalBlocks()) < 0 ? -1 : 1;
}else if(sortBy.equals("progress")){
result = firstRequest.getSuccessFraction() - secondRequest.getSuccessFraction() < 0 ? -1 : 1;
}else
isSet=false;
}else
isSet=false;
if(!isSet){
int priorityDifference = firstRequest.getPriority() - secondRequest.getPriority();
if (priorityDifference != 0)
result = (priorityDifference < 0 ? -1 : 1);
else
result = firstRequest.getIdentifier().compareTo(secondRequest.getIdentifier());
}
if(result == 0){
return 0;
}else if(request.isParameterSet("reversed")){
isReversed = true;
return result > 0 ? -1 : 1;
}else{
isReversed = false;
return result < 0 ? -1 : 1;
}
}
};
Collections.sort(completedDownloadToDisk, jobComparator);
Collections.sort(completedDownloadToTemp, jobComparator);
Collections.sort(completedUpload, jobComparator);
Collections.sort(completedDirUpload, jobComparator);
Collections.sort(failedDownload, jobComparator);
Collections.sort(failedUpload, jobComparator);
Collections.sort(failedDirUpload, jobComparator);
Collections.sort(uncompletedDownload, jobComparator);
Collections.sort(uncompletedUpload, jobComparator);
Collections.sort(uncompletedDirUpload, jobComparator);
HTMLNode pageNode = pageMaker.getPageNode("(" + (uncompletedDirUpload.size() + uncompletedDownload.size()
+ uncompletedUpload.size()) + '/' + (failedDirUpload.size() + failedDownload.size() + failedUpload.size()) + '/'
+ (completedDirUpload.size() + completedDownloadToDisk.size() + completedDownloadToTemp.size()
+ completedUpload.size()) + ") " +
L10n.getString("QueueToadlet.title", new String[]{ "nodeName" }, new String[]{ core.getMyName() }), ctx);
HTMLNode contentNode = pageMaker.getContentNode(pageNode);
/* add alert summary box */
if(ctx.isAllowedFullAccess())
contentNode.addChild(core.alerts.createSummary());
final int mode = pageMaker.drawModeSelectionArray(core, request, contentNode);
/* add file insert box */
contentNode.addChild(createInsertBox(pageMaker, ctx, mode >= PageMaker.MODE_ADVANCED));
/* navigation bar */
HTMLNode navigationBar = pageMaker.getInfobox("navbar", L10n.getString("QueueToadlet.requestNavigation"));
HTMLNode navigationContent = pageMaker.getContentNode(navigationBar).addChild("ul");
boolean includeNavigationBar = false;
if (!completedDownloadToTemp.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#completedDownloadToTemp", L10n.getString("QueueToadlet.completedDtoTemp", new String[]{ "size" }, new String[]{ String.valueOf(completedDownloadToTemp.size()) }));
includeNavigationBar = true;
}
if (!completedDownloadToDisk.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#completedDownloadToDisk", L10n.getString("QueueToadlet.completedDtoDisk", new String[]{ "size" }, new String[]{ String.valueOf(completedDownloadToDisk.size()) }));
includeNavigationBar = true;
}
if (!completedUpload.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#completedUpload", L10n.getString("QueueToadlet.completedU", new String[]{ "size" }, new String[]{ String.valueOf(completedUpload.size()) }));
includeNavigationBar = true;
}
if (!completedDirUpload.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#completedDirUpload", L10n.getString("QueueToadlet.completedDU", new String[]{ "size" }, new String[]{ String.valueOf(completedDirUpload.size()) }));
includeNavigationBar = true;
}
if (!failedDownload.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#failedDownload", L10n.getString("QueueToadlet.failedD", new String[]{ "size" }, new String[]{ String.valueOf(failedDownload.size()) }));
includeNavigationBar = true;
}
if (!failedUpload.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#failedUpload", L10n.getString("QueueToadlet.failedU", new String[]{ "size" }, new String[]{ String.valueOf(failedUpload.size()) }));
includeNavigationBar = true;
}
if (!failedDirUpload.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#failedDirUpload", L10n.getString("QueueToadlet.failedDU", new String[]{ "size" }, new String[]{ String.valueOf(failedDirUpload.size()) }));
includeNavigationBar = true;
}
if (!uncompletedDownload.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#uncompletedDownload", L10n.getString("QueueToadlet.DinProgress", new String[]{ "size" }, new String[]{ String.valueOf(uncompletedDownload.size()) }));
includeNavigationBar = true;
}
if (!uncompletedUpload.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#uncompletedUpload", L10n.getString("QueueToadlet.UinProgress", new String[]{ "size" }, new String[]{ String.valueOf(uncompletedUpload.size()) }));
includeNavigationBar = true;
}
if (!uncompletedDirUpload.isEmpty()) {
navigationContent.addChild("li").addChild("a", "href", "#uncompletedDirUpload", L10n.getString("QueueToadlet.DUinProgress", new String[]{ "size" }, new String[]{ String.valueOf(uncompletedDirUpload.size()) }));
includeNavigationBar = true;
}
if (includeNavigationBar) {
contentNode.addChild(navigationBar);
}
final String[] priorityClasses = new String[] {
L10n.getString("QueueToadlet.priority0"),
L10n.getString("QueueToadlet.priority1"),
L10n.getString("QueueToadlet.priority2"),
L10n.getString("QueueToadlet.priority3"),
L10n.getString("QueueToadlet.priority4"),
L10n.getString("QueueToadlet.priority5"),
L10n.getString("QueueToadlet.priority6")
};
boolean advancedModeEnabled = (mode >= PageMaker.MODE_ADVANCED);
HTMLNode legendBox = contentNode.addChild(pageMaker.getInfobox("legend", L10n.getString("QueueToadlet.legend")));
HTMLNode legendContent = pageMaker.getContentNode(legendBox);
HTMLNode legendTable = legendContent.addChild("table", "class", "queue");
HTMLNode legendRow = legendTable.addChild("tr");
for(int i=0; i<7; i++){
if(i > RequestStarter.INTERACTIVE_PRIORITY_CLASS || advancedModeEnabled || i <= lowestQueuedPrio)
legendRow.addChild("td", "class", "priority" + i, priorityClasses[i]);
}
if (reqs.length > 1 && SimpleToadletServer.isPanicButtonToBeShown) {
contentNode.addChild(createPanicBox(pageMaker, ctx));
}
if (!completedDownloadToTemp.isEmpty()) {
contentNode.addChild("a", "id", "completedDownloadToTemp");
HTMLNode completedDownloadsTempInfobox = contentNode.addChild(pageMaker.getInfobox("completed_requests", L10n.getString("QueueToadlet.completedDinTempDirectory", new String[]{ "size" }, new String[]{ String.valueOf(completedDownloadToTemp.size()) })));
HTMLNode completedDownloadsToTempContent = pageMaker.getContentNode(completedDownloadsTempInfobox);
if (advancedModeEnabled) {
completedDownloadsToTempContent.addChild(createRequestTable(pageMaker, ctx, completedDownloadToTemp, new int[] { LIST_IDENTIFIER, LIST_SIZE, LIST_MIME_TYPE, LIST_DOWNLOAD, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, false));
} else {
completedDownloadsToTempContent.addChild(createRequestTable(pageMaker, ctx, completedDownloadToTemp, new int[] { LIST_SIZE, LIST_MIME_TYPE, LIST_DOWNLOAD, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, false));
}
}
if (!completedDownloadToDisk.isEmpty()) {
contentNode.addChild("a", "id", "completedDownloadToDisk");
HTMLNode completedToDiskInfobox = contentNode.addChild(pageMaker.getInfobox("completed_requests", L10n.getString("QueueToadlet.completedDinDownloadDirectory", new String[]{ "size" }, new String[]{ String.valueOf(completedDownloadToDisk.size()) })));
HTMLNode completedToDiskInfoboxContent = pageMaker.getContentNode(completedToDiskInfobox);
if (advancedModeEnabled) {
completedToDiskInfoboxContent.addChild(createRequestTable(pageMaker, ctx, completedDownloadToDisk, new int[] { LIST_IDENTIFIER, LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_DOWNLOAD, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, false));
} else {
completedToDiskInfoboxContent.addChild(createRequestTable(pageMaker, ctx, completedDownloadToDisk, new int[] { LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_DOWNLOAD, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, false));
}
}
if (!completedUpload.isEmpty()) {
contentNode.addChild("a", "id", "completedUpload");
HTMLNode completedUploadInfobox = contentNode.addChild(pageMaker.getInfobox("completed_requests", L10n.getString("QueueToadlet.completedU", new String[]{ "size" }, new String[]{ String.valueOf(completedUpload.size()) })));
HTMLNode completedUploadInfoboxContent = pageMaker.getContentNode(completedUploadInfobox);
if (advancedModeEnabled) {
completedUploadInfoboxContent.addChild(createRequestTable(pageMaker, ctx, completedUpload, new int[] { LIST_IDENTIFIER, LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
} else {
completedUploadInfoboxContent.addChild(createRequestTable(pageMaker, ctx, completedUpload, new int[] { LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
}
}
if (!completedDirUpload.isEmpty()) {
contentNode.addChild("a", "id", "completedDirUpload");
HTMLNode completedUploadDirInfobox = contentNode.addChild(pageMaker.getInfobox("completed_requests", L10n.getString("QueueToadlet.completedUDirectory", new String[]{ "size" }, new String[]{ String.valueOf(completedDirUpload.size()) })));
HTMLNode completedUploadDirContent = pageMaker.getContentNode(completedUploadDirInfobox);
if (advancedModeEnabled) {
completedUploadDirContent.addChild(createRequestTable(pageMaker, ctx, completedDirUpload, new int[] { LIST_IDENTIFIER, LIST_FILES, LIST_TOTAL_SIZE, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
} else {
completedUploadDirContent.addChild(createRequestTable(pageMaker, ctx, completedDirUpload, new int[] { LIST_FILES, LIST_TOTAL_SIZE, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
}
}
if (!failedDownload.isEmpty()) {
contentNode.addChild("a", "id", "failedDownload");
HTMLNode failedInfobox = contentNode.addChild(pageMaker.getInfobox("failed_requests", L10n.getString("QueueToadlet.failedD", new String[]{ "size" }, new String[]{ String.valueOf(failedDownload.size()) })));
HTMLNode failedContent = pageMaker.getContentNode(failedInfobox);
if (advancedModeEnabled) {
failedContent.addChild(createRequestTable(pageMaker, ctx, failedDownload, new int[] { LIST_IDENTIFIER, LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_PROGRESS, LIST_REASON, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, false));
} else {
failedContent.addChild(createRequestTable(pageMaker, ctx, failedDownload, new int[] { LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_PROGRESS, LIST_REASON, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, false));
}
}
if (!failedUpload.isEmpty()) {
contentNode.addChild("a", "id", "failedUpload");
HTMLNode failedInfobox = contentNode.addChild(pageMaker.getInfobox("failed_requests", L10n.getString("QueueToadlet.failedU", new String[]{ "size" }, new String[]{ String.valueOf(failedUpload.size()) })));
HTMLNode failedContent = pageMaker.getContentNode(failedInfobox);
if (advancedModeEnabled) {
failedContent.addChild(createRequestTable(pageMaker, ctx, failedUpload, new int[] { LIST_IDENTIFIER, LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_PROGRESS, LIST_REASON, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
} else {
failedContent.addChild(createRequestTable(pageMaker, ctx, failedUpload, new int[] { LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_PROGRESS, LIST_REASON, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
}
}
if (!failedDirUpload.isEmpty()) {
contentNode.addChild("a", "id", "failedDirUpload");
HTMLNode failedInfobox = contentNode.addChild(pageMaker.getInfobox("failed_requests", L10n.getString("QueueToadlet.failedU", new String[]{ "size" }, new String[]{ String.valueOf(failedDirUpload.size()) })));
HTMLNode failedContent = pageMaker.getContentNode(failedInfobox);
if (advancedModeEnabled) {
failedContent.addChild(createRequestTable(pageMaker, ctx, failedDirUpload, new int[] { LIST_IDENTIFIER, LIST_FILES, LIST_TOTAL_SIZE, LIST_PROGRESS, LIST_REASON, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
} else {
failedContent.addChild(createRequestTable(pageMaker, ctx, failedDirUpload, new int[] { LIST_FILES, LIST_TOTAL_SIZE, LIST_PROGRESS, LIST_REASON, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
}
}
if (!uncompletedDownload.isEmpty()) {
contentNode.addChild("a", "id", "uncompletedDownload");
HTMLNode uncompletedInfobox = contentNode.addChild(pageMaker.getInfobox("requests_in_progress", L10n.getString("QueueToadlet.wipD", new String[]{ "size" }, new String[]{ String.valueOf(uncompletedDownload.size()) })));
HTMLNode uncompletedContent = pageMaker.getContentNode(uncompletedInfobox);
if (advancedModeEnabled) {
uncompletedContent.addChild(createRequestTable(pageMaker, ctx, uncompletedDownload, new int[] { LIST_IDENTIFIER, LIST_PRIORITY, LIST_SIZE, LIST_MIME_TYPE, LIST_PROGRESS, LIST_PERSISTENCE, LIST_FILENAME, LIST_KEY }, priorityClasses, advancedModeEnabled, false));
} else {
uncompletedContent.addChild(createRequestTable(pageMaker, ctx, uncompletedDownload, new int[] { LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_PROGRESS, LIST_PRIORITY, LIST_KEY, LIST_PERSISTENCE }, priorityClasses, advancedModeEnabled, false));
}
}
if (!uncompletedUpload.isEmpty()) {
contentNode.addChild("a", "id", "uncompletedUpload");
HTMLNode uncompletedInfobox = contentNode.addChild(pageMaker.getInfobox("requests_in_progress", L10n.getString("QueueToadlet.wipU", new String[]{ "size" }, new String[]{ String.valueOf(uncompletedUpload.size()) })));
HTMLNode uncompletedContent = pageMaker.getContentNode(uncompletedInfobox);
if (advancedModeEnabled) {
uncompletedContent.addChild(createRequestTable(pageMaker, ctx, uncompletedUpload, new int[] { LIST_IDENTIFIER, LIST_PRIORITY, LIST_SIZE, LIST_MIME_TYPE, LIST_PROGRESS, LIST_PERSISTENCE, LIST_FILENAME, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
} else {
uncompletedContent.addChild(createRequestTable(pageMaker, ctx, uncompletedUpload, new int[] { LIST_FILENAME, LIST_SIZE, LIST_MIME_TYPE, LIST_PROGRESS, LIST_PRIORITY, LIST_KEY, LIST_PRIORITY, LIST_PERSISTENCE }, priorityClasses, advancedModeEnabled, true));
}
}
if (!uncompletedDirUpload.isEmpty()) {
contentNode.addChild("a", "id", "uncompletedDirUpload");
HTMLNode uncompletedInfobox = contentNode.addChild(pageMaker.getInfobox("requests_in_progress", L10n.getString("QueueToadlet.wipDU", new String[]{ "size" }, new String[]{ String.valueOf(uncompletedDirUpload.size()) })));
HTMLNode uncompletedContent = pageMaker.getContentNode(uncompletedInfobox);
if (advancedModeEnabled) {
uncompletedContent.addChild(createRequestTable(pageMaker, ctx, uncompletedDirUpload, new int[] { LIST_IDENTIFIER, LIST_FILES, LIST_PRIORITY, LIST_TOTAL_SIZE, LIST_PROGRESS, LIST_PERSISTENCE, LIST_KEY }, priorityClasses, advancedModeEnabled, true));
} else {
uncompletedContent.addChild(createRequestTable(pageMaker, ctx, uncompletedDirUpload, new int[] { LIST_FILES, LIST_TOTAL_SIZE, LIST_PROGRESS, LIST_PRIORITY, LIST_KEY, LIST_PERSISTENCE }, priorityClasses, advancedModeEnabled, true));
}
}
contentNode.addChild(createBulkDownloadForm(ctx, pageMaker));
MultiValueTable pageHeaders = new MultiValueTable();
writeHTMLReply(ctx, 200, "OK", pageHeaders, pageNode.generate());
}
private HTMLNode createReasonCell(String failureReason) {
HTMLNode reasonCell = new HTMLNode("td", "class", "request-reason");
if (failureReason == null) {
reasonCell.addChild("span", "class", "failure_reason_unknown", L10n.getString("QueueToadlet.unknown"));
} else {
reasonCell.addChild("span", "class", "failure_reason_is", failureReason);
}
return reasonCell;
}
private HTMLNode createProgressCell(boolean started, int fetched, int failed, int fatallyFailed, int min, int total, boolean finalized, boolean upload) {
HTMLNode progressCell = new HTMLNode("td", "class", "request-progress");
if (!started) {
progressCell.addChild("#", L10n.getString("QueueToadlet.starting"));
return progressCell;
}
//double frac = p.getSuccessFraction();
if (!core.isAdvancedModeEnabled()) {
total = min;
}
if ((fetched < 0) || (total <= 0)) {
progressCell.addChild("span", "class", "progress_fraction_unknown", L10n.getString("QueueToadlet.unknown"));
} else {
int fetchedPercent = (int) (fetched / (double) total * 100);
int failedPercent = (int) (failed / (double) total * 100);
int fatallyFailedPercent = (int) (fatallyFailed / (double) total * 100);
int minPercent = (int) (min / (double) total * 100);
HTMLNode progressBar = progressCell.addChild("div", "class", "progressbar");
progressBar.addChild("div", new String[] { "class", "style" }, new String[] { "progressbar-done", "width: " + fetchedPercent + "%;" });
if (failed > 0)
progressBar.addChild("div", new String[] { "class", "style" }, new String[] { "progressbar-failed", "width: " + failedPercent + "%;" });
if (fatallyFailed > 0)
progressBar.addChild("div", new String[] { "class", "style" }, new String[] { "progressbar-failed2", "width: " + fatallyFailedPercent + "%;" });
if ((fetched + failed + fatallyFailed) < min)
progressBar.addChild("div", new String[] { "class", "style" }, new String[] { "progressbar-min", "width: " + (minPercent - fetchedPercent) + "%;" });
NumberFormat nf = NumberFormat.getInstance();
nf.setMaximumFractionDigits(1);
String prefix = '('+Integer.toString(fetched) + "/ " + Integer.toString(min)+"): ";
if (finalized) {
progressBar.addChild("div", new String[] { "class", "title" }, new String[] { "progress_fraction_finalized", prefix + L10n.getString("QueueToadlet.progressbarAccurate") }, nf.format((int) ((fetched / (double) min) * 1000) / 10.0) + '%');
} else {
String text = nf.format((int) ((fetched / (double) min) * 1000) / 10.0)+ '%';
if(!finalized)
text = "" + fetched + " ("+text+"??)";
progressBar.addChild("div", new String[] { "class", "title" }, new String[] { "progress_fraction_not_finalized", prefix + L10n.getString(upload ? "QueueToadlet.uploadProgressbarNotAccurate" : "QueueToadlet.progressbarNotAccurate") }, text);
}
}
return progressCell;
}
private HTMLNode createNumberCell(int numberOfFiles) {
HTMLNode numberCell = new HTMLNode("td", "class", "request-files");
numberCell.addChild("span", "class", "number_of_files", String.valueOf(numberOfFiles));
return numberCell;
}
private HTMLNode createFilenameCell(File filename) {
HTMLNode filenameCell = new HTMLNode("td", "class", "request-filename");
if (filename != null) {
filenameCell.addChild("span", "class", "filename_is", filename.toString());
} else {
filenameCell.addChild("span", "class", "filename_none", L10n.getString("QueueToadlet.none"));
}
return filenameCell;
}
private HTMLNode createPriorityCell(PageMaker pageMaker, String identifier, short priorityClass, ToadletContext ctx, String[] priorityClasses, boolean advancedModeEnabled) {
HTMLNode priorityCell = new HTMLNode("td", "class", "request-priority nowrap");
HTMLNode priorityForm = ctx.addFormChild(priorityCell, "/queue/", "queueChangePriorityCell-" + identifier.hashCode());
priorityForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "hidden", "identifier", identifier });
HTMLNode prioritySelect = priorityForm.addChild("select", "name", "priority");
for (int p = 0; p < RequestStarter.NUMBER_OF_PRIORITY_CLASSES; p++) {
if(p <= RequestStarter.INTERACTIVE_PRIORITY_CLASS && !advancedModeEnabled) continue;
if (p == priorityClass) {
prioritySelect.addChild("option", new String[] { "value", "selected" }, new String[] { String.valueOf(p), "selected" }, priorityClasses[p]);
} else {
prioritySelect.addChild("option", "value", String.valueOf(p), priorityClasses[p]);
}
}
priorityForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "change_priority", L10n.getString("QueueToadlet.change") });
return priorityCell;
}
private HTMLNode createDeleteCell(PageMaker pageMaker, String identifier, ClientRequest clientRequest, ToadletContext ctx) {
HTMLNode deleteNode = new HTMLNode("td", "class", "request-delete");
HTMLNode deleteForm = ctx.addFormChild(deleteNode, "/queue/", "queueDeleteForm-" + identifier.hashCode());
deleteForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "hidden", "identifier", identifier });
deleteForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "remove_request", L10n.getString("QueueToadlet.remove") });
// If it's failed, offer to restart it
if(clientRequest.hasFinished() && !clientRequest.hasSucceeded() && clientRequest.canRestart()) {
HTMLNode retryForm = ctx.addFormChild(deleteNode, "/queue/", "queueRestartForm-" + identifier.hashCode());
String restartName = L10n.getString(clientRequest instanceof ClientGet && ((ClientGet)clientRequest).hasPermRedirect() ? "QueueToadlet.follow" : "QueueToadlet.restart");
retryForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "hidden", "identifier", identifier });
retryForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "restart_request", restartName });
}
return deleteNode;
}
private HTMLNode createPanicBox(PageMaker pageMaker, ToadletContext ctx) {
HTMLNode panicBox = pageMaker.getInfobox("infobox-alert", L10n.getString("QueueToadlet.panicButton"));
HTMLNode panicForm = ctx.addFormChild(pageMaker.getContentNode(panicBox), "/queue/", "queuePanicForm");
panicForm.addChild("#", (L10n.getString("QueueToadlet.panicButtonConfirmation") + ' '));
panicForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "remove_AllRequests", L10n.getString("QueueToadlet.remove") });
return panicBox;
}
private HTMLNode createIdentifierCell(FreenetURI uri, String identifier, boolean directory) {
HTMLNode identifierCell = new HTMLNode("td", "class", "request-identifier");
if (uri != null) {
identifierCell.addChild("span", "class", "identifier_with_uri").addChild("a", "href", "/" + uri + (directory ? "/" : ""), identifier);
} else {
identifierCell.addChild("span", "class", "identifier_without_uri", identifier);
}
return identifierCell;
}
private HTMLNode createPersistenceCell(boolean persistent, boolean persistentForever) {
HTMLNode persistenceCell = new HTMLNode("td", "class", "request-persistence");
if (persistentForever) {
persistenceCell.addChild("span", "class", "persistence_forever", L10n.getString("QueueToadlet.persistenceForever"));
} else if (persistent) {
persistenceCell.addChild("span", "class", "persistence_reboot", L10n.getString("QueueToadlet.persistenceReboot"));
} else {
persistenceCell.addChild("span", "class", "persistence_none", L10n.getString("QueueToadlet.persistenceNone"));
}
return persistenceCell;
}
private HTMLNode createDownloadCell(PageMaker pageMaker, ClientGet p) {
HTMLNode downloadCell = new HTMLNode("td", "class", "request-download");
downloadCell.addChild("a", "href", p.getURI().toString(), L10n.getString("QueueToadlet.download"));
return downloadCell;
}
private HTMLNode createTypeCell(String type) {
HTMLNode typeCell = new HTMLNode("td", "class", "request-type");
if (type != null) {
typeCell.addChild("span", "class", "mimetype_is", type);
} else {
typeCell.addChild("span", "class", "mimetype_unknown", L10n.getString("QueueToadlet.unknown"));
}
return typeCell;
}
private HTMLNode createSizeCell(long dataSize, boolean confirmed, boolean advancedModeEnabled) {
HTMLNode sizeCell = new HTMLNode("td", "class", "request-size");
if (dataSize > 0 && (confirmed || advancedModeEnabled)) {
sizeCell.addChild("span", "class", "filesize_is", (confirmed ? "" : ">= ") + SizeUtil.formatSize(dataSize) + (confirmed ? "" : " ??"));
} else {
sizeCell.addChild("span", "class", "filesize_unknown", L10n.getString("QueueToadlet.unknown"));
}
return sizeCell;
}
private HTMLNode createKeyCell(FreenetURI uri, boolean addSlash) {
HTMLNode keyCell = new HTMLNode("td", "class", "request-key");
if (uri != null) {
keyCell.addChild("span", "class", "key_is").addChild("a", "href", '/' + uri.toString() + (addSlash ? "/" : ""), uri.toShortString() + (addSlash ? "/" : ""));
} else {
keyCell.addChild("span", "class", "key_unknown", L10n.getString("QueueToadlet.unknown"));
}
return keyCell;
}
private HTMLNode createInsertBox(PageMaker pageMaker, ToadletContext ctx, boolean isAdvancedModeEnabled) {
/* the insert file box */
HTMLNode insertBox = pageMaker.getInfobox(L10n.getString("QueueToadlet.insertFile"));
HTMLNode insertContent = pageMaker.getContentNode(insertBox);
HTMLNode insertForm = ctx.addFormChild(insertContent, "/queue/", "queueInsertForm");
insertForm.addChild("#", (L10n.getString("QueueToadlet.insertAs") + ' '));
insertForm.addChild("input", new String[] { "type", "name", "value", "checked" }, new String[] { "radio", "keytype", "chk", "checked" });
insertForm.addChild("#", " CHK \u00a0 ");
insertForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "radio", "keytype", "ksk" });
insertForm.addChild("#", " KSK/SSK/USK \u00a0 ");
insertForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "text", "key", "KSK@" });
if(ctx.isAllowedFullAccess()) {
insertForm.addChild("#", " \u00a0 ");
insertForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "insert-local", L10n.getString("QueueToadlet.insertFileBrowseLabel") + "..." });
insertForm.addChild("br");
}
insertForm.addChild("#", L10n.getString("QueueToadlet.insertFileLabel") + ": ");
insertForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "file", "filename", "" });
insertForm.addChild("#", " \u00a0 ");
insertForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "insert", L10n.getString("QueueToadlet.insertFileInsertFileLabel") });
insertForm.addChild("#", " \u00a0 ");
if(isAdvancedModeEnabled) {
insertForm.addChild("input", new String[] { "type", "name", "checked" }, new String[] { "checkbox", "compress", "checked" });
insertForm.addChild("#", " " + L10n.getString("QueueToadlet.insertFileCompressLabel") + " \u00a0 ");
} else {
insertForm.addChild("input", new String[] { "type", "value" }, new String[] { "hidden", "true" });
}
insertForm.addChild("input", new String[] { "type", "name" }, new String[] { "reset", L10n.getString("QueueToadlet.insertFileResetForm") });
return insertBox;
}
private HTMLNode createBulkDownloadForm(ToadletContext ctx, PageMaker pageMaker) {
HTMLNode downloadBox = pageMaker.getInfobox(L10n.getString("QueueToadlet.downloadFiles"));
HTMLNode downloadBoxContent = pageMaker.getContentNode(downloadBox);
HTMLNode downloadForm = ctx.addFormChild(downloadBoxContent, "/queue/", "queueDownloadForm");
downloadForm.addChild("#", L10n.getString("QueueToadlet.downloadFilesInstructions"));
downloadForm.addChild("br");
downloadForm.addChild("textarea", new String[] { "id", "name", "cols", "rows" }, new String[] { "bulkDownloads", "bulkDownloads", "120", "8" });
downloadForm.addChild("br");
downloadForm.addChild("input", new String[] { "type", "name", "value" }, new String[] { "submit", "insert", L10n.getString("QueueToadlet.download") });
return downloadBox;
}
private HTMLNode createRequestTable(PageMaker pageMaker, ToadletContext ctx, List requests, int[] columns, String[] priorityClasses, boolean advancedModeEnabled, boolean isUpload) {
HTMLNode table = new HTMLNode("table", "class", "requests");
HTMLNode headerRow = table.addChild("tr", "class", "table-header");
headerRow.addChild("th");
for (int columnIndex = 0, columnCount = columns.length; columnIndex < columnCount; columnIndex++) {
int column = columns[columnIndex];
if (column == LIST_IDENTIFIER) {
headerRow.addChild("th").addChild("a", "href", (isReversed ? "?sortBy=id" : "?sortBy=id&reversed")).addChild("#", L10n.getString("QueueToadlet.identifier"));
} else if (column == LIST_SIZE) {
headerRow.addChild("th").addChild("a", "href", (isReversed ? "?sortBy=size" : "?sortBy=size&reversed")).addChild("#", L10n.getString("QueueToadlet.size"));
} else if (column == LIST_DOWNLOAD) {
headerRow.addChild("th", L10n.getString("QueueToadlet.download"));
} else if (column == LIST_MIME_TYPE) {
headerRow.addChild("th", L10n.getString("QueueToadlet.mimeType"));
} else if (column == LIST_PERSISTENCE) {
headerRow.addChild("th", L10n.getString("QueueToadlet.persistence"));
} else if (column == LIST_KEY) {
headerRow.addChild("th", L10n.getString("QueueToadlet.key"));
} else if (column == LIST_FILENAME) {
headerRow.addChild("th", L10n.getString("QueueToadlet.fileName"));
} else if (column == LIST_PRIORITY) {
headerRow.addChild("th").addChild("a", "href", (isReversed ? "?sortBy=priority" : "?sortBy=priority&reversed")).addChild("#", L10n.getString("QueueToadlet.priority"));
} else if (column == LIST_FILES) {
headerRow.addChild("th", L10n.getString("QueueToadlet.files"));
} else if (column == LIST_TOTAL_SIZE) {
headerRow.addChild("th", L10n.getString("QueueToadlet.totalSize"));
} else if (column == LIST_PROGRESS) {
headerRow.addChild("th").addChild("a", "href", (isReversed ? "?sortBy=progress" : "?sortBy=progress&reversed")).addChild("#", L10n.getString("QueueToadlet.progress"));
} else if (column == LIST_REASON) {
headerRow.addChild("th", L10n.getString("QueueToadlet.reason"));
}
}
for (Iterator requestItems = requests.iterator(); requestItems.hasNext(); ) {
ClientRequest clientRequest = (ClientRequest) requestItems.next();
HTMLNode requestRow = table.addChild("tr", "class", "priority" + clientRequest.getPriority());
requestRow.addChild(createDeleteCell(pageMaker, clientRequest.getIdentifier(), clientRequest, ctx));
for (int columnIndex = 0, columnCount = columns.length; columnIndex < columnCount; columnIndex++) {
int column = columns[columnIndex];
if (column == LIST_IDENTIFIER) {
if (clientRequest instanceof ClientGet) {
requestRow.addChild(createIdentifierCell(((ClientGet) clientRequest).getURI(), clientRequest.getIdentifier(), false));
} else if (clientRequest instanceof ClientPutDir) {
requestRow.addChild(createIdentifierCell(((ClientPutDir) clientRequest).getFinalURI(), clientRequest.getIdentifier(), true));
} else if (clientRequest instanceof ClientPut) {
requestRow.addChild(createIdentifierCell(((ClientPut) clientRequest).getFinalURI(), clientRequest.getIdentifier(), false));
}
} else if (column == LIST_SIZE) {
if (clientRequest instanceof ClientGet) {
requestRow.addChild(createSizeCell(((ClientGet) clientRequest).getDataSize(), ((ClientGet) clientRequest).isTotalFinalized(), advancedModeEnabled));
} else if (clientRequest instanceof ClientPut) {
requestRow.addChild(createSizeCell(((ClientPut) clientRequest).getDataSize(), true, advancedModeEnabled));
}
} else if (column == LIST_DOWNLOAD) {
requestRow.addChild(createDownloadCell(pageMaker, (ClientGet) clientRequest));
} else if (column == LIST_MIME_TYPE) {
if (clientRequest instanceof ClientGet) {
requestRow.addChild(createTypeCell(((ClientGet) clientRequest).getMIMEType()));
} else if (clientRequest instanceof ClientPut) {
requestRow.addChild(createTypeCell(((ClientPut) clientRequest).getMIMEType()));
}
} else if (column == LIST_PERSISTENCE) {
requestRow.addChild(createPersistenceCell(clientRequest.isPersistent(), clientRequest.isPersistentForever()));
} else if (column == LIST_KEY) {
if (clientRequest instanceof ClientGet) {
requestRow.addChild(createKeyCell(((ClientGet) clientRequest).getURI(), false));
} else if (clientRequest instanceof ClientPut) {
requestRow.addChild(createKeyCell(((ClientPut) clientRequest).getFinalURI(), false));
}else {
requestRow.addChild(createKeyCell(((ClientPutDir) clientRequest).getFinalURI(), true));
}
} else if (column == LIST_FILENAME) {
if (clientRequest instanceof ClientGet) {
requestRow.addChild(createFilenameCell(((ClientGet) clientRequest).getDestFilename()));
} else if (clientRequest instanceof ClientPut) {
requestRow.addChild(createFilenameCell(((ClientPut) clientRequest).getOrigFilename()));
}
} else if (column == LIST_PRIORITY) {
requestRow.addChild(createPriorityCell(pageMaker, clientRequest.getIdentifier(), clientRequest.getPriority(), ctx, priorityClasses, advancedModeEnabled));
} else if (column == LIST_FILES) {
requestRow.addChild(createNumberCell(((ClientPutDir) clientRequest).getNumberOfFiles()));
} else if (column == LIST_TOTAL_SIZE) {
requestRow.addChild(createSizeCell(((ClientPutDir) clientRequest).getTotalDataSize(), true, advancedModeEnabled));
} else if (column == LIST_PROGRESS) {
requestRow.addChild(createProgressCell(clientRequest.isStarted(), (int) clientRequest.getFetchedBlocks(), (int) clientRequest.getFailedBlocks(), (int) clientRequest.getFatalyFailedBlocks(), (int) clientRequest.getMinBlocks(), (int) clientRequest.getTotalBlocks(), clientRequest.isTotalFinalized() || clientRequest instanceof ClientPut, isUpload));
} else if (column == LIST_REASON) {
requestRow.addChild(createReasonCell(clientRequest.getFailureReason()));
}
}
}
return table;
}
public String supportedMethods() {
return "GET, POST";
}
/**
* List of completed request identifiers which the user hasn't acknowledged yet.
*/
private final HashSet completedRequestIdentifiers = new HashSet();
private final HashMap alertsByIdentifier = new HashMap();
public void notifyFailure(ClientRequest req) {
// FIXME do something???
}
public void notifySuccess(ClientRequest req) {
synchronized(completedRequestIdentifiers) {
completedRequestIdentifiers.add(req.getIdentifier());
}
registerAlert(req);
saveCompletedIdentifiersOffThread();
}
private void saveCompletedIdentifiersOffThread() {
core.getExecutor().execute(new Runnable() {
public void run() {
saveCompletedIdentifiers();
}
}, "Save completed identifiers");
}
private void loadCompletedIdentifiers() {
File completedIdentifiersList = new File(core.node.getNodeDir(), "completed.list");
File completedIdentifiersListNew = new File(core.node.getNodeDir(), "completed.list.bak");
if(!readCompletedIdentifiers(completedIdentifiersList)) {
readCompletedIdentifiers(completedIdentifiersListNew);
}
String[] identifiers;
synchronized(completedRequestIdentifiers) {
identifiers = (String[]) completedRequestIdentifiers.toArray(new String[completedRequestIdentifiers.size()]);
}
for(int i=0;i<identifiers.length;i++) {
ClientRequest req = fcp.getGlobalClient().getRequest(identifiers[i]);
if(req == null) {
synchronized(completedRequestIdentifiers) {
completedRequestIdentifiers.remove(identifiers[i]);
}
continue;
}
registerAlert(req);
}
}
private boolean readCompletedIdentifiers(File file) {
FileInputStream fis = null;
try {
fis = new FileInputStream(file);
BufferedInputStream bis = new BufferedInputStream(fis);
InputStreamReader isr = new InputStreamReader(bis, "UTF-8");
BufferedReader br = new BufferedReader(isr);
synchronized(completedRequestIdentifiers) {
completedRequestIdentifiers.clear();
while(true) {
String identifier = br.readLine();
if(identifier == null) return true;
completedRequestIdentifiers.add(identifier);
}
}
} catch (EOFException e) {
// Normal
return true;
} catch (FileNotFoundException e) {
// Normal
return false;
} catch (UnsupportedEncodingException e) {
throw new Error("Impossible: JVM doesn't support UTF-8: " + e, e);
} catch (IOException e) {
Logger.error(this, "Could not read completed identifiers list from "+file);
return false;
} finally {
Closer.close(fis);
}
}
private void saveCompletedIdentifiers() {
FileOutputStream fos = null;
BufferedWriter bw = null;
File completedIdentifiersList = new File(core.node.getNodeDir(), "completed.list");
File completedIdentifiersListNew = new File(core.node.getNodeDir(), "completed.list.bak");
File temp;
try {
temp = File.createTempFile("completed.list", ".tmp", core.node.getNodeDir());
temp.deleteOnExit();
fos = new FileOutputStream(temp);
OutputStreamWriter osw = new OutputStreamWriter(fos, "UTF-8");
bw = new BufferedWriter(osw);
String[] identifiers;
synchronized(completedRequestIdentifiers) {
identifiers = (String[]) completedRequestIdentifiers.toArray(new String[completedRequestIdentifiers.size()]);
}
for(int i=0;i<identifiers.length;i++)
bw.write(identifiers[i]+'\n');
} catch (FileNotFoundException e) {
Logger.error(this, "Unable to save completed requests list (can't find node directory?!!?): "+e, e);
return;
} catch (IOException e) {
Logger.error(this, "Unable to save completed requests list: "+e, e);
return;
} finally {
if(bw != null) {
try {
bw.close();
} catch (IOException e) {
try {
fos.close();
} catch (IOException e1) {
// Ignore
}
}
} else {
try {
fos.close();
} catch (IOException e1) {
// Ignore
}
}
}
completedIdentifiersListNew.delete();
temp.renameTo(completedIdentifiersListNew);
if(!completedIdentifiersListNew.renameTo(completedIdentifiersList)) {
completedIdentifiersList.delete();
if(!completedIdentifiersListNew.renameTo(completedIdentifiersList)) {
Logger.error(this, "Unable to store completed identifiers list because unable to rename "+completedIdentifiersListNew+" to "+completedIdentifiersList);
}
}
}
private void registerAlert(ClientRequest req) {
final String identifier = req.getIdentifier();
boolean logMINOR = Logger.shouldLog(Logger.MINOR, this);
if(logMINOR)
Logger.minor(this, "Registering alert for "+identifier);
if(!req.hasFinished()) {
if(logMINOR)
Logger.minor(this, "Request hasn't finished: "+req+" for "+identifier, new Exception("debug"));
return;
}
if(req instanceof ClientGet) {
FreenetURI uri = ((ClientGet)req).getURI();
long size = ((ClientGet)req).getDataSize();
String name = uri.getPreferredFilename();
String title = l10n("downloadSucceededTitle", "filename", name);
HTMLNode text = new HTMLNode("div");
L10n.addL10nSubstitution(text, "QueueToadlet.downloadSucceeded",
new String[] { "link", "/link", "origlink", "/origlink", "filename", "size" },
new String[] { "<a href=\"/queue/"+uri.toACIIString()+"\">", "</a>", "<a href=\"/"+uri.toACIIString()+"\">", "</a>", name, SizeUtil.formatSize(size) } );
UserAlert alert =
new SimpleHTMLUserAlert(true, title, title, text, UserAlert.MINOR) {
public void onDismiss() {
synchronized(completedRequestIdentifiers) {
completedRequestIdentifiers.remove(identifier);
}
synchronized(alertsByIdentifier) {
alertsByIdentifier.remove(identifier);
}
saveCompletedIdentifiersOffThread();
}
public boolean isEventNotification() {
return true;
}
};
core.alerts.register(alert);
synchronized(alertsByIdentifier) {
alertsByIdentifier.put(identifier, alert);
}
} else if(req instanceof ClientPut) {
FreenetURI uri = ((ClientPut)req).getFinalURI();
if(uri == null) {
Logger.error(this, "No URI for supposedly finished request "+req);
return;
}
long size = ((ClientPut)req).getDataSize();
if(uri == null) {
Logger.error(this, "uri is null for "+req+" for "+identifier);
return;
}
String name = uri.getPreferredFilename();
String title = l10n("uploadSucceededTitle", "filename", name);
HTMLNode text = new HTMLNode("div");
L10n.addL10nSubstitution(text, "QueueToadlet.uploadSucceeded",
new String[] { "link", "/link", "filename", "size" },
new String[] { "<a href=\"/"+uri.toACIIString()+"\">", "</a>", name, SizeUtil.formatSize(size) } );
UserAlert alert =
new SimpleHTMLUserAlert(true, title, title, text, UserAlert.MINOR) {
public void onDismiss() {
synchronized(completedRequestIdentifiers) {
completedRequestIdentifiers.remove(identifier);
}
synchronized(alertsByIdentifier) {
alertsByIdentifier.remove(identifier);
}
saveCompletedIdentifiersOffThread();
}
public boolean isEventNotification() {
return true;
}
};
core.alerts.register(alert);
synchronized(alertsByIdentifier) {
alertsByIdentifier.put(identifier, alert);
}
} else if(req instanceof ClientPutDir) {
FreenetURI uri = ((ClientPutDir)req).getFinalURI();
long size = ((ClientPutDir)req).getTotalDataSize();
int files = ((ClientPutDir)req).getNumberOfFiles();
String name = uri.getPreferredFilename();
String title = l10n("siteUploadSucceededTitle", "filename", name);
HTMLNode text = new HTMLNode("div");
L10n.addL10nSubstitution(text, "QueueToadlet.siteUploadSucceeded",
new String[] { "link", "/link", "filename", "size", "files" },
new String[] { "<a href=\"/"+uri.toACIIString()+"\">", "</a>", name, SizeUtil.formatSize(size), Integer.toString(files) } );
UserAlert alert =
new SimpleHTMLUserAlert(true, title, title, text, UserAlert.MINOR) {
public void onDismiss() {
synchronized(completedRequestIdentifiers) {
completedRequestIdentifiers.remove(identifier);
}
synchronized(alertsByIdentifier) {
alertsByIdentifier.remove(identifier);
}
saveCompletedIdentifiersOffThread();
}
public boolean isEventNotification() {
return true;
}
};
core.alerts.register(alert);
synchronized(alertsByIdentifier) {
alertsByIdentifier.put(identifier, alert);
}
}
}
String l10n(String key, String pattern, String value) {
return L10n.getString("QueueToadlet."+key, pattern, value);
}
public void onRemove(ClientRequest req) {
String identifier = req.getIdentifier();
synchronized(completedRequestIdentifiers) {
completedRequestIdentifiers.remove(identifier);
}
UserAlert alert;
synchronized(alertsByIdentifier) {
alert = (UserAlert) alertsByIdentifier.remove(identifier);
}
core.alerts.unregister(alert);
saveCompletedIdentifiersOffThread();
}
}
The table below shows all metrics for QueueToadlet.java.
| Metric | Value | Description | |
|---|---|---|---|
| BLOCKS | 300.00 | Number of blocks | |
| BLOCK_COMMENT | 11.00 | Number of block comment lines | |
| COMMENTS | 27.00 | Comment lines | |
| COMMENT_DENSITY | 0.02 | Comment density | |
| COMPARISONS | 219.00 | Number of comparison operators | |
| CYCLOMATIC | 303.00 | Cyclomatic complexity | |
| DECL_COMMENTS | 2.00 | Comments in declarations | |
| DOC_COMMENT | 3.00 | Number of javadoc comment lines | |
| ELOC | 1109.00 | Effective lines of code | |
| EXEC_COMMENTS | 21.00 | Comments in executable code | |
| EXITS | 188.00 | Procedure exits | |
| FUNCTIONS | 39.00 | Number of function declarations | |
| HALSTEAD_DIFFICULTY | 141.96 | Halstead difficulty | |
| HALSTEAD_EFFORT | 0.00 | Halstead effort | |
| INTERFACE_COMPLEXITY | 256.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 | 1.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 | 41.00 | JAVA0034 Missing braces in if statement | |
| JAVA0035 | 1.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 | 2.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 | 0.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 | 3.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 | 0.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 | 0.00 | JAVA0075 Method parameter hides field | |
| JAVA0076 | 34.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 | 0.00 | JAVA0108 Incorrect javadoc: no @param tag for 'parameter' | |
| JAVA0109 | 0.00 | JAVA0109 Incorrect javadoc: no parameter 'parameter' | |
| JAVA0110 | 0.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 | 1.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 | 15.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 | 3.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 | 120.00 | JAVA0144 Line exceeds maximum M characters | |
| JAVA0145 | 4626.00 | JAVA0145 Tab character used in source file | |
| JAVA0150 | 1.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 | 1.00 | JAVA0166 Generic exception caught | |
| JAVA0167 | 0.00 | JAVA0167 ThreadDeath not rethrown | |
| JAVA0169 | 0.00 | JAVA0169 Unnecessary catch block: exception 'exception' | |
| JAVA0170 | 0.00 | JAVA0170 Caught exception not derived from java.lang.Exception | |
| JAVA0171 | 0.00 | JAVA0171 Unused local variable | |
| JAVA0173 | 3.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 | 9.00 | JAVA0177 Variable declaration missing initializer | |
| JAVA0179 | 0.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 | 1.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 | 0.00 | JAVA0264 Integer math in long context - check for overflow | |
| JAVA0265 | 3.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 | 4.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 | 2.00 | JAVA0285 Dereference of potentially null variable | |
| JAVA0286 | 0.00 | JAVA0286 Dereference of null variable | |
| JAVA0287 | 1.00 | JAVA0287 Unnecessary null check | |
| JAVA0288 | 0.00 | JAVA0288 Inconsistent null check | |
| LINES | 1432.00 | Number of lines in the source file | |
| LINE_COMMENT | 13.00 | Number of line comments | |
| LOC | 1298.00 | Lines of code | |
| LOGICAL_LINES | 769.00 | Number of statements | |
| LOOPS | 17.00 | Number of loops | |
| NEST_DEPTH | 10.00 | Maximum nesting depth | |
| OPERANDS | 4878.00 | Number of operands | |
| OPERATORS | 8804.00 | Number of operators | |
| PARAMS | 74.00 | Number of formal parameter declarations | |
| PROGRAM_LENGTH | 13682.00 | Halstead program length | |
| PROGRAM_VOCAB | 1109.00 | Halstead program vocabulary | |
| PROGRAM_VOLUME | 0.00 | Halstead program volume | |
| RETURNS | 182.00 | Number of return points from functions | |
| SIZE | 71199.00 | Size of the file in bytes | |
| UNIQUE_OPERANDS | 1048.00 | Number of unique operands | |
| UNIQUE_OPERATORS | 61.00 | Number of unique operators | |
| WHITESPACE | 107.00 | Number of whitespace lines | |