blob: ca64d4f87140e792efd217610e8530bcfa0b1311 (
plain)
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
|
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
package org.mozilla.gecko.fxa.sync;
import java.util.Map;
import java.util.Map.Entry;
import java.util.WeakHashMap;
import org.mozilla.gecko.fxa.SyncStatusListener;
import org.mozilla.gecko.fxa.authenticator.AndroidFxAccount;
import org.mozilla.gecko.util.ThreadUtils;
import android.content.ContentResolver;
import android.content.SyncStatusObserver;
/**
* Abstract away some details of Android's SyncStatusObserver.
* <p>
* Provides a simplified sync started/sync finished delegate.
*/
public class FxAccountSyncStatusHelper implements SyncStatusObserver {
@SuppressWarnings("unused")
private static final String LOG_TAG = FxAccountSyncStatusHelper.class.getSimpleName();
protected static FxAccountSyncStatusHelper sInstance;
public synchronized static FxAccountSyncStatusHelper getInstance() {
if (sInstance == null) {
sInstance = new FxAccountSyncStatusHelper();
}
return sInstance;
}
// Used to unregister this as a listener.
protected Object handle;
// Maps delegates to whether their underlying Android account was syncing the
// last time we observed a status change.
protected Map<SyncStatusListener, Boolean> delegates = new WeakHashMap<SyncStatusListener, Boolean>();
@Override
public synchronized void onStatusChanged(int which) {
for (Entry<SyncStatusListener, Boolean> entry : delegates.entrySet()) {
final SyncStatusListener delegate = entry.getKey();
final AndroidFxAccount fxAccount = new AndroidFxAccount(delegate.getContext(), delegate.getAccount());
final boolean active = fxAccount.isCurrentlySyncing();
// Remember for later.
boolean wasActiveLastTime = entry.getValue();
// It's okay to update the value of an entry while iterating the entrySet.
entry.setValue(active);
if (active && !wasActiveLastTime) {
// We've started a sync.
ThreadUtils.postToUiThread(new Runnable() {
@Override
public void run() {
delegate.onSyncStarted();
}
});
}
if (!active && wasActiveLastTime) {
// We've finished a sync.
ThreadUtils.postToUiThread(new Runnable() {
@Override
public void run() {
delegate.onSyncFinished();
}
});
}
}
}
protected void addListener() {
final int mask = ContentResolver.SYNC_OBSERVER_TYPE_ACTIVE;
if (this.handle != null) {
throw new IllegalStateException("Already registered this as an observer?");
}
this.handle = ContentResolver.addStatusChangeListener(mask, this);
}
protected void removeListener() {
Object handle = this.handle;
this.handle = null;
if (handle != null) {
ContentResolver.removeStatusChangeListener(handle);
}
}
public synchronized void startObserving(SyncStatusListener delegate) {
if (delegate == null) {
throw new IllegalArgumentException("delegate must not be null");
}
if (delegates.containsKey(delegate)) {
return;
}
// If we are the first delegate to the party, start listening.
if (delegates.isEmpty()) {
addListener();
}
delegates.put(delegate, Boolean.FALSE);
}
public synchronized void stopObserving(SyncStatusListener delegate) {
delegates.remove(delegate);
// If we are the last delegate leaving the party, stop listening.
if (delegates.isEmpty()) {
removeListener();
}
}
}
|
