private Operation enqueueCheckInWorkRequest(boolean isExpedited, Duration delay) {
        OneTimeWorkRequest.Builder builder =
                new OneTimeWorkRequest.Builder(DeviceCheckInWorker.class

@Override
        public void onReceive(Context context, Intent intent) {
            mHandler.post(() -> {
                if (mIsApfShutdown) return;
                final PowerManager powerManager 

@Override
        public void onReceive(Context context, Intent intent) {
            switch (intent.getAction()) {
                case Intent.ACTION_SCREEN_ON:
                    onInteractiveState

public boolean canRunInDoze() {
        return appHasDozeExemption
                || (getFlags() & JobInfo.FLAG_WILL_BE_FOREGROUND) != 0
                || shouldTreatAsUserInitiatedJob()
           

package com.android.statementservice.domain

import android.content.BroadcastReceiver
import android.content.Context
import android.content.Intent
import androidx.work.Constraints
import androidx.work

void updateIdleMode(boolean enabled) {
        boolean changed = false;
        synchronized (mLock) {
            if (mDeviceIdleMode != enabled) {
                changed = true;
            }
     

private void maybeEnqueueFcmRegistrationTokenRetrievalWork(
            @Nullable String fcmRegistrationToken) {
        if (Strings.isNullOrEmpty(fcmRegistrationToken) || fcmRegistrationToken.isBlank

@Override
        public void performReceive(Intent intent, int resultCode, String data, Bundle extras,
                boolean ordered, boolean sticky, int sendingUser) {
            // When coming o

public static final class WorkFailureAlarmReceiver extends BroadcastReceiver {
        private final Executor mExecutor = Executors.newSingleThreadExecutor();

        @Override
        public void on

@Test
    public void testExemptedSyncScheduled() throws Exception {
        setAndAssertBucket(PACKAGE_1, USER_ID, STANDBY_BUCKET_RARE, REASON_MAIN_FORCED_BY_SYSTEM);
        mInjector.mDeviceIdleMod