mirror
/
FairEmail
mirror of https://github.com/M66B/FairEmail.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Really limit fetch

This commit is contained in:
M66B 2020-11-09 21:29:14 +01:00
parent 8685872eb0
commit 1dc1b0ae6f
1 changed files with 18 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
app/src/main/java/eu/faircode/email/EntityOperation.java
View File

@ -321,13 +321,6 @@ public class EntityOperation {
}
return;
} else if (FETCH.equals(name)) {
int count = db.operation().getOperationCount(message.folder, name);
if (count >= MAX_FETCH) {
sync(context, message.folder, false);
return;
}
} else if (DELETE.equals(name)) {
db.message().setMessageUiHide(message.id, true);
/*
@ -349,9 +342,26 @@ public class EntityOperation {
}
}
private static void queue(Context context, Long account, long folder, long message, String name, JSONArray jargs) {
static void queue(Context context, EntityFolder folder, String name, Object... values) {
JSONArray jargs = new JSONArray();
for (Object value : values)
jargs.put(value);
queue(context, folder.account, folder.id, null, name, jargs);
}
private static void queue(Context context, Long account, long folder, Long message, String name, JSONArray jargs) {
DB db = DB.getInstance(context);
if (FETCH.equals(name)) {
int count = db.operation().getOperationCount(folder, name);
if (count >= MAX_FETCH) {
Log.i("Replacing fetch by sync folder=" + folder + " args=" + jargs + " count=" + count);
sync(context, folder, false);
return;
}
}
EntityOperation op = new EntityOperation();
op.account = account;
op.folder = folder;
@ -375,36 +385,6 @@ public class EntityOperation {
Log.breadcrumb("queued", crumb);
}
static void queue(Context context, EntityFolder folder, String name, Object... values) {
DB db = DB.getInstance(context);
JSONArray jargs = new JSONArray();
for (Object value : values)
jargs.put(value);
EntityOperation op = new EntityOperation();
op.account = folder.account;
op.folder = folder.id;
op.message = null;
op.name = name;
op.args = jargs.toString();
op.created = new Date().getTime();
op.id = db.operation().insertOperation(op);
Log.i("Queued op=" + op.id + "/" + op.name +
" folder=" + op.folder + " msg=" + op.message +
" args=" + op.args);
Map<String, String> crumb = new HashMap<>();
crumb.put("name", op.name);
crumb.put("args", op.args);
crumb.put("folder", op.account + ":" + op.folder);
if (op.message != null)
crumb.put("message", Long.toString(op.message));
crumb.put("free", Integer.toString(Log.getFreeMemMb()));
Log.breadcrumb("queued", crumb);
}
static void sync(Context context, long fid, boolean foreground) {
DB db = DB.getInstance(context);