Author: toad
Date: 2008-06-17 15:22:30 +0000 (Tue, 17 Jun 2008)
New Revision: 20401

Modified:
   branches/db4o/freenet/src/freenet/clients/http/QueueToadlet.java
Log:
remove dead references to force store

Modified: branches/db4o/freenet/src/freenet/clients/http/QueueToadlet.java
===================================================================
--- branches/db4o/freenet/src/freenet/clients/http/QueueToadlet.java    
2008-06-17 15:21:31 UTC (rev 20400)
+++ branches/db4o/freenet/src/freenet/clients/http/QueueToadlet.java    
2008-06-17 15:22:30 UTC (rev 20401)
@@ -161,7 +161,6 @@
                                                clientRequest.restartAsync();
                                        }
                                }
-                               fcp.forceStorePersistentRequests();
                                writePermanentRedirect(ctx, "Done", "/queue/");
                                return;
                        } else if(request.isPartSet("remove_AllRequests") && 
(request.getPartAsString("remove_AllRequests", 32).length() > 0)) {
@@ -192,7 +191,6 @@
                                                        ));
                                else
                                        writePermanentRedirect(ctx, "Done", 
"/queue/");
-                               fcp.forceStorePersistentRequests();
                                return;
                        }else if(request.isPartSet("download")) {
                                // Queue a download
@@ -233,7 +231,6 @@
                                        }
                                }
                                writePermanentRedirect(ctx, "Done", "/queue/");
-                               fcp.forceStorePersistentRequests();
                                return;
                        } else if (request.getPartAsString("insert", 
128).length() > 0) {
                                FreenetURI insertURI;
@@ -269,7 +266,6 @@
                                try {
                                        ClientPut clientPut = new 
ClientPut(fcp.getGlobalForeverClient(), 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) {
@@ -307,7 +303,6 @@
                                        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) {
@@ -341,7 +336,6 @@
                                        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) {


Reply via email to