@@ -95,7 +95,7 @@ class ArchiveAttachmentReconciliationJob private constructor(
95
95
}
96
96
97
97
if (SignalStore .backup.lastAttachmentReconciliationTime < 0 ) {
98
- Log .w(TAG , " First ever time we're attempting a reconciliation. Setting the last sync time to now, so we'll run at the proper interval. Skipping this iteration." )
98
+ Log .w(TAG , " First ever time we're attempting a reconciliation. Setting the last sync time to now, so we'll run at the proper interval. Skipping this iteration." , true )
99
99
SignalStore .backup.lastAttachmentReconciliationTime = System .currentTimeMillis()
100
100
return Result .success()
101
101
}
@@ -127,7 +127,7 @@ class ArchiveAttachmentReconciliationJob private constructor(
127
127
private fun syncDataFromCdn (snapshotVersion : Long ): Result ? {
128
128
do {
129
129
if (isCanceled) {
130
- Log .w(TAG , " Job cancelled while syncing archived attachments from the CDN." )
130
+ Log .w(TAG , " Job cancelled while syncing archived attachments from the CDN." , true )
131
131
return Result .failure()
132
132
}
133
133
@@ -145,11 +145,11 @@ class ArchiveAttachmentReconciliationJob private constructor(
145
145
} while (serverCursor != null )
146
146
147
147
if (isCanceled) {
148
- Log .w(TAG , " Job cancelled while syncing archived attachments from the CDN." )
148
+ Log .w(TAG , " Job cancelled while syncing archived attachments from the CDN." , true )
149
149
return Result .failure()
150
150
}
151
151
152
- Log .d(TAG , " BEFORE:\n " + SignalDatabase .attachments.debugGetAttachmentStats().prettyString())
152
+ Log .d(TAG , " BEFORE:\n " + SignalDatabase .attachments.debugGetAttachmentStats().prettyString(), true )
153
153
154
154
val mediaObjectsThatMayNeedReUpload = SignalDatabase .backupMediaSnapshots.getMediaObjectsLastSeenOnCdnBeforeSnapshotVersion(snapshotVersion)
155
155
val mayNeedReUploadCount = mediaObjectsThatMayNeedReUpload.count
@@ -200,10 +200,10 @@ class ArchiveAttachmentReconciliationJob private constructor(
200
200
Log .i(TAG , " None of the $mayNeedReUploadCount CDN mismatches were bookkeeping errors." , true )
201
201
}
202
202
203
- Log .d(TAG , " AFTER:\n " + SignalDatabase .attachments.debugGetAttachmentStats().prettyString())
203
+ Log .d(TAG , " AFTER:\n " + SignalDatabase .attachments.debugGetAttachmentStats().prettyString(), true )
204
204
205
205
if (internalUser && mediaIdsThatNeedUpload.isNotEmpty()) {
206
- Log .w(TAG , " Starting internal-only lookup of matching attachments. May take a while!" )
206
+ Log .w(TAG , " Starting internal-only lookup of matching attachments. May take a while!" , true )
207
207
208
208
val matchingAttachments = SignalDatabase .attachments.debugGetAttachmentsForMediaIds(mediaIdsThatNeedUpload, limit = 10_000 )
209
209
Log .w(TAG , " Found ${matchingAttachments.size} out of the ${mediaIdsThatNeedUpload.size} attachments we looked up (capped lookups to 10k)." , true )
@@ -212,9 +212,9 @@ class ArchiveAttachmentReconciliationJob private constructor(
212
212
val (attachment, isThumbnail) = pair
213
213
if (isThumbnail) {
214
214
val thumbnailTransferState = SignalDatabase .attachments.getArchiveThumbnailTransferState(attachment.attachmentId)
215
- Log .w(TAG , " [Thumbnail] Needed Upload: attachmentId=${attachment.attachmentId} , messageId=${attachment.mmsId} , contentType=${attachment.contentType} , quote=${attachment.quote} , transferState=${attachment.transferState} , archiveTransferState=${attachment.archiveTransferState} , archiveThumbnailTransferState=$thumbnailTransferState , hasData=${attachment.hasData} " )
215
+ Log .w(TAG , " [Thumbnail] Needed Upload: attachmentId=${attachment.attachmentId} , messageId=${attachment.mmsId} , contentType=${attachment.contentType} , quote=${attachment.quote} , transferState=${attachment.transferState} , archiveTransferState=${attachment.archiveTransferState} , archiveThumbnailTransferState=$thumbnailTransferState , hasData=${attachment.hasData} " , true )
216
216
} else {
217
- Log .w(TAG , " [Fullsize] Needed Upload: attachmentId=${attachment.attachmentId} , messageId=${attachment.mmsId} , contentType=${attachment.contentType} , quote=${attachment.quote} , transferState=${attachment.transferState} , archiveTransferState=${attachment.archiveTransferState} , hasData=${attachment.hasData} " )
217
+ Log .w(TAG , " [Fullsize] Needed Upload: attachmentId=${attachment.attachmentId} , messageId=${attachment.mmsId} , contentType=${attachment.contentType} , quote=${attachment.quote} , transferState=${attachment.transferState} , archiveTransferState=${attachment.archiveTransferState} , hasData=${attachment.hasData} " , true )
218
218
}
219
219
}
220
220
}
@@ -234,7 +234,7 @@ class ArchiveAttachmentReconciliationJob private constructor(
234
234
}
235
235
}
236
236
} else {
237
- Log .d(TAG , " No attachments need to be repaired." )
237
+ Log .d(TAG , " No attachments need to be repaired." , true )
238
238
}
239
239
240
240
SignalStore .backup.remoteStorageGarbageCollectionPending = false
0 commit comments