Signal/Android
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Android.git synced 2025-12-23 20:48:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Ensure MessageProcessReceiver pending result finished is called timely.

Browse Source
This commit is contained in:
Alan Evans
2021-02-12 11:24:12 -04:00
parent 050b59f09d
commit f6aaef1434
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/src/main/java/org/thoughtcrime/securesms/messageprocessingalarm/MessageProcessReceiver.java
View File

@@ -6,6 +6,8 @@ import android.app.PendingIntent;
import android.content.BroadcastReceiver; import android.content.BroadcastReceiver;
import android.content.Context; import android.content.Context;
import android.content.Intent; import android.content.Intent;
import android.os.Handler;
import android.os.Looper;
import android.os.SystemClock; import android.os.SystemClock;
import androidx.annotation.NonNull; import androidx.annotation.NonNull;
@@ -44,6 +46,8 @@ public final class MessageProcessReceiver extends BroadcastReceiver {
} else if (BROADCAST_ACTION.equals(intent.getAction())) { } else if (BROADCAST_ACTION.equals(intent.getAction())) {
PendingResult pendingResult = goAsync(); PendingResult pendingResult = goAsync();
new Handler(Looper.getMainLooper()).postDelayed(pendingResult::finish, JOB_TIMEOUT);
SignalExecutors.BOUNDED.submit(() -> { SignalExecutors.BOUNDED.submit(() -> {
Log.i(TAG, "Running PushNotificationReceiveJob"); Log.i(TAG, "Running PushNotificationReceiveJob");
@@ -51,8 +55,6 @@ public final class MessageProcessReceiver extends BroadcastReceiver {
.runSynchronously(PushNotificationReceiveJob.withDelayedForegroundService(FOREGROUND_DELAY), JOB_TIMEOUT); .runSynchronously(PushNotificationReceiveJob.withDelayedForegroundService(FOREGROUND_DELAY), JOB_TIMEOUT);
Log.i(TAG, "PushNotificationReceiveJob ended: " + (jobState.isPresent() ? jobState.get().toString() : "Job did not complete")); Log.i(TAG, "PushNotificationReceiveJob ended: " + (jobState.isPresent() ? jobState.get().toString() : "Job did not complete"));
pendingResult.finish();
}); });
} }
} }