r26852 - trunk/freenet/src/freenet/client
[email protected] Wed, 15 Apr 2009 19:44:45 +0000
| Newsgroups | gmane.network.freenet.cvs |
|---|---|
| Message-ID | <[email protected]> |
Author: toad
Date: 2009-04-15 19:44:45 +0000 (Wed, 15 Apr 2009)
New Revision: 26852
Modified:
trunk/freenet/src/freenet/client/HighLevelSimpleClient.java
trunk/freenet/src/freenet/client/HighLevelSimpleClientImpl.java
Log:
Allow to specify priority in prefetch
Modified: trunk/freenet/src/freenet/client/HighLevelSimpleClient.java
===================================================================
--- trunk/freenet/src/freenet/client/HighLevelSimpleClient.java 2009-04-15 18:48:24 UTC (rev 26851)
+++ trunk/freenet/src/freenet/client/HighLevelSimpleClient.java 2009-04-15 19:44:45 UTC (rev 26852)
@@ -100,4 +100,6 @@
*/
public void prefetch(FreenetURI uri, long timeout, long maxSize, Set allowedTypes);
+ public void prefetch(FreenetURI uri, long timeout, long maxSize, Set allowedTypes, short prio);
+
}
Modified: trunk/freenet/src/freenet/client/HighLevelSimpleClientImpl.java
===================================================================
--- trunk/freenet/src/freenet/client/HighLevelSimpleClientImpl.java 2009-04-15 18:48:24 UTC (rev 26851)
+++ trunk/freenet/src/freenet/client/HighLevelSimpleClientImpl.java 2009-04-15 19:44:45 UTC (rev 26852)
@@ -252,11 +252,15 @@
}
};
+
+ public void prefetch(FreenetURI uri, long timeout, long maxSize, Set allowedTypes) {
+ prefetch(uri, timeout, maxSize, allowedTypes, RequestStarter.PREFETCH_PRIORITY_CLASS);
+ }
- public void prefetch(FreenetURI uri, long timeout, long maxSize, Set allowedTypes) {
+ public void prefetch(FreenetURI uri, long timeout, long maxSize, Set allowedTypes, short prio) {
FetchContext ctx = getFetchContext(maxSize);
ctx.allowedMIMETypes = allowedTypes;
- final ClientGetter get = new ClientGetter(nullCallback, uri, ctx, RequestStarter.PREFETCH_PRIORITY_CLASS, this, new NullBucket(), null);
+ final ClientGetter get = new ClientGetter(nullCallback, uri, ctx, prio, this, new NullBucket(), null);
core.getTicker().queueTimedJob(new Runnable() {
public void run() {
get.cancel(null, core.clientContext);