mobeigi
/
filebot
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

* enable 3x fetch-retry for important resources

This commit is contained in:
Reinhard Pointner 2013-03-30 11:00:14 +00:00
parent 86b7c9d482
commit db820647af
1 changed files with 37 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
source/net/sourceforge/filebot/web/CachedResource.java
View File

@ -22,12 +22,8 @@ public abstract class CachedResource<T extends Serializable> {
private Class<T> type; private Class<T> type;
private long expirationTime; private long expirationTime;
private int retryCountLimit;
public CachedResource(String resource, Class<T> type, long expirationTime) { private long retryWaitTime;
this.resource = resource;
this.type = type;
this.expirationTime = expirationTime;
}
public CachedResource(String resource, Class<T> type) { public CachedResource(String resource, Class<T> type) {
@ -35,6 +31,20 @@ public abstract class CachedResource<T extends Serializable> {
} }
public CachedResource(String resource, Class<T> type, long expirationTime) {
this(resource, type, expirationTime, 2, 1000);
}
public CachedResource(String resource, Class<T> type, long expirationTime, int retryCountLimit, long retryWaitTime) {
this.resource = resource;
this.type = type;
this.expirationTime = expirationTime;
this.retryCountLimit = retryCountLimit;
this.retryWaitTime = retryWaitTime;
}
protected Cache getCache() { protected Cache getCache() {
return CacheManager.getInstance().getCache("web-persistent-datasource"); return CacheManager.getInstance().getCache("web-persistent-datasource");
} }
@ -82,9 +92,13 @@ public abstract class CachedResource<T extends Serializable> {
IOException networkException = null; IOException networkException = null;
try { try {
data = fetchData(new URL(resource), element != null ? lastUpdateTime : 0); long lastModified = element != null ? lastUpdateTime : 0;
URL url = new URL(resource);
data = fetch(url, lastModified);
} catch (IOException e) { } catch (IOException e) {
networkException = e; networkException = e;
} catch (InterruptedException e) {
throw new RuntimeException(e);
} }
if (data != null) { if (data != null) {
@ -114,8 +128,9 @@ public abstract class CachedResource<T extends Serializable> {
// throw network error only if we can't use previously cached data // throw network error only if we can't use previously cached data
if (networkException != null) { if (networkException != null) {
if (product == null) if (product == null) {
throw networkException; throw networkException;
}
// just log error and continue with cached data // just log error and continue with cached data
Logger.getLogger(getClass().getName()).log(Level.WARNING, networkException.toString()); Logger.getLogger(getClass().getName()).log(Level.WARNING, networkException.toString());
@ -124,4 +139,18 @@ public abstract class CachedResource<T extends Serializable> {
return product; return product;
} }
protected ByteBuffer fetch(URL url, long lastModified) throws IOException, InterruptedException {
for (int i = 0; retryCountLimit < 0 || i <= retryCountLimit; i++) {
try {
return fetchData(url, lastModified);
} catch (IOException e) {
if (i >= 0 && i >= retryCountLimit) {
throw e;
}
Thread.sleep(retryWaitTime);
}
}
return null; // can't happen
}
} }