Revert thread updates to running inline again.

This commit is contained in:
Cody Henthorne
2021-09-17 11:49:37 -04:00
parent d5fbd10406
commit ce2c2002c6
5 changed files with 15 additions and 15 deletions

View File

@@ -1360,7 +1360,7 @@ public class MmsDatabase extends MessageDatabase {
if (!Types.isExpirationTimerUpdate(mailbox)) {
DatabaseFactory.getThreadDatabase(context).incrementUnread(threadId, 1);
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
}
notifyConversationListeners(threadId);
@@ -1458,7 +1458,7 @@ public class MmsDatabase extends MessageDatabase {
DatabaseFactory.getThreadDatabase(context).incrementUnread(threadId, 1);
}
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
TrimThreadJob.enqueueAsync(threadId);
}
@@ -1668,7 +1668,7 @@ public class MmsDatabase extends MessageDatabase {
if (updateThread) {
DatabaseFactory.getThreadDatabase(context).setLastScrolled(contentValuesThreadId, 0);
ThreadUpdateJob.enqueue(contentValuesThreadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
}
}
}

View File

@@ -667,7 +667,7 @@ public class SmsDatabase extends MessageDatabase {
long threadId = getThreadIdForMessage(messageId);
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
notifyConversationListeners(threadId);
return new InsertResult(messageId, threadId);
@@ -751,7 +751,7 @@ public class SmsDatabase extends MessageDatabase {
DatabaseFactory.getThreadDatabase(context).incrementUnread(threadId, 1);
}
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
db.setTransactionSuccessful();
} finally {
@@ -828,7 +828,7 @@ public class SmsDatabase extends MessageDatabase {
DatabaseFactory.getThreadDatabase(context).incrementUnread(threadId, 1);
}
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
db.setTransactionSuccessful();
} finally {
@@ -900,7 +900,7 @@ public class SmsDatabase extends MessageDatabase {
DatabaseFactory.getThreadDatabase(context).incrementUnread(threadId, 1);
}
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
notifyConversationListeners(threadId);
TrimThreadJob.enqueueAsync(threadId);
@@ -1174,7 +1174,7 @@ public class SmsDatabase extends MessageDatabase {
}
if (!silent) {
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
}
if (message.getSubscriptionId() != -1) {
@@ -1217,7 +1217,7 @@ public class SmsDatabase extends MessageDatabase {
long messageId = db.insert(TABLE_NAME, null, values);
DatabaseFactory.getThreadDatabase(context).incrementUnread(threadId, 1);
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
notifyConversationListeners(threadId);
@@ -1241,7 +1241,7 @@ public class SmsDatabase extends MessageDatabase {
databaseHelper.getSignalWritableDatabase().insert(TABLE_NAME, null, values);
DatabaseFactory.getThreadDatabase(context).incrementUnread(threadId, 1);
ThreadUpdateJob.enqueue(threadId);
DatabaseFactory.getThreadDatabase(context).update(threadId, true);
notifyConversationListeners(threadId);