diff --git a/k9mail/build.gradle b/k9mail/build.gradle index 09c10a99b..4a4bef840 100644 --- a/k9mail/build.gradle +++ b/k9mail/build.gradle @@ -35,6 +35,7 @@ dependencies { compile 'com.github.amlcurran.showcaseview:library:5.4.1' compile 'com.squareup.moshi:moshi:1.2.0' compile "com.jakewharton.timber:timber:${timberVersion}" + compile 'net.jcip:jcip-annotations:1.0' androidTestCompile 'com.android.support.test.espresso:espresso-core:2.2.2' diff --git a/k9mail/src/main/java/com/fsck/k9/activity/ActivityListener.java b/k9mail/src/main/java/com/fsck/k9/activity/ActivityListener.java index 1d494bc8d..93631085d 100644 --- a/k9mail/src/main/java/com/fsck/k9/activity/ActivityListener.java +++ b/k9mail/src/main/java/com/fsck/k9/activity/ActivityListener.java @@ -1,5 +1,6 @@ package com.fsck.k9.activity; + import android.content.BroadcastReceiver; import android.content.Context; import android.content.Intent; @@ -12,216 +13,252 @@ import com.fsck.k9.K9; import com.fsck.k9.R; import com.fsck.k9.controller.SimpleMessagingListener; import com.fsck.k9.service.MailService; +import net.jcip.annotations.GuardedBy; + public class ActivityListener extends SimpleMessagingListener { - private Account mAccount = null; - private String mLoadingFolderName = null; - private String mLoadingHeaderFolderName = null; - private String mLoadingAccountDescription = null; - private String mSendingAccountDescription = null; - private int mFolderCompleted = 0; - private int mFolderTotal = 0; - private String mProcessingAccountDescription = null; - private String mProcessingCommandTitle = null; + private final Object lock = new Object(); - private BroadcastReceiver mTickReceiver = new BroadcastReceiver() { + @GuardedBy("lock") private Account account = null; + @GuardedBy("lock") private String loadingFolderName = null; + @GuardedBy("lock") private String loadingHeaderFolderName = null; + @GuardedBy("lock") private String loadingAccountDescription = null; + @GuardedBy("lock") private String sendingAccountDescription = null; + @GuardedBy("lock") private int folderCompleted = 0; + @GuardedBy("lock") private int folderTotal = 0; + @GuardedBy("lock") private String processingAccountDescription = null; + @GuardedBy("lock") private String processingCommandTitle = null; + + private BroadcastReceiver tickReceiver = new BroadcastReceiver() { @Override public void onReceive(Context context, Intent intent) { informUserOfStatus(); } }; + public String getOperation(Context context) { - if (mLoadingAccountDescription != null - || mSendingAccountDescription != null - || mLoadingHeaderFolderName != null - || mProcessingAccountDescription != null) { - - return getActionInProgressOperation(context); - - } else { - long nextPollTime = MailService.getNextPollTime(); - if (nextPollTime != -1) { - return context.getString(R.string.status_next_poll, - DateUtils.getRelativeTimeSpanString(nextPollTime, System.currentTimeMillis(), - DateUtils.MINUTE_IN_MILLIS, 0)); - } else if (K9.isDebug() && MailService.isSyncDisabled()) { - if (MailService.hasNoConnectivity()) { - return context.getString(R.string.status_no_network); - } else if (MailService.isSyncNoBackground()) { - return context.getString(R.string.status_no_background); - } else if (MailService.isSyncBlocked()) { - return context.getString(R.string.status_syncing_blocked); - } else if (MailService.isPollAndPushDisabled()) { - return context.getString(R.string.status_poll_and_push_disabled); - } else { - return context.getString(R.string.status_syncing_off); - } - } else if (MailService.isSyncDisabled()) { - return context.getString(R.string.status_syncing_off); - } else { - return ""; + synchronized (lock) { + if (loadingAccountDescription != null || + sendingAccountDescription != null || + loadingHeaderFolderName != null || + processingAccountDescription != null) { + return getActionInProgressOperation(context); } } + + long nextPollTime = MailService.getNextPollTime(); + if (nextPollTime != -1) { + CharSequence relativeTimeSpanString = DateUtils.getRelativeTimeSpanString( + nextPollTime, System.currentTimeMillis(), DateUtils.MINUTE_IN_MILLIS, 0); + return context.getString(R.string.status_next_poll, relativeTimeSpanString); + } else if (K9.isDebug() && MailService.isSyncDisabled()) { + if (MailService.hasNoConnectivity()) { + return context.getString(R.string.status_no_network); + } else if (MailService.isSyncNoBackground()) { + return context.getString(R.string.status_no_background); + } else if (MailService.isSyncBlocked()) { + return context.getString(R.string.status_syncing_blocked); + } else if (MailService.isPollAndPushDisabled()) { + return context.getString(R.string.status_poll_and_push_disabled); + } else { + return context.getString(R.string.status_syncing_off); + } + } else if (MailService.isSyncDisabled()) { + return context.getString(R.string.status_syncing_off); + } else { + return ""; + } } + @GuardedBy("lock") private String getActionInProgressOperation(Context context) { - String progress = (mFolderTotal > 0 ? - context.getString(R.string.folder_progress, mFolderCompleted, mFolderTotal) : ""); + String progress = folderTotal > 0 ? + context.getString(R.string.folder_progress, folderCompleted, folderTotal) : ""; - if (mLoadingFolderName != null || mLoadingHeaderFolderName != null) { - String displayName = null; - if (mLoadingHeaderFolderName != null) { - displayName = mLoadingHeaderFolderName; - } else if (mLoadingFolderName != null) { - displayName = mLoadingFolderName; - } - if ((mAccount != null) && (mAccount.getInboxFolderName() != null) - && mAccount.getInboxFolderName().equalsIgnoreCase(displayName)) { - displayName = context.getString(R.string.special_mailbox_name_inbox); - } else if ((mAccount != null) && (mAccount.getOutboxFolderName() != null) - && mAccount.getOutboxFolderName().equals(displayName)) { - displayName = context.getString(R.string.special_mailbox_name_outbox); + if (loadingFolderName != null || loadingHeaderFolderName != null) { + String displayName; + if (loadingHeaderFolderName != null) { + displayName = loadingHeaderFolderName; + } else { + displayName = loadingFolderName; } - if (mLoadingHeaderFolderName != null) { + if (account != null) { + if (displayName.equalsIgnoreCase(account.getInboxFolderName())) { + displayName = context.getString(R.string.special_mailbox_name_inbox); + } else if (displayName.equalsIgnoreCase(account.getOutboxFolderName())) { + displayName = context.getString(R.string.special_mailbox_name_outbox); + } + } + + if (loadingHeaderFolderName != null) { return context.getString(R.string.status_loading_account_folder_headers, - mLoadingAccountDescription, displayName, progress); + loadingAccountDescription, displayName, progress); } else { return context.getString(R.string.status_loading_account_folder, - mLoadingAccountDescription, displayName, progress); + loadingAccountDescription, displayName, progress); } - } - - else if (mSendingAccountDescription != null) { - return context.getString(R.string.status_sending_account, mSendingAccountDescription, progress); - } else if (mProcessingAccountDescription != null) { - return context.getString(R.string.status_processing_account, mProcessingAccountDescription, - mProcessingCommandTitle != null ? mProcessingCommandTitle : "", - progress); + } else if (sendingAccountDescription != null) { + return context.getString(R.string.status_sending_account, sendingAccountDescription, progress); + } else if (processingAccountDescription != null) { + return context.getString(R.string.status_processing_account, processingAccountDescription, + processingCommandTitle != null ? processingCommandTitle : "", progress); } else { return ""; } } public void onResume(Context context) { - context.registerReceiver(mTickReceiver, new IntentFilter(Intent.ACTION_TIME_TICK)); + context.registerReceiver(tickReceiver, new IntentFilter(Intent.ACTION_TIME_TICK)); } public void onPause(Context context) { - context.unregisterReceiver(mTickReceiver); + context.unregisterReceiver(tickReceiver); } public void informUserOfStatus() { } @Override - public void synchronizeMailboxFinished( - Account account, - String folder, - int totalMessagesInMailbox, - int numNewMessages) { - mLoadingAccountDescription = null; - mLoadingFolderName = null; - mAccount = null; + public void synchronizeMailboxFinished(Account account, String folder, int totalMessagesInMailbox, + int numNewMessages) { + synchronized (lock) { + loadingAccountDescription = null; + loadingFolderName = null; + this.account = null; + } + informUserOfStatus(); } @Override public void synchronizeMailboxStarted(Account account, String folder) { - mLoadingAccountDescription = account.getDescription(); - mLoadingFolderName = folder; - mAccount = account; - mFolderCompleted = 0; - mFolderTotal = 0; + synchronized (lock) { + loadingAccountDescription = account.getDescription(); + loadingFolderName = folder; + this.account = account; + folderCompleted = 0; + folderTotal = 0; + } + informUserOfStatus(); } - @Override public void synchronizeMailboxHeadersStarted(Account account, String folder) { - mLoadingAccountDescription = account.getDescription(); - mLoadingHeaderFolderName = folder; + synchronized (lock) { + loadingAccountDescription = account.getDescription(); + loadingHeaderFolderName = folder; + } + informUserOfStatus(); } - @Override public void synchronizeMailboxHeadersProgress(Account account, String folder, int completed, int total) { - mFolderCompleted = completed; - mFolderTotal = total; + synchronized (lock) { + folderCompleted = completed; + folderTotal = total; + } + informUserOfStatus(); } @Override - public void synchronizeMailboxHeadersFinished(Account account, String folder, - int total, int completed) { - mLoadingHeaderFolderName = null; - mFolderCompleted = 0; - mFolderTotal = 0; + public void synchronizeMailboxHeadersFinished(Account account, String folder, int total, int completed) { + synchronized (lock) { + loadingHeaderFolderName = null; + folderCompleted = 0; + folderTotal = 0; + } + informUserOfStatus(); } - @Override public void synchronizeMailboxProgress(Account account, String folder, int completed, int total) { - mFolderCompleted = completed; - mFolderTotal = total; + synchronized (lock) { + folderCompleted = completed; + folderTotal = total; + } + informUserOfStatus(); } @Override - public void synchronizeMailboxFailed(Account account, String folder, - String message) { - mLoadingAccountDescription = null; - mLoadingHeaderFolderName = null; - mLoadingFolderName = null; - mAccount = null; + public void synchronizeMailboxFailed(Account account, String folder, String message) { + synchronized (lock) { + loadingAccountDescription = null; + loadingHeaderFolderName = null; + loadingFolderName = null; + this.account = null; + } informUserOfStatus(); - } @Override public void sendPendingMessagesStarted(Account account) { - mSendingAccountDescription = account.getDescription(); + synchronized (lock) { + sendingAccountDescription = account.getDescription(); + } + informUserOfStatus(); } @Override public void sendPendingMessagesCompleted(Account account) { - mSendingAccountDescription = null; + synchronized (lock) { + sendingAccountDescription = null; + } + informUserOfStatus(); } @Override public void sendPendingMessagesFailed(Account account) { - mSendingAccountDescription = null; + synchronized (lock) { + sendingAccountDescription = null; + } + informUserOfStatus(); } @Override public void pendingCommandsProcessing(Account account) { - mProcessingAccountDescription = account.getDescription(); - mFolderCompleted = 0; - mFolderTotal = 0; + synchronized (lock) { + processingAccountDescription = account.getDescription(); + folderCompleted = 0; + folderTotal = 0; + } + informUserOfStatus(); } @Override public void pendingCommandsFinished(Account account) { - mProcessingAccountDescription = null; + synchronized (lock) { + processingAccountDescription = null; + } + informUserOfStatus(); } @Override public void pendingCommandStarted(Account account, String commandTitle) { - mProcessingCommandTitle = commandTitle; + synchronized (lock) { + processingCommandTitle = commandTitle; + + } informUserOfStatus(); } @Override public void pendingCommandCompleted(Account account, String commandTitle) { - mProcessingCommandTitle = null; + synchronized (lock) { + processingCommandTitle = null; + } + informUserOfStatus(); } @@ -241,12 +278,14 @@ public class ActivityListener extends SimpleMessagingListener { } public int getFolderCompleted() { - return mFolderCompleted; + synchronized (lock) { + return folderCompleted; + } } - public int getFolderTotal() { - return mFolderTotal; + synchronized (lock) { + return folderTotal; + } } - }