32
32
/*package*/ class StorageTaskManager {
33
33
private static final StorageTaskManager _instance = new StorageTaskManager ();
34
34
35
- private final Map <String , WeakReference <StorageTask >> inProgressTasks = new HashMap <>();
35
+ private final Map <String , WeakReference <StorageTask <?> >> inProgressTasks = new HashMap <>();
36
36
37
37
private final Object syncObject = new Object ();
38
38
@@ -44,7 +44,7 @@ public List<UploadTask> getUploadTasksUnder(@NonNull StorageReference parent) {
44
44
synchronized (syncObject ) {
45
45
ArrayList <UploadTask > inProgressList = new ArrayList <>();
46
46
String parentPath = parent .toString ();
47
- for (Map .Entry <String , WeakReference <StorageTask >> entry : inProgressTasks .entrySet ()) {
47
+ for (Map .Entry <String , WeakReference <StorageTask <?> >> entry : inProgressTasks .entrySet ()) {
48
48
if (entry .getKey ().startsWith (parentPath )) {
49
49
StorageTask task = entry .getValue ().get ();
50
50
if (task instanceof UploadTask ) {
@@ -60,9 +60,9 @@ public List<FileDownloadTask> getDownloadTasksUnder(@NonNull StorageReference pa
60
60
synchronized (syncObject ) {
61
61
ArrayList <FileDownloadTask > inProgressList = new ArrayList <>();
62
62
String parentPath = parent .toString ();
63
- for (Map .Entry <String , WeakReference <StorageTask >> entry : inProgressTasks .entrySet ()) {
63
+ for (Map .Entry <String , WeakReference <StorageTask <?> >> entry : inProgressTasks .entrySet ()) {
64
64
if (entry .getKey ().startsWith (parentPath )) {
65
- StorageTask task = entry .getValue ().get ();
65
+ StorageTask <?> task = entry .getValue ().get ();
66
66
if (task instanceof FileDownloadTask ) {
67
67
inProgressList .add ((FileDownloadTask ) task );
68
68
}
@@ -72,19 +72,19 @@ public List<FileDownloadTask> getDownloadTasksUnder(@NonNull StorageReference pa
72
72
}
73
73
}
74
74
75
- public void ensureRegistered (StorageTask targetTask ) {
75
+ public void ensureRegistered (StorageTask <?> targetTask ) {
76
76
synchronized (syncObject ) {
77
77
// ensure *this* is added to the in progress list
78
78
inProgressTasks .put (targetTask .getStorage ().toString (), new WeakReference <>(targetTask ));
79
79
}
80
80
}
81
81
82
- public void unRegister (StorageTask targetTask ) {
82
+ public void unRegister (StorageTask <?> targetTask ) {
83
83
synchronized (syncObject ) {
84
84
// ensure *this* is added to the in progress list
85
85
String key = targetTask .getStorage ().toString ();
86
- WeakReference <StorageTask > weakReference = inProgressTasks .get (key );
87
- StorageTask task = weakReference != null ? weakReference .get () : null ;
86
+ WeakReference <StorageTask <?> > weakReference = inProgressTasks .get (key );
87
+ StorageTask <?> task = weakReference != null ? weakReference .get () : null ;
88
88
if (task == null || task == targetTask ) {
89
89
inProgressTasks .remove (key );
90
90
}
0 commit comments