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);