Kaladaran/briar
0
0
Fork 0
mirror of https://code.briarproject.org/briar/briar.git synced 2026-02-23 16:19:54 +01:00
Code Issues Projects Releases Wiki Activity

Improved blog controller's caching.

Browse Source
This commit is contained in:
akwizgran
2016-08-23 23:34:33 +01:00
parent 3aa3811d1b
commit ef02908082
1 changed files with 25 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
briar-android/src/org/briarproject/android/blogs/BlogControllerImpl.java
View File

@@ -43,6 +43,8 @@ public class BlogControllerImpl extends DbControllerImpl
protected volatile BlogManager blogManager; protected volatile BlogManager blogManager;
private final Map<MessageId, byte[]> bodyCache = new ConcurrentHashMap<>(); private final Map<MessageId, byte[]> bodyCache = new ConcurrentHashMap<>();
private final Map<MessageId, BlogPostHeader> headerCache =
new ConcurrentHashMap<>();
private volatile BlogPostListener listener; private volatile BlogPostListener listener;
private volatile GroupId groupId = null; private volatile GroupId groupId = null;
@@ -127,6 +129,7 @@ public class BlogControllerImpl extends DbControllerImpl
List<BlogPostItem> items = new ArrayList<>(headers.size()); List<BlogPostItem> items = new ArrayList<>(headers.size());
now = System.currentTimeMillis(); now = System.currentTimeMillis();
for (BlogPostHeader h : headers) { for (BlogPostHeader h : headers) {
headerCache.put(h.getId(), h);
byte[] body = getPostBody(h.getId()); byte[] body = getPostBody(h.getId());
items.add(new BlogPostItem(groupId, h, body)); items.add(new BlogPostItem(groupId, h, body));
} }
@@ -147,6 +150,12 @@ public class BlogControllerImpl extends DbControllerImpl
public void loadBlogPost(final BlogPostHeader header, public void loadBlogPost(final BlogPostHeader header,
final ResultExceptionHandler<BlogPostItem, DbException> handler) { final ResultExceptionHandler<BlogPostItem, DbException> handler) {
if (groupId == null) throw new IllegalStateException(); if (groupId == null) throw new IllegalStateException();
byte[] body = bodyCache.get(header.getId());
if (body != null) {
LOG.info("Loaded body from cache");
handler.onResult(new BlogPostItem(groupId, header, body));
return;
}
runOnDbThread(new Runnable() { runOnDbThread(new Runnable() {
@Override @Override
public void run() { public void run() {
@@ -170,12 +179,18 @@ public class BlogControllerImpl extends DbControllerImpl
public void loadBlogPost(final MessageId m, public void loadBlogPost(final MessageId m,
final ResultExceptionHandler<BlogPostItem, DbException> handler) { final ResultExceptionHandler<BlogPostItem, DbException> handler) {
if (groupId == null) throw new IllegalStateException(); if (groupId == null) throw new IllegalStateException();
BlogPostHeader header = headerCache.get(m);
if (header != null) {
LOG.info("Loaded header from cache");
loadBlogPost(header, handler);
return;
}
runOnDbThread(new Runnable() { runOnDbThread(new Runnable() {
@Override @Override
public void run() { public void run() {
try { try {
long now = System.currentTimeMillis(); long now = System.currentTimeMillis();
BlogPostHeader header = blogManager.getPostHeader(m); BlogPostHeader header = getPostHeader(m);
byte[] body = getPostBody(m); byte[] body = getPostBody(m);
long duration = System.currentTimeMillis() - now; long duration = System.currentTimeMillis() - now;
if (LOG.isLoggable(INFO)) if (LOG.isLoggable(INFO))
@@ -190,6 +205,15 @@ public class BlogControllerImpl extends DbControllerImpl
}); });
} }
private BlogPostHeader getPostHeader(MessageId m) throws DbException {
BlogPostHeader header = headerCache.get(m);
if (header == null) {
header = blogManager.getPostHeader(m);
headerCache.put(m, header);
}
return header;
}
private byte[] getPostBody(MessageId m) throws DbException { private byte[] getPostBody(MessageId m) throws DbException {
byte[] body = bodyCache.get(m); byte[] body = bodyCache.get(m);
if (body == null) { if (body == null) {