1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
/*
* Copyright (C) 2016 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.android.documentsui;
import static com.android.documentsui.base.SharedMinimal.DEBUG;
import android.content.ContentProviderClient;
import android.content.ContentResolver;
import android.content.Context;
import android.net.Uri;
import android.os.CancellationSignal;
import android.os.FileUtils;
import android.util.Log;
import androidx.annotation.Nullable;
import com.android.documentsui.base.ApplicationScope;
import com.android.documentsui.base.BooleanConsumer;
import com.android.documentsui.base.CheckedTask;
import com.android.documentsui.base.DocumentInfo;
import com.android.documentsui.base.Features;
import com.android.documentsui.base.State;
/**
* A {@link CheckedTask} that calls
* {@link ContentResolver#refresh(Uri, android.os.Bundle, android.os.CancellationSignal)} on the
* current directory, and then calls the supplied callback with the refresh return value.
*/
public class RefreshTask extends TimeoutTask<Void, Boolean> {
private final static String TAG = "RefreshTask";
private final @ApplicationScope Context mContext;
private final Features mFeatures;
private final State mState;
private final DocumentInfo mDoc;
private final BooleanConsumer mCallback;
private final CancellationSignal mSignal;
public RefreshTask(Features features, State state, DocumentInfo doc, long timeout,
@ApplicationScope Context context, Check check, BooleanConsumer callback) {
super(check, timeout);
mFeatures = features;
mState = state;
mDoc = doc;
mContext = context;
mCallback = callback;
mSignal = new CancellationSignal();
}
@Override
public @Nullable Boolean run(Void... params) {
if (mDoc == null) {
Log.w(TAG, "Ignoring attempt to refresh due to null DocumentInfo.");
return false;
}
if (mState.stack.isEmpty()) {
Log.w(TAG, "Ignoring attempt to refresh due to empty stack.");
return false;
}
if (mDoc.derivedUri == null) {
Log.w(TAG, "Ignoring attempt to refresh due to null derived uri in DocumentInfo.");
return false;
}
if (!mDoc.derivedUri.equals(mState.stack.peek().derivedUri)) {
Log.w(TAG, "Ignoring attempt to refresh on a non-top-level uri.");
return false;
}
if (!mState.canInteractWith(mDoc.userId) || mDoc.userId.isQuietModeEnabled(mContext)) {
// No result was returned by these errors so it does not support refresh.
Log.w(TAG, "Cannot refresh due to cross profile error.");
return false;
}
// API O introduces ContentResolver#refresh, and if available and the ContentProvider
// supports it, the ContentProvider will automatically send a content updated notification
// and we will update accordingly. Else, we just tell the callback that Refresh is not
// supported.
if (!mFeatures.isContentRefreshEnabled()) {
Log.w(TAG, "Ignoring attempt to call Refresh on an older Android platform.");
return false;
}
final ContentResolver resolver = mDoc.userId.getContentResolver(mContext);
final String authority = mDoc.authority;
boolean refreshSupported = false;
ContentProviderClient client = null;
try {
client = DocumentsApplication.acquireUnstableProviderOrThrow(resolver, authority);
refreshSupported = client.refresh(mDoc.derivedUri, null, mSignal);
} catch (Exception e) {
Log.w(TAG, "Failed to refresh", e);
} finally {
FileUtils.closeQuietly(client);
}
return refreshSupported;
}
@Override
protected void onTimeout() {
mSignal.cancel();
Log.w(TAG, "Provider taking too long to respond. Cancelling.");
}
@Override
public void finish(Boolean refreshSupported) {
if (DEBUG) {
// In case of timeout, refreshSupported is null.
if (Boolean.TRUE.equals(refreshSupported)) {
Log.v(TAG, "Provider supports refresh and has refreshed");
} else {
Log.v(TAG, "Provider does not support refresh and did not refresh");
}
}
mCallback.accept(refreshSupported != null ? refreshSupported : Boolean.FALSE);
}
}
|