filippodb/SchildiChat-android
1
0
Fork 0
mirror of https://github.com/SchildiChat/SchildiChat-android.git synced 2024-12-31 11:57:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Improve code

Browse Source
This commit is contained in:
Benoit Marty 2019-10-22 17:31:07 +02:00
parent f43dcb1183
commit 377a228f88
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/session/room/timeline/TimelineEventDecryptor.kt
View File

@ -39,8 +39,8 @@ internal class TimelineEventDecryptor(
override fun onNewSession(roomId: String?, senderKey: String, sessionId: String) {
synchronized(unknownSessionsFailure) {
unknownSessionsFailure[sessionId]
?.toList()
.orEmpty()
.toList()
.also {
unknownSessionsFailure[sessionId]?.clear()
}
@ -55,7 +55,7 @@ internal class TimelineEventDecryptor(
// Set of eventIds which are currently decrypting
private val existingRequests = mutableSetOf<String>()
// sessionId -> list of eventIds
private val unknownSessionsFailure = mutableMapOf<String, MutableList<String>>()
private val unknownSessionsFailure = mutableMapOf<String, MutableSet<String>>()
fun start() {
executor = Executors.newSingleThreadExecutor()
@ -84,11 +84,10 @@ internal class TimelineEventDecryptor(
}
}
synchronized(existingRequests) {
if (eventId in existingRequests) {
if (!existingRequests.add(eventId)) {
Timber.d("Skip Decryption request for event $eventId, already requested")
return
}
existingRequests.add(eventId)
}
executor?.execute {
Realm.getInstance(realmConfiguration).use { realm ->
@ -120,7 +119,7 @@ internal class TimelineEventDecryptor(
event.content?.toModel<EncryptedEventContent>()?.let { content ->
content.sessionId?.let { sessionId ->
synchronized(unknownSessionsFailure) {
val list = unknownSessionsFailure.getOrPut(sessionId) { ArrayList() }
val list = unknownSessionsFailure.getOrPut(sessionId) { mutableSetOf() }
list.add(eventId)
}
}