Author: toad
Date: 2008-08-05 20:01:18 +0000 (Tue, 05 Aug 2008)
New Revision: 21627
Modified:
trunk/freenet/src/freenet/client/HighLevelSimpleClient.java
trunk/freenet/src/freenet/client/HighLevelSimpleClientImpl.java
Log:
Non-blocking inserts too
Modified: trunk/freenet/src/freenet/client/HighLevelSimpleClient.java
===================================================================
--- trunk/freenet/src/freenet/client/HighLevelSimpleClient.java 2008-08-05
19:45:37 UTC (rev 21626)
+++ trunk/freenet/src/freenet/client/HighLevelSimpleClient.java 2008-08-05
20:01:18 UTC (rev 21627)
@@ -51,6 +51,11 @@
public FreenetURI insert(InsertBlock insert, boolean getCHKOnly, String
filenameHint) throws InsertException;
/**
+ * Non-blocking insert.
+ */
+ public void insert(InsertBlock insert, boolean getCHKOnly, String
filenameHint, boolean isMetadata, InsertContext ctx, ClientCallback cb) throws
InsertException;
+
+ /**
* Blocking insert of a redirect.
*/
public FreenetURI insertRedirect(FreenetURI insertURI, FreenetURI
target) throws InsertException;
Modified: trunk/freenet/src/freenet/client/HighLevelSimpleClientImpl.java
===================================================================
--- trunk/freenet/src/freenet/client/HighLevelSimpleClientImpl.java
2008-08-05 19:45:37 UTC (rev 21626)
+++ trunk/freenet/src/freenet/client/HighLevelSimpleClientImpl.java
2008-08-05 20:01:18 UTC (rev 21627)
@@ -155,6 +155,13 @@
put.start(false);
return pw.waitForCompletion();
}
+
+ public void insert(InsertBlock insert, boolean getCHKOnly, String
filenameHint, boolean isMetadata, InsertContext ctx, ClientCallback cb) throws
InsertException {
+ ClientPutter put = new ClientPutter(cb, insert.getData(),
insert.desiredURI, insert.clientMetadata,
+ ctx, core.requestStarters.chkPutScheduler,
core.requestStarters.sskPutScheduler, priorityClass,
+ getCHKOnly, isMetadata, this, null,
filenameHint, false);
+ put.start(false);
+ }
public FreenetURI insertRedirect(FreenetURI insertURI, FreenetURI
targetURI) throws InsertException {
Metadata m = new Metadata(Metadata.SIMPLE_REDIRECT, targetURI,
new ClientMetadata());